mirror of
https://github.com/chirpstack/chirpstack.git
synced 2025-01-30 15:43:53 +00:00
api: Add BackendInterfacesRequest stream message.
This commit is contained in:
Orne Brocaar
parent
36e6d5ccb9
commit
6931e9adb5
1
api/csharp/Chirpstack.Api.csproj
vendored
1
api/csharp/Chirpstack.Api.csproj
vendored
@ -23,6 +23,7 @@
|
|||||||
<Protobuf Include="../proto/stream/meta.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
<Protobuf Include="../proto/stream/meta.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
||||||
<Protobuf Include="../proto/stream/frame.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
<Protobuf Include="../proto/stream/frame.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
||||||
<Protobuf Include="../proto/stream/api_request.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
<Protobuf Include="../proto/stream/api_request.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
||||||
|
<Protobuf Include="../proto/stream/backend_interfaces.proto" ProtoRoot="../proto/" OutputDir="Chirpstack/" CompileOutputs="false" AdditionalImportDirs="/googleproto" />
|
||||||
<Protobuf Include="/googleproto/google/api/*.proto" ProtoRoot="/googleproto" OutputDir="Chirpstack/" CompileOutputs="false" />
|
<Protobuf Include="/googleproto/google/api/*.proto" ProtoRoot="/googleproto" OutputDir="Chirpstack/" CompileOutputs="false" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
|
|||||||
573
api/csharp/Chirpstack/stream/BackendInterfaces.cs
vendored
Normal file
573
api/csharp/Chirpstack/stream/BackendInterfaces.cs
vendored
Normal file
@ -0,0 +1,573 @@
|
|||||||
|
// <auto-generated>
|
||||||
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
// source: stream/backend_interfaces.proto
|
||||||
|
// </auto-generated>
|
||||||
|
#pragma warning disable 1591, 0612, 3021, 8981
|
||||||
|
#region Designer generated code
|
||||||
|
|
||||||
|
using pb = global::Google.Protobuf;
|
||||||
|
using pbc = global::Google.Protobuf.Collections;
|
||||||
|
using pbr = global::Google.Protobuf.Reflection;
|
||||||
|
using scg = global::System.Collections.Generic;
|
||||||
|
namespace Chirpstack.Stream {
|
||||||
|
|
||||||
|
/// <summary>Holder for reflection information generated from stream/backend_interfaces.proto</summary>
|
||||||
|
public static partial class BackendInterfacesReflection {
|
||||||
|
|
||||||
|
#region Descriptor
|
||||||
|
/// <summary>File descriptor for stream/backend_interfaces.proto</summary>
|
||||||
|
public static pbr::FileDescriptor Descriptor {
|
||||||
|
get { return descriptor; }
|
||||||
|
}
|
||||||
|
private static pbr::FileDescriptor descriptor;
|
||||||
|
|
||||||
|
static BackendInterfacesReflection() {
|
||||||
|
byte[] descriptorData = global::System.Convert.FromBase64String(
|
||||||
|
string.Concat(
|
||||||
|
"Ch9zdHJlYW0vYmFja2VuZF9pbnRlcmZhY2VzLnByb3RvEgZzdHJlYW0aH2dv",
|
||||||
|
"b2dsZS9wcm90b2J1Zi90aW1lc3RhbXAucHJvdG8i8wEKGEJhY2tlbmRJbnRl",
|
||||||
|
"cmZhY2VzUmVxdWVzdBIRCglzZW5kZXJfaWQYASABKAkSEwoLcmVjZWl2ZXJf",
|
||||||
|
"aWQYAiABKAkSKAoEdGltZRgDIAEoCzIaLmdvb2dsZS5wcm90b2J1Zi5UaW1l",
|
||||||
|
"c3RhbXASFgoOdHJhbnNhY3Rpb25faWQYBCABKA0SFAoMbWVzc2FnZV90eXBl",
|
||||||
|
"GAUgASgJEhMKC3Jlc3VsdF9jb2RlGAYgASgJEhQKDHJlcXVlc3RfYm9keRgH",
|
||||||
|
"IAEoCRIVCg1yZXF1ZXN0X2Vycm9yGAggASgJEhUKDXJlc3BvbnNlX2JvZHkY",
|
||||||
|
"CSABKAlCewoYaW8uY2hpcnBzdGFjay5hcGkuc3RyZWFtQhZCYWNrZW5kSW50",
|
||||||
|
"ZXJmYWNlc1Byb3RvUAFaMWdpdGh1Yi5jb20vY2hpcnBzdGFjay9jaGlycHN0",
|
||||||
|
"YWNrL2FwaS9nby92NC9zdHJlYW2qAhFDaGlycHN0YWNrLlN0cmVhbWIGcHJv",
|
||||||
|
"dG8z"));
|
||||||
|
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
|
||||||
|
new pbr::FileDescriptor[] { global::Google.Protobuf.WellKnownTypes.TimestampReflection.Descriptor, },
|
||||||
|
new pbr::GeneratedClrTypeInfo(null, null, new pbr::GeneratedClrTypeInfo[] {
|
||||||
|
new pbr::GeneratedClrTypeInfo(typeof(global::Chirpstack.Stream.BackendInterfacesRequest), global::Chirpstack.Stream.BackendInterfacesRequest.Parser, new[]{ "SenderId", "ReceiverId", "Time", "TransactionId", "MessageType", "ResultCode", "RequestBody", "RequestError", "ResponseBody" }, null, null, null, null)
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
}
|
||||||
|
#region Messages
|
||||||
|
public sealed partial class BackendInterfacesRequest : pb::IMessage<BackendInterfacesRequest>
|
||||||
|
#if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
|
||||||
|
, pb::IBufferMessage
|
||||||
|
#endif
|
||||||
|
{
|
||||||
|
private static readonly pb::MessageParser<BackendInterfacesRequest> _parser = new pb::MessageParser<BackendInterfacesRequest>(() => new BackendInterfacesRequest());
|
||||||
|
private pb::UnknownFieldSet _unknownFields;
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public static pb::MessageParser<BackendInterfacesRequest> Parser { get { return _parser; } }
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public static pbr::MessageDescriptor Descriptor {
|
||||||
|
get { return global::Chirpstack.Stream.BackendInterfacesReflection.Descriptor.MessageTypes[0]; }
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor {
|
||||||
|
get { return Descriptor; }
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public BackendInterfacesRequest() {
|
||||||
|
OnConstruction();
|
||||||
|
}
|
||||||
|
|
||||||
|
partial void OnConstruction();
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public BackendInterfacesRequest(BackendInterfacesRequest other) : this() {
|
||||||
|
senderId_ = other.senderId_;
|
||||||
|
receiverId_ = other.receiverId_;
|
||||||
|
time_ = other.time_ != null ? other.time_.Clone() : null;
|
||||||
|
transactionId_ = other.transactionId_;
|
||||||
|
messageType_ = other.messageType_;
|
||||||
|
resultCode_ = other.resultCode_;
|
||||||
|
requestBody_ = other.requestBody_;
|
||||||
|
requestError_ = other.requestError_;
|
||||||
|
responseBody_ = other.responseBody_;
|
||||||
|
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public BackendInterfacesRequest Clone() {
|
||||||
|
return new BackendInterfacesRequest(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "sender_id" field.</summary>
|
||||||
|
public const int SenderIdFieldNumber = 1;
|
||||||
|
private string senderId_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Sender ID.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string SenderId {
|
||||||
|
get { return senderId_; }
|
||||||
|
set {
|
||||||
|
senderId_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "receiver_id" field.</summary>
|
||||||
|
public const int ReceiverIdFieldNumber = 2;
|
||||||
|
private string receiverId_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Receiver ID.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string ReceiverId {
|
||||||
|
get { return receiverId_; }
|
||||||
|
set {
|
||||||
|
receiverId_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "time" field.</summary>
|
||||||
|
public const int TimeFieldNumber = 3;
|
||||||
|
private global::Google.Protobuf.WellKnownTypes.Timestamp time_;
|
||||||
|
/// <summary>
|
||||||
|
/// Timestamp.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public global::Google.Protobuf.WellKnownTypes.Timestamp Time {
|
||||||
|
get { return time_; }
|
||||||
|
set {
|
||||||
|
time_ = value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "transaction_id" field.</summary>
|
||||||
|
public const int TransactionIdFieldNumber = 4;
|
||||||
|
private uint transactionId_;
|
||||||
|
/// <summary>
|
||||||
|
/// Transaction ID.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public uint TransactionId {
|
||||||
|
get { return transactionId_; }
|
||||||
|
set {
|
||||||
|
transactionId_ = value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "message_type" field.</summary>
|
||||||
|
public const int MessageTypeFieldNumber = 5;
|
||||||
|
private string messageType_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Message-type.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string MessageType {
|
||||||
|
get { return messageType_; }
|
||||||
|
set {
|
||||||
|
messageType_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "result_code" field.</summary>
|
||||||
|
public const int ResultCodeFieldNumber = 6;
|
||||||
|
private string resultCode_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Result code.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string ResultCode {
|
||||||
|
get { return resultCode_; }
|
||||||
|
set {
|
||||||
|
resultCode_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "request_body" field.</summary>
|
||||||
|
public const int RequestBodyFieldNumber = 7;
|
||||||
|
private string requestBody_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Request body.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string RequestBody {
|
||||||
|
get { return requestBody_; }
|
||||||
|
set {
|
||||||
|
requestBody_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "request_error" field.</summary>
|
||||||
|
public const int RequestErrorFieldNumber = 8;
|
||||||
|
private string requestError_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Request error.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string RequestError {
|
||||||
|
get { return requestError_; }
|
||||||
|
set {
|
||||||
|
requestError_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Field number for the "response_body" field.</summary>
|
||||||
|
public const int ResponseBodyFieldNumber = 9;
|
||||||
|
private string responseBody_ = "";
|
||||||
|
/// <summary>
|
||||||
|
/// Response body.
|
||||||
|
/// </summary>
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public string ResponseBody {
|
||||||
|
get { return responseBody_; }
|
||||||
|
set {
|
||||||
|
responseBody_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public override bool Equals(object other) {
|
||||||
|
return Equals(other as BackendInterfacesRequest);
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public bool Equals(BackendInterfacesRequest other) {
|
||||||
|
if (ReferenceEquals(other, null)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (ReferenceEquals(other, this)) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
if (SenderId != other.SenderId) return false;
|
||||||
|
if (ReceiverId != other.ReceiverId) return false;
|
||||||
|
if (!object.Equals(Time, other.Time)) return false;
|
||||||
|
if (TransactionId != other.TransactionId) return false;
|
||||||
|
if (MessageType != other.MessageType) return false;
|
||||||
|
if (ResultCode != other.ResultCode) return false;
|
||||||
|
if (RequestBody != other.RequestBody) return false;
|
||||||
|
if (RequestError != other.RequestError) return false;
|
||||||
|
if (ResponseBody != other.ResponseBody) return false;
|
||||||
|
return Equals(_unknownFields, other._unknownFields);
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public override int GetHashCode() {
|
||||||
|
int hash = 1;
|
||||||
|
if (SenderId.Length != 0) hash ^= SenderId.GetHashCode();
|
||||||
|
if (ReceiverId.Length != 0) hash ^= ReceiverId.GetHashCode();
|
||||||
|
if (time_ != null) hash ^= Time.GetHashCode();
|
||||||
|
if (TransactionId != 0) hash ^= TransactionId.GetHashCode();
|
||||||
|
if (MessageType.Length != 0) hash ^= MessageType.GetHashCode();
|
||||||
|
if (ResultCode.Length != 0) hash ^= ResultCode.GetHashCode();
|
||||||
|
if (RequestBody.Length != 0) hash ^= RequestBody.GetHashCode();
|
||||||
|
if (RequestError.Length != 0) hash ^= RequestError.GetHashCode();
|
||||||
|
if (ResponseBody.Length != 0) hash ^= ResponseBody.GetHashCode();
|
||||||
|
if (_unknownFields != null) {
|
||||||
|
hash ^= _unknownFields.GetHashCode();
|
||||||
|
}
|
||||||
|
return hash;
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public override string ToString() {
|
||||||
|
return pb::JsonFormatter.ToDiagnosticString(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public void WriteTo(pb::CodedOutputStream output) {
|
||||||
|
#if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
|
||||||
|
output.WriteRawMessage(this);
|
||||||
|
#else
|
||||||
|
if (SenderId.Length != 0) {
|
||||||
|
output.WriteRawTag(10);
|
||||||
|
output.WriteString(SenderId);
|
||||||
|
}
|
||||||
|
if (ReceiverId.Length != 0) {
|
||||||
|
output.WriteRawTag(18);
|
||||||
|
output.WriteString(ReceiverId);
|
||||||
|
}
|
||||||
|
if (time_ != null) {
|
||||||
|
output.WriteRawTag(26);
|
||||||
|
output.WriteMessage(Time);
|
||||||
|
}
|
||||||
|
if (TransactionId != 0) {
|
||||||
|
output.WriteRawTag(32);
|
||||||
|
output.WriteUInt32(TransactionId);
|
||||||
|
}
|
||||||
|
if (MessageType.Length != 0) {
|
||||||
|
output.WriteRawTag(42);
|
||||||
|
output.WriteString(MessageType);
|
||||||
|
}
|
||||||
|
if (ResultCode.Length != 0) {
|
||||||
|
output.WriteRawTag(50);
|
||||||
|
output.WriteString(ResultCode);
|
||||||
|
}
|
||||||
|
if (RequestBody.Length != 0) {
|
||||||
|
output.WriteRawTag(58);
|
||||||
|
output.WriteString(RequestBody);
|
||||||
|
}
|
||||||
|
if (RequestError.Length != 0) {
|
||||||
|
output.WriteRawTag(66);
|
||||||
|
output.WriteString(RequestError);
|
||||||
|
}
|
||||||
|
if (ResponseBody.Length != 0) {
|
||||||
|
output.WriteRawTag(74);
|
||||||
|
output.WriteString(ResponseBody);
|
||||||
|
}
|
||||||
|
if (_unknownFields != null) {
|
||||||
|
_unknownFields.WriteTo(output);
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
#if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
void pb::IBufferMessage.InternalWriteTo(ref pb::WriteContext output) {
|
||||||
|
if (SenderId.Length != 0) {
|
||||||
|
output.WriteRawTag(10);
|
||||||
|
output.WriteString(SenderId);
|
||||||
|
}
|
||||||
|
if (ReceiverId.Length != 0) {
|
||||||
|
output.WriteRawTag(18);
|
||||||
|
output.WriteString(ReceiverId);
|
||||||
|
}
|
||||||
|
if (time_ != null) {
|
||||||
|
output.WriteRawTag(26);
|
||||||
|
output.WriteMessage(Time);
|
||||||
|
}
|
||||||
|
if (TransactionId != 0) {
|
||||||
|
output.WriteRawTag(32);
|
||||||
|
output.WriteUInt32(TransactionId);
|
||||||
|
}
|
||||||
|
if (MessageType.Length != 0) {
|
||||||
|
output.WriteRawTag(42);
|
||||||
|
output.WriteString(MessageType);
|
||||||
|
}
|
||||||
|
if (ResultCode.Length != 0) {
|
||||||
|
output.WriteRawTag(50);
|
||||||
|
output.WriteString(ResultCode);
|
||||||
|
}
|
||||||
|
if (RequestBody.Length != 0) {
|
||||||
|
output.WriteRawTag(58);
|
||||||
|
output.WriteString(RequestBody);
|
||||||
|
}
|
||||||
|
if (RequestError.Length != 0) {
|
||||||
|
output.WriteRawTag(66);
|
||||||
|
output.WriteString(RequestError);
|
||||||
|
}
|
||||||
|
if (ResponseBody.Length != 0) {
|
||||||
|
output.WriteRawTag(74);
|
||||||
|
output.WriteString(ResponseBody);
|
||||||
|
}
|
||||||
|
if (_unknownFields != null) {
|
||||||
|
_unknownFields.WriteTo(ref output);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public int CalculateSize() {
|
||||||
|
int size = 0;
|
||||||
|
if (SenderId.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(SenderId);
|
||||||
|
}
|
||||||
|
if (ReceiverId.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(ReceiverId);
|
||||||
|
}
|
||||||
|
if (time_ != null) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeMessageSize(Time);
|
||||||
|
}
|
||||||
|
if (TransactionId != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeUInt32Size(TransactionId);
|
||||||
|
}
|
||||||
|
if (MessageType.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(MessageType);
|
||||||
|
}
|
||||||
|
if (ResultCode.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(ResultCode);
|
||||||
|
}
|
||||||
|
if (RequestBody.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(RequestBody);
|
||||||
|
}
|
||||||
|
if (RequestError.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(RequestError);
|
||||||
|
}
|
||||||
|
if (ResponseBody.Length != 0) {
|
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(ResponseBody);
|
||||||
|
}
|
||||||
|
if (_unknownFields != null) {
|
||||||
|
size += _unknownFields.CalculateSize();
|
||||||
|
}
|
||||||
|
return size;
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public void MergeFrom(BackendInterfacesRequest other) {
|
||||||
|
if (other == null) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if (other.SenderId.Length != 0) {
|
||||||
|
SenderId = other.SenderId;
|
||||||
|
}
|
||||||
|
if (other.ReceiverId.Length != 0) {
|
||||||
|
ReceiverId = other.ReceiverId;
|
||||||
|
}
|
||||||
|
if (other.time_ != null) {
|
||||||
|
if (time_ == null) {
|
||||||
|
Time = new global::Google.Protobuf.WellKnownTypes.Timestamp();
|
||||||
|
}
|
||||||
|
Time.MergeFrom(other.Time);
|
||||||
|
}
|
||||||
|
if (other.TransactionId != 0) {
|
||||||
|
TransactionId = other.TransactionId;
|
||||||
|
}
|
||||||
|
if (other.MessageType.Length != 0) {
|
||||||
|
MessageType = other.MessageType;
|
||||||
|
}
|
||||||
|
if (other.ResultCode.Length != 0) {
|
||||||
|
ResultCode = other.ResultCode;
|
||||||
|
}
|
||||||
|
if (other.RequestBody.Length != 0) {
|
||||||
|
RequestBody = other.RequestBody;
|
||||||
|
}
|
||||||
|
if (other.RequestError.Length != 0) {
|
||||||
|
RequestError = other.RequestError;
|
||||||
|
}
|
||||||
|
if (other.ResponseBody.Length != 0) {
|
||||||
|
ResponseBody = other.ResponseBody;
|
||||||
|
}
|
||||||
|
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
|
||||||
|
}
|
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
public void MergeFrom(pb::CodedInputStream input) {
|
||||||
|
#if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
|
||||||
|
input.ReadRawMessage(this);
|
||||||
|
#else
|
||||||
|
uint tag;
|
||||||
|
while ((tag = input.ReadTag()) != 0) {
|
||||||
|
switch(tag) {
|
||||||
|
default:
|
||||||
|
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input);
|
||||||
|
break;
|
||||||
|
case 10: {
|
||||||
|
SenderId = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 18: {
|
||||||
|
ReceiverId = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 26: {
|
||||||
|
if (time_ == null) {
|
||||||
|
Time = new global::Google.Protobuf.WellKnownTypes.Timestamp();
|
||||||
|
}
|
||||||
|
input.ReadMessage(Time);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 32: {
|
||||||
|
TransactionId = input.ReadUInt32();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 42: {
|
||||||
|
MessageType = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 50: {
|
||||||
|
ResultCode = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 58: {
|
||||||
|
RequestBody = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 66: {
|
||||||
|
RequestError = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 74: {
|
||||||
|
ResponseBody = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
#if !GOOGLE_PROTOBUF_REFSTRUCT_COMPATIBILITY_MODE
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
|
||||||
|
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
|
||||||
|
void pb::IBufferMessage.InternalMergeFrom(ref pb::ParseContext input) {
|
||||||
|
uint tag;
|
||||||
|
while ((tag = input.ReadTag()) != 0) {
|
||||||
|
switch(tag) {
|
||||||
|
default:
|
||||||
|
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, ref input);
|
||||||
|
break;
|
||||||
|
case 10: {
|
||||||
|
SenderId = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 18: {
|
||||||
|
ReceiverId = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 26: {
|
||||||
|
if (time_ == null) {
|
||||||
|
Time = new global::Google.Protobuf.WellKnownTypes.Timestamp();
|
||||||
|
}
|
||||||
|
input.ReadMessage(Time);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 32: {
|
||||||
|
TransactionId = input.ReadUInt32();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 42: {
|
||||||
|
MessageType = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 50: {
|
||||||
|
ResultCode = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 58: {
|
||||||
|
RequestBody = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 66: {
|
||||||
|
RequestError = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case 74: {
|
||||||
|
ResponseBody = input.ReadString();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion Designer generated code
|
||||||
1
api/go/Makefile
vendored
1
api/go/Makefile
vendored
@ -34,3 +34,4 @@ stream:
|
|||||||
protoc ${PROTOC_ARGS} stream/meta.proto
|
protoc ${PROTOC_ARGS} stream/meta.proto
|
||||||
protoc ${PROTOC_ARGS} stream/frame.proto
|
protoc ${PROTOC_ARGS} stream/frame.proto
|
||||||
protoc ${PROTOC_ARGS} stream/api_request.proto
|
protoc ${PROTOC_ARGS} stream/api_request.proto
|
||||||
|
protoc ${PROTOC_ARGS} stream/backend_interfaces.proto
|
||||||
|
|||||||
248
api/go/stream/backend_interfaces.pb.go
vendored
Normal file
248
api/go/stream/backend_interfaces.pb.go
vendored
Normal file
@ -0,0 +1,248 @@
|
|||||||
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
|
// versions:
|
||||||
|
// protoc-gen-go v1.31.0
|
||||||
|
// protoc v3.21.9
|
||||||
|
// source: stream/backend_interfaces.proto
|
||||||
|
|
||||||
|
package stream
|
||||||
|
|
||||||
|
import (
|
||||||
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||||
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||||
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
||||||
|
reflect "reflect"
|
||||||
|
sync "sync"
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
// Verify that this generated code is sufficiently up-to-date.
|
||||||
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
||||||
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
||||||
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
||||||
|
)
|
||||||
|
|
||||||
|
type BackendInterfacesRequest struct {
|
||||||
|
state protoimpl.MessageState
|
||||||
|
sizeCache protoimpl.SizeCache
|
||||||
|
unknownFields protoimpl.UnknownFields
|
||||||
|
|
||||||
|
// Sender ID.
|
||||||
|
SenderId string `protobuf:"bytes,1,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
|
||||||
|
// Receiver ID.
|
||||||
|
ReceiverId string `protobuf:"bytes,2,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
|
||||||
|
// Timestamp.
|
||||||
|
Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
|
||||||
|
// Transaction ID.
|
||||||
|
TransactionId uint32 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
|
||||||
|
// Message-type.
|
||||||
|
MessageType string `protobuf:"bytes,5,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
|
||||||
|
// Result code.
|
||||||
|
ResultCode string `protobuf:"bytes,6,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
|
||||||
|
// Request body.
|
||||||
|
RequestBody string `protobuf:"bytes,7,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
|
||||||
|
// Request error.
|
||||||
|
RequestError string `protobuf:"bytes,8,opt,name=request_error,json=requestError,proto3" json:"request_error,omitempty"`
|
||||||
|
// Response body.
|
||||||
|
ResponseBody string `protobuf:"bytes,9,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) Reset() {
|
||||||
|
*x = BackendInterfacesRequest{}
|
||||||
|
if protoimpl.UnsafeEnabled {
|
||||||
|
mi := &file_stream_backend_interfaces_proto_msgTypes[0]
|
||||||
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||||
|
ms.StoreMessageInfo(mi)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) String() string {
|
||||||
|
return protoimpl.X.MessageStringOf(x)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (*BackendInterfacesRequest) ProtoMessage() {}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) ProtoReflect() protoreflect.Message {
|
||||||
|
mi := &file_stream_backend_interfaces_proto_msgTypes[0]
|
||||||
|
if protoimpl.UnsafeEnabled && x != nil {
|
||||||
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||||
|
if ms.LoadMessageInfo() == nil {
|
||||||
|
ms.StoreMessageInfo(mi)
|
||||||
|
}
|
||||||
|
return ms
|
||||||
|
}
|
||||||
|
return mi.MessageOf(x)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Deprecated: Use BackendInterfacesRequest.ProtoReflect.Descriptor instead.
|
||||||
|
func (*BackendInterfacesRequest) Descriptor() ([]byte, []int) {
|
||||||
|
return file_stream_backend_interfaces_proto_rawDescGZIP(), []int{0}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetSenderId() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.SenderId
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetReceiverId() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.ReceiverId
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetTime() *timestamppb.Timestamp {
|
||||||
|
if x != nil {
|
||||||
|
return x.Time
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetTransactionId() uint32 {
|
||||||
|
if x != nil {
|
||||||
|
return x.TransactionId
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetMessageType() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.MessageType
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetResultCode() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.ResultCode
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetRequestBody() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.RequestBody
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetRequestError() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.RequestError
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func (x *BackendInterfacesRequest) GetResponseBody() string {
|
||||||
|
if x != nil {
|
||||||
|
return x.ResponseBody
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
var File_stream_backend_interfaces_proto protoreflect.FileDescriptor
|
||||||
|
|
||||||
|
var file_stream_backend_interfaces_proto_rawDesc = []byte{
|
||||||
|
0x0a, 0x1f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64,
|
||||||
|
0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x66, 0x61, 0x63, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74,
|
||||||
|
0x6f, 0x12, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
|
||||||
|
0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73,
|
||||||
|
0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xe0, 0x02, 0x0a, 0x18, 0x42,
|
||||||
|
0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x66, 0x61, 0x63, 0x65, 0x73,
|
||||||
|
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x65, 0x6e, 0x64, 0x65,
|
||||||
|
0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x6e, 0x64,
|
||||||
|
0x65, 0x72, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x72,
|
||||||
|
0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x72, 0x65, 0x63, 0x65, 0x69,
|
||||||
|
0x76, 0x65, 0x72, 0x49, 0x64, 0x12, 0x2e, 0x0a, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20,
|
||||||
|
0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
|
||||||
|
0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52,
|
||||||
|
0x04, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63,
|
||||||
|
0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x74,
|
||||||
|
0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x0c,
|
||||||
|
0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01,
|
||||||
|
0x28, 0x09, 0x52, 0x0b, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12,
|
||||||
|
0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x06,
|
||||||
|
0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x43, 0x6f, 0x64, 0x65,
|
||||||
|
0x12, 0x21, 0x0a, 0x0c, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x62, 0x6f, 0x64, 0x79,
|
||||||
|
0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x42,
|
||||||
|
0x6f, 0x64, 0x79, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x65,
|
||||||
|
0x72, 0x72, 0x6f, 0x72, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x72, 0x65, 0x71, 0x75,
|
||||||
|
0x65, 0x73, 0x74, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70,
|
||||||
|
0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52,
|
||||||
|
0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x6f, 0x64, 0x79, 0x42, 0x7b, 0x0a,
|
||||||
|
0x18, 0x69, 0x6f, 0x2e, 0x63, 0x68, 0x69, 0x72, 0x70, 0x73, 0x74, 0x61, 0x63, 0x6b, 0x2e, 0x61,
|
||||||
|
0x70, 0x69, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x16, 0x42, 0x61, 0x63, 0x6b, 0x65,
|
||||||
|
0x6e, 0x64, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x66, 0x61, 0x63, 0x65, 0x73, 0x50, 0x72, 0x6f, 0x74,
|
||||||
|
0x6f, 0x50, 0x01, 0x5a, 0x31, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
|
||||||
|
0x63, 0x68, 0x69, 0x72, 0x70, 0x73, 0x74, 0x61, 0x63, 0x6b, 0x2f, 0x63, 0x68, 0x69, 0x72, 0x70,
|
||||||
|
0x73, 0x74, 0x61, 0x63, 0x6b, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f, 0x2f, 0x76, 0x34, 0x2f,
|
||||||
|
0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0xaa, 0x02, 0x11, 0x43, 0x68, 0x69, 0x72, 0x70, 0x73, 0x74,
|
||||||
|
0x61, 0x63, 0x6b, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
|
||||||
|
0x6f, 0x33,
|
||||||
|
}
|
||||||
|
|
||||||
|
var (
|
||||||
|
file_stream_backend_interfaces_proto_rawDescOnce sync.Once
|
||||||
|
file_stream_backend_interfaces_proto_rawDescData = file_stream_backend_interfaces_proto_rawDesc
|
||||||
|
)
|
||||||
|
|
||||||
|
func file_stream_backend_interfaces_proto_rawDescGZIP() []byte {
|
||||||
|
file_stream_backend_interfaces_proto_rawDescOnce.Do(func() {
|
||||||
|
file_stream_backend_interfaces_proto_rawDescData = protoimpl.X.CompressGZIP(file_stream_backend_interfaces_proto_rawDescData)
|
||||||
|
})
|
||||||
|
return file_stream_backend_interfaces_proto_rawDescData
|
||||||
|
}
|
||||||
|
|
||||||
|
var file_stream_backend_interfaces_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
|
||||||
|
var file_stream_backend_interfaces_proto_goTypes = []interface{}{
|
||||||
|
(*BackendInterfacesRequest)(nil), // 0: stream.BackendInterfacesRequest
|
||||||
|
(*timestamppb.Timestamp)(nil), // 1: google.protobuf.Timestamp
|
||||||
|
}
|
||||||
|
var file_stream_backend_interfaces_proto_depIdxs = []int32{
|
||||||
|
1, // 0: stream.BackendInterfacesRequest.time:type_name -> google.protobuf.Timestamp
|
||||||
|
1, // [1:1] is the sub-list for method output_type
|
||||||
|
1, // [1:1] is the sub-list for method input_type
|
||||||
|
1, // [1:1] is the sub-list for extension type_name
|
||||||
|
1, // [1:1] is the sub-list for extension extendee
|
||||||
|
0, // [0:1] is the sub-list for field type_name
|
||||||
|
}
|
||||||
|
|
||||||
|
func init() { file_stream_backend_interfaces_proto_init() }
|
||||||
|
func file_stream_backend_interfaces_proto_init() {
|
||||||
|
if File_stream_backend_interfaces_proto != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if !protoimpl.UnsafeEnabled {
|
||||||
|
file_stream_backend_interfaces_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
||||||
|
switch v := v.(*BackendInterfacesRequest); i {
|
||||||
|
case 0:
|
||||||
|
return &v.state
|
||||||
|
case 1:
|
||||||
|
return &v.sizeCache
|
||||||
|
case 2:
|
||||||
|
return &v.unknownFields
|
||||||
|
default:
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
type x struct{}
|
||||||
|
out := protoimpl.TypeBuilder{
|
||||||
|
File: protoimpl.DescBuilder{
|
||||||
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
||||||
|
RawDescriptor: file_stream_backend_interfaces_proto_rawDesc,
|
||||||
|
NumEnums: 0,
|
||||||
|
NumMessages: 1,
|
||||||
|
NumExtensions: 0,
|
||||||
|
NumServices: 0,
|
||||||
|
},
|
||||||
|
GoTypes: file_stream_backend_interfaces_proto_goTypes,
|
||||||
|
DependencyIndexes: file_stream_backend_interfaces_proto_depIdxs,
|
||||||
|
MessageInfos: file_stream_backend_interfaces_proto_msgTypes,
|
||||||
|
}.Build()
|
||||||
|
File_stream_backend_interfaces_proto = out.File
|
||||||
|
file_stream_backend_interfaces_proto_rawDesc = nil
|
||||||
|
file_stream_backend_interfaces_proto_goTypes = nil
|
||||||
|
file_stream_backend_interfaces_proto_depIdxs = nil
|
||||||
|
}
|
||||||
1
api/js/Makefile
vendored
1
api/js/Makefile
vendored
@ -36,6 +36,7 @@ stream:
|
|||||||
protoc ${PROTOC_ARGS} ../proto/stream/meta.proto
|
protoc ${PROTOC_ARGS} ../proto/stream/meta.proto
|
||||||
protoc ${PROTOC_ARGS} ../proto/stream/frame.proto
|
protoc ${PROTOC_ARGS} ../proto/stream/frame.proto
|
||||||
protoc ${PROTOC_ARGS} ../proto/stream/api_request.proto
|
protoc ${PROTOC_ARGS} ../proto/stream/api_request.proto
|
||||||
|
protoc ${PROTOC_ARGS} ../proto/stream/backend_interfaces.proto
|
||||||
|
|
||||||
google-api:
|
google-api:
|
||||||
protoc $(PROTOC_ARGS) /googleapis/google/api/*.proto
|
protoc $(PROTOC_ARGS) /googleapis/google/api/*.proto
|
||||||
|
|||||||
1
api/js/stream/backend_interfaces_grpc_pb.d.ts
vendored
Normal file
1
api/js/stream/backend_interfaces_grpc_pb.d.ts
vendored
Normal file
@ -0,0 +1 @@
|
|||||||
|
// GENERATED CODE -- NO SERVICES IN PROTO
|
||||||
60
api/js/stream/backend_interfaces_pb.d.ts
vendored
Normal file
60
api/js/stream/backend_interfaces_pb.d.ts
vendored
Normal file
@ -0,0 +1,60 @@
|
|||||||
|
// package: stream
|
||||||
|
// file: stream/backend_interfaces.proto
|
||||||
|
|
||||||
|
import * as jspb from "google-protobuf";
|
||||||
|
import * as google_protobuf_timestamp_pb from "google-protobuf/google/protobuf/timestamp_pb";
|
||||||
|
|
||||||
|
export class BackendInterfacesRequest extends jspb.Message {
|
||||||
|
getSenderId(): string;
|
||||||
|
setSenderId(value: string): void;
|
||||||
|
|
||||||
|
getReceiverId(): string;
|
||||||
|
setReceiverId(value: string): void;
|
||||||
|
|
||||||
|
hasTime(): boolean;
|
||||||
|
clearTime(): void;
|
||||||
|
getTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
|
||||||
|
setTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
|
||||||
|
|
||||||
|
getTransactionId(): number;
|
||||||
|
setTransactionId(value: number): void;
|
||||||
|
|
||||||
|
getMessageType(): string;
|
||||||
|
setMessageType(value: string): void;
|
||||||
|
|
||||||
|
getResultCode(): string;
|
||||||
|
setResultCode(value: string): void;
|
||||||
|
|
||||||
|
getRequestBody(): string;
|
||||||
|
setRequestBody(value: string): void;
|
||||||
|
|
||||||
|
getRequestError(): string;
|
||||||
|
setRequestError(value: string): void;
|
||||||
|
|
||||||
|
getResponseBody(): string;
|
||||||
|
setResponseBody(value: string): void;
|
||||||
|
|
||||||
|
serializeBinary(): Uint8Array;
|
||||||
|
toObject(includeInstance?: boolean): BackendInterfacesRequest.AsObject;
|
||||||
|
static toObject(includeInstance: boolean, msg: BackendInterfacesRequest): BackendInterfacesRequest.AsObject;
|
||||||
|
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
|
||||||
|
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
|
||||||
|
static serializeBinaryToWriter(message: BackendInterfacesRequest, writer: jspb.BinaryWriter): void;
|
||||||
|
static deserializeBinary(bytes: Uint8Array): BackendInterfacesRequest;
|
||||||
|
static deserializeBinaryFromReader(message: BackendInterfacesRequest, reader: jspb.BinaryReader): BackendInterfacesRequest;
|
||||||
|
}
|
||||||
|
|
||||||
|
export namespace BackendInterfacesRequest {
|
||||||
|
export type AsObject = {
|
||||||
|
senderId: string,
|
||||||
|
receiverId: string,
|
||||||
|
time?: google_protobuf_timestamp_pb.Timestamp.AsObject,
|
||||||
|
transactionId: number,
|
||||||
|
messageType: string,
|
||||||
|
resultCode: string,
|
||||||
|
requestBody: string,
|
||||||
|
requestError: string,
|
||||||
|
responseBody: string,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
430
api/js/stream/backend_interfaces_pb.js
vendored
Normal file
430
api/js/stream/backend_interfaces_pb.js
vendored
Normal file
@ -0,0 +1,430 @@
|
|||||||
|
// source: stream/backend_interfaces.proto
|
||||||
|
/**
|
||||||
|
* @fileoverview
|
||||||
|
* @enhanceable
|
||||||
|
* @suppress {messageConventions} JS Compiler reports an error if a variable or
|
||||||
|
* field starts with 'MSG_' and isn't a translatable message.
|
||||||
|
* @public
|
||||||
|
*/
|
||||||
|
// GENERATED CODE -- DO NOT EDIT!
|
||||||
|
|
||||||
|
var jspb = require('google-protobuf');
|
||||||
|
var goog = jspb;
|
||||||
|
var global = Function('return this')();
|
||||||
|
|
||||||
|
var google_protobuf_timestamp_pb = require('google-protobuf/google/protobuf/timestamp_pb.js');
|
||||||
|
goog.object.extend(proto, google_protobuf_timestamp_pb);
|
||||||
|
goog.exportSymbol('proto.stream.BackendInterfacesRequest', null, global);
|
||||||
|
/**
|
||||||
|
* Generated by JsPbCodeGenerator.
|
||||||
|
* @param {Array=} opt_data Optional initial data array, typically from a
|
||||||
|
* server response, or constructed directly in Javascript. The array is used
|
||||||
|
* in place and becomes part of the constructed object. It is not cloned.
|
||||||
|
* If no data is provided, the constructed object will be empty, but still
|
||||||
|
* valid.
|
||||||
|
* @extends {jspb.Message}
|
||||||
|
* @constructor
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest = function(opt_data) {
|
||||||
|
jspb.Message.initialize(this, opt_data, 0, -1, null, null);
|
||||||
|
};
|
||||||
|
goog.inherits(proto.stream.BackendInterfacesRequest, jspb.Message);
|
||||||
|
if (goog.DEBUG && !COMPILED) {
|
||||||
|
/**
|
||||||
|
* @public
|
||||||
|
* @override
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.displayName = 'proto.stream.BackendInterfacesRequest';
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if (jspb.Message.GENERATE_TO_OBJECT) {
|
||||||
|
/**
|
||||||
|
* Creates an object representation of this proto.
|
||||||
|
* Field names that are reserved in JavaScript and will be renamed to pb_name.
|
||||||
|
* Optional fields that are not set will be set to undefined.
|
||||||
|
* To access a reserved field use, foo.pb_<name>, eg, foo.pb_default.
|
||||||
|
* For the list of reserved names please see:
|
||||||
|
* net/proto2/compiler/js/internal/generator.cc#kKeyword.
|
||||||
|
* @param {boolean=} opt_includeInstance Deprecated. whether to include the
|
||||||
|
* JSPB instance for transitional soy proto support:
|
||||||
|
* http://goto/soy-param-migration
|
||||||
|
* @return {!Object}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.toObject = function(opt_includeInstance) {
|
||||||
|
return proto.stream.BackendInterfacesRequest.toObject(opt_includeInstance, this);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Static version of the {@see toObject} method.
|
||||||
|
* @param {boolean|undefined} includeInstance Deprecated. Whether to include
|
||||||
|
* the JSPB instance for transitional soy proto support:
|
||||||
|
* http://goto/soy-param-migration
|
||||||
|
* @param {!proto.stream.BackendInterfacesRequest} msg The msg instance to transform.
|
||||||
|
* @return {!Object}
|
||||||
|
* @suppress {unusedLocalVariables} f is only used for nested messages
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.toObject = function(includeInstance, msg) {
|
||||||
|
var f, obj = {
|
||||||
|
senderId: jspb.Message.getFieldWithDefault(msg, 1, ""),
|
||||||
|
receiverId: jspb.Message.getFieldWithDefault(msg, 2, ""),
|
||||||
|
time: (f = msg.getTime()) && google_protobuf_timestamp_pb.Timestamp.toObject(includeInstance, f),
|
||||||
|
transactionId: jspb.Message.getFieldWithDefault(msg, 4, 0),
|
||||||
|
messageType: jspb.Message.getFieldWithDefault(msg, 5, ""),
|
||||||
|
resultCode: jspb.Message.getFieldWithDefault(msg, 6, ""),
|
||||||
|
requestBody: jspb.Message.getFieldWithDefault(msg, 7, ""),
|
||||||
|
requestError: jspb.Message.getFieldWithDefault(msg, 8, ""),
|
||||||
|
responseBody: jspb.Message.getFieldWithDefault(msg, 9, "")
|
||||||
|
};
|
||||||
|
|
||||||
|
if (includeInstance) {
|
||||||
|
obj.$jspbMessageInstance = msg;
|
||||||
|
}
|
||||||
|
return obj;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Deserializes binary data (in protobuf wire format).
|
||||||
|
* @param {jspb.ByteSource} bytes The bytes to deserialize.
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.deserializeBinary = function(bytes) {
|
||||||
|
var reader = new jspb.BinaryReader(bytes);
|
||||||
|
var msg = new proto.stream.BackendInterfacesRequest;
|
||||||
|
return proto.stream.BackendInterfacesRequest.deserializeBinaryFromReader(msg, reader);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Deserializes binary data (in protobuf wire format) from the
|
||||||
|
* given reader into the given message object.
|
||||||
|
* @param {!proto.stream.BackendInterfacesRequest} msg The message object to deserialize into.
|
||||||
|
* @param {!jspb.BinaryReader} reader The BinaryReader to use.
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.deserializeBinaryFromReader = function(msg, reader) {
|
||||||
|
while (reader.nextField()) {
|
||||||
|
if (reader.isEndGroup()) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
var field = reader.getFieldNumber();
|
||||||
|
switch (field) {
|
||||||
|
case 1:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setSenderId(value);
|
||||||
|
break;
|
||||||
|
case 2:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setReceiverId(value);
|
||||||
|
break;
|
||||||
|
case 3:
|
||||||
|
var value = new google_protobuf_timestamp_pb.Timestamp;
|
||||||
|
reader.readMessage(value,google_protobuf_timestamp_pb.Timestamp.deserializeBinaryFromReader);
|
||||||
|
msg.setTime(value);
|
||||||
|
break;
|
||||||
|
case 4:
|
||||||
|
var value = /** @type {number} */ (reader.readUint32());
|
||||||
|
msg.setTransactionId(value);
|
||||||
|
break;
|
||||||
|
case 5:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setMessageType(value);
|
||||||
|
break;
|
||||||
|
case 6:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setResultCode(value);
|
||||||
|
break;
|
||||||
|
case 7:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setRequestBody(value);
|
||||||
|
break;
|
||||||
|
case 8:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setRequestError(value);
|
||||||
|
break;
|
||||||
|
case 9:
|
||||||
|
var value = /** @type {string} */ (reader.readString());
|
||||||
|
msg.setResponseBody(value);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
reader.skipField();
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return msg;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Serializes the message to binary data (in protobuf wire format).
|
||||||
|
* @return {!Uint8Array}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.serializeBinary = function() {
|
||||||
|
var writer = new jspb.BinaryWriter();
|
||||||
|
proto.stream.BackendInterfacesRequest.serializeBinaryToWriter(this, writer);
|
||||||
|
return writer.getResultBuffer();
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Serializes the given message to binary data (in protobuf wire
|
||||||
|
* format), writing to the given BinaryWriter.
|
||||||
|
* @param {!proto.stream.BackendInterfacesRequest} message
|
||||||
|
* @param {!jspb.BinaryWriter} writer
|
||||||
|
* @suppress {unusedLocalVariables} f is only used for nested messages
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.serializeBinaryToWriter = function(message, writer) {
|
||||||
|
var f = undefined;
|
||||||
|
f = message.getSenderId();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
1,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getReceiverId();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
2,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getTime();
|
||||||
|
if (f != null) {
|
||||||
|
writer.writeMessage(
|
||||||
|
3,
|
||||||
|
f,
|
||||||
|
google_protobuf_timestamp_pb.Timestamp.serializeBinaryToWriter
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getTransactionId();
|
||||||
|
if (f !== 0) {
|
||||||
|
writer.writeUint32(
|
||||||
|
4,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getMessageType();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
5,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getResultCode();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
6,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getRequestBody();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
7,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getRequestError();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
8,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
f = message.getResponseBody();
|
||||||
|
if (f.length > 0) {
|
||||||
|
writer.writeString(
|
||||||
|
9,
|
||||||
|
f
|
||||||
|
);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string sender_id = 1;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getSenderId = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setSenderId = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 1, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string receiver_id = 2;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getReceiverId = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setReceiverId = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 2, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional google.protobuf.Timestamp time = 3;
|
||||||
|
* @return {?proto.google.protobuf.Timestamp}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getTime = function() {
|
||||||
|
return /** @type{?proto.google.protobuf.Timestamp} */ (
|
||||||
|
jspb.Message.getWrapperField(this, google_protobuf_timestamp_pb.Timestamp, 3));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {?proto.google.protobuf.Timestamp|undefined} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setTime = function(value) {
|
||||||
|
return jspb.Message.setWrapperField(this, 3, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Clears the message field making it undefined.
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.clearTime = function() {
|
||||||
|
return this.setTime(undefined);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns whether this field is set.
|
||||||
|
* @return {boolean}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.hasTime = function() {
|
||||||
|
return jspb.Message.getField(this, 3) != null;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional uint32 transaction_id = 4;
|
||||||
|
* @return {number}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getTransactionId = function() {
|
||||||
|
return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {number} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setTransactionId = function(value) {
|
||||||
|
return jspb.Message.setProto3IntField(this, 4, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string message_type = 5;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getMessageType = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 5, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setMessageType = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 5, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string result_code = 6;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getResultCode = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 6, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setResultCode = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 6, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string request_body = 7;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getRequestBody = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 7, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setRequestBody = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 7, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string request_error = 8;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getRequestError = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 8, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setRequestError = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 8, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* optional string response_body = 9;
|
||||||
|
* @return {string}
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.getResponseBody = function() {
|
||||||
|
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 9, ""));
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {string} value
|
||||||
|
* @return {!proto.stream.BackendInterfacesRequest} returns this
|
||||||
|
*/
|
||||||
|
proto.stream.BackendInterfacesRequest.prototype.setResponseBody = function(value) {
|
||||||
|
return jspb.Message.setProto3StringField(this, 9, value);
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
goog.object.extend(exports, proto.stream);
|
||||||
40
api/proto/stream/backend_interfaces.proto
vendored
Normal file
40
api/proto/stream/backend_interfaces.proto
vendored
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
package stream;
|
||||||
|
|
||||||
|
option go_package = "github.com/chirpstack/chirpstack/api/go/v4/stream";
|
||||||
|
option java_package = "io.chirpstack.api.stream";
|
||||||
|
option java_multiple_files = true;
|
||||||
|
option java_outer_classname = "BackendInterfacesProto";
|
||||||
|
option csharp_namespace = "Chirpstack.Stream";
|
||||||
|
|
||||||
|
import "google/protobuf/timestamp.proto";
|
||||||
|
|
||||||
|
message BackendInterfacesRequest {
|
||||||
|
// Sender ID.
|
||||||
|
string sender_id = 1;
|
||||||
|
|
||||||
|
// Receiver ID.
|
||||||
|
string receiver_id = 2;
|
||||||
|
|
||||||
|
// Timestamp.
|
||||||
|
google.protobuf.Timestamp time = 3;
|
||||||
|
|
||||||
|
// Transaction ID.
|
||||||
|
uint32 transaction_id = 4;
|
||||||
|
|
||||||
|
// Message-type.
|
||||||
|
string message_type = 5;
|
||||||
|
|
||||||
|
// Result code.
|
||||||
|
string result_code = 6;
|
||||||
|
|
||||||
|
// Request body.
|
||||||
|
string request_body = 7;
|
||||||
|
|
||||||
|
// Request error.
|
||||||
|
string request_error = 8;
|
||||||
|
|
||||||
|
// Response body.
|
||||||
|
string response_body = 9;
|
||||||
|
}
|
||||||
1
api/python/Makefile
vendored
1
api/python/Makefile
vendored
@ -45,3 +45,4 @@ stream:
|
|||||||
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/meta.proto
|
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/meta.proto
|
||||||
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/frame.proto
|
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/frame.proto
|
||||||
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/api_request.proto
|
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/api_request.proto
|
||||||
|
$(PROTOC) ${PROTOC_ARGS} chirpstack-api/stream/backend_interfaces.proto
|
||||||
|
|||||||
40
api/python/proto/chirpstack-api/stream/backend_interfaces.proto
vendored
Normal file
40
api/python/proto/chirpstack-api/stream/backend_interfaces.proto
vendored
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
package stream;
|
||||||
|
|
||||||
|
option go_package = "github.com/chirpstack/chirpstack/api/go/v4/stream";
|
||||||
|
option java_package = "io.chirpstack.api.stream";
|
||||||
|
option java_multiple_files = true;
|
||||||
|
option java_outer_classname = "BackendInterfacesProto";
|
||||||
|
option csharp_namespace = "Chirpstack.Stream";
|
||||||
|
|
||||||
|
import "google/protobuf/timestamp.proto";
|
||||||
|
|
||||||
|
message BackendInterfacesRequest {
|
||||||
|
// Sender ID.
|
||||||
|
string sender_id = 1;
|
||||||
|
|
||||||
|
// Receiver ID.
|
||||||
|
string receiver_id = 2;
|
||||||
|
|
||||||
|
// Timestamp.
|
||||||
|
google.protobuf.Timestamp time = 3;
|
||||||
|
|
||||||
|
// Transaction ID.
|
||||||
|
uint32 transaction_id = 4;
|
||||||
|
|
||||||
|
// Message-type.
|
||||||
|
string message_type = 5;
|
||||||
|
|
||||||
|
// Result code.
|
||||||
|
string result_code = 6;
|
||||||
|
|
||||||
|
// Request body.
|
||||||
|
string request_body = 7;
|
||||||
|
|
||||||
|
// Request error.
|
||||||
|
string request_error = 8;
|
||||||
|
|
||||||
|
// Response body.
|
||||||
|
string response_body = 9;
|
||||||
|
}
|
||||||
@ -1,3 +1,4 @@
|
|||||||
from .frame_pb2 import *
|
from .frame_pb2 import *
|
||||||
from .meta_pb2 import *
|
from .meta_pb2 import *
|
||||||
from .api_request_pb2 import *
|
from .api_request_pb2 import *
|
||||||
|
from .backend_interfaces_pb2 import *
|
||||||
|
|||||||
28
api/python/src/chirpstack_api/stream/backend_interfaces_pb2.py
vendored
Normal file
28
api/python/src/chirpstack_api/stream/backend_interfaces_pb2.py
vendored
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: chirpstack-api/stream/backend_interfaces.proto
|
||||||
|
"""Generated protocol buffer code."""
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import descriptor_pool as _descriptor_pool
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
from google.protobuf.internal import builder as _builder
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n.chirpstack-api/stream/backend_interfaces.proto\x12\x06stream\x1a\x1fgoogle/protobuf/timestamp.proto\"\xf3\x01\n\x18\x42\x61\x63kendInterfacesRequest\x12\x11\n\tsender_id\x18\x01 \x01(\t\x12\x13\n\x0breceiver_id\x18\x02 \x01(\t\x12(\n\x04time\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x16\n\x0etransaction_id\x18\x04 \x01(\r\x12\x14\n\x0cmessage_type\x18\x05 \x01(\t\x12\x13\n\x0bresult_code\x18\x06 \x01(\t\x12\x14\n\x0crequest_body\x18\x07 \x01(\t\x12\x15\n\rrequest_error\x18\x08 \x01(\t\x12\x15\n\rresponse_body\x18\t \x01(\tB{\n\x18io.chirpstack.api.streamB\x16\x42\x61\x63kendInterfacesProtoP\x01Z1github.com/chirpstack/chirpstack/api/go/v4/stream\xaa\x02\x11\x43hirpstack.Streamb\x06proto3')
|
||||||
|
|
||||||
|
_globals = globals()
|
||||||
|
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
|
||||||
|
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'chirpstack_api.stream.backend_interfaces_pb2', _globals)
|
||||||
|
if _descriptor._USE_C_DESCRIPTORS == False:
|
||||||
|
|
||||||
|
DESCRIPTOR._options = None
|
||||||
|
DESCRIPTOR._serialized_options = b'\n\030io.chirpstack.api.streamB\026BackendInterfacesProtoP\001Z1github.com/chirpstack/chirpstack/api/go/v4/stream\252\002\021Chirpstack.Stream'
|
||||||
|
_globals['_BACKENDINTERFACESREQUEST']._serialized_start=92
|
||||||
|
_globals['_BACKENDINTERFACESREQUEST']._serialized_end=335
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
||||||
28
api/python/src/chirpstack_api/stream/backend_interfaces_pb2.pyi
vendored
Normal file
28
api/python/src/chirpstack_api/stream/backend_interfaces_pb2.pyi
vendored
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
from google.protobuf import timestamp_pb2 as _timestamp_pb2
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from typing import ClassVar as _ClassVar, Mapping as _Mapping, Optional as _Optional, Union as _Union
|
||||||
|
|
||||||
|
DESCRIPTOR: _descriptor.FileDescriptor
|
||||||
|
|
||||||
|
class BackendInterfacesRequest(_message.Message):
|
||||||
|
__slots__ = ["sender_id", "receiver_id", "time", "transaction_id", "message_type", "result_code", "request_body", "request_error", "response_body"]
|
||||||
|
SENDER_ID_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
RECEIVER_ID_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
TIME_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
TRANSACTION_ID_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
MESSAGE_TYPE_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
RESULT_CODE_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
REQUEST_BODY_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
REQUEST_ERROR_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
RESPONSE_BODY_FIELD_NUMBER: _ClassVar[int]
|
||||||
|
sender_id: str
|
||||||
|
receiver_id: str
|
||||||
|
time: _timestamp_pb2.Timestamp
|
||||||
|
transaction_id: int
|
||||||
|
message_type: str
|
||||||
|
result_code: str
|
||||||
|
request_body: str
|
||||||
|
request_error: str
|
||||||
|
response_body: str
|
||||||
|
def __init__(self, sender_id: _Optional[str] = ..., receiver_id: _Optional[str] = ..., time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., transaction_id: _Optional[int] = ..., message_type: _Optional[str] = ..., result_code: _Optional[str] = ..., request_body: _Optional[str] = ..., request_error: _Optional[str] = ..., response_body: _Optional[str] = ...) -> None: ...
|
||||||
4
api/python/src/chirpstack_api/stream/backend_interfaces_pb2_grpc.py
vendored
Normal file
4
api/python/src/chirpstack_api/stream/backend_interfaces_pb2_grpc.py
vendored
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
|
||||||
|
"""Client and server classes corresponding to protobuf-defined services."""
|
||||||
|
import grpc
|
||||||
|
|
||||||
5
api/rust/build.rs
vendored
5
api/rust/build.rs
vendored
@ -153,6 +153,11 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
.join("api_request.proto")
|
.join("api_request.proto")
|
||||||
.to_str()
|
.to_str()
|
||||||
.unwrap(),
|
.unwrap(),
|
||||||
|
cs_dir
|
||||||
|
.join("stream")
|
||||||
|
.join("backend_interfaces.proto")
|
||||||
|
.to_str()
|
||||||
|
.unwrap(),
|
||||||
],
|
],
|
||||||
&[
|
&[
|
||||||
proto_dir.join("chirpstack").to_str().unwrap(),
|
proto_dir.join("chirpstack").to_str().unwrap(),
|
||||||
|
|||||||
40
api/rust/proto/chirpstack/stream/backend_interfaces.proto
vendored
Normal file
40
api/rust/proto/chirpstack/stream/backend_interfaces.proto
vendored
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
package stream;
|
||||||
|
|
||||||
|
option go_package = "github.com/chirpstack/chirpstack/api/go/v4/stream";
|
||||||
|
option java_package = "io.chirpstack.api.stream";
|
||||||
|
option java_multiple_files = true;
|
||||||
|
option java_outer_classname = "BackendInterfacesProto";
|
||||||
|
option csharp_namespace = "Chirpstack.Stream";
|
||||||
|
|
||||||
|
import "google/protobuf/timestamp.proto";
|
||||||
|
|
||||||
|
message BackendInterfacesRequest {
|
||||||
|
// Sender ID.
|
||||||
|
string sender_id = 1;
|
||||||
|
|
||||||
|
// Receiver ID.
|
||||||
|
string receiver_id = 2;
|
||||||
|
|
||||||
|
// Timestamp.
|
||||||
|
google.protobuf.Timestamp time = 3;
|
||||||
|
|
||||||
|
// Transaction ID.
|
||||||
|
uint32 transaction_id = 4;
|
||||||
|
|
||||||
|
// Message-type.
|
||||||
|
string message_type = 5;
|
||||||
|
|
||||||
|
// Result code.
|
||||||
|
string result_code = 6;
|
||||||
|
|
||||||
|
// Request body.
|
||||||
|
string request_body = 7;
|
||||||
|
|
||||||
|
// Request error.
|
||||||
|
string request_error = 8;
|
||||||
|
|
||||||
|
// Response body.
|
||||||
|
string response_body = 9;
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user