Documentation ¶
Index ¶
- Variables
- type MessageHeader
- func (*MessageHeader) Descriptor() ([]byte, []int)deprecated
- func (x *MessageHeader) GetKey() string
- func (x *MessageHeader) GetValue() string
- func (*MessageHeader) ProtoMessage()
- func (x *MessageHeader) ProtoReflect() protoreflect.Message
- func (x *MessageHeader) Reset()
- func (x *MessageHeader) String() string
- type RawMessage
- type SendMessage
- func (*SendMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessage) GetDestination() string
- func (x *SendMessage) GetHeaders() []*MessageHeader
- func (x *SendMessage) GetId() string
- func (x *SendMessage) GetMessageType() string
- func (x *SendMessage) GetPayload() []byte
- func (*SendMessage) ProtoMessage()
- func (x *SendMessage) ProtoReflect() protoreflect.Message
- func (x *SendMessage) Reset()
- func (x *SendMessage) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_o5_messaging_v1_topic_bridge_proto protoreflect.FileDescriptor
View Source
var File_o5_messaging_v1_topic_raw_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type MessageHeader ¶
type MessageHeader struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*MessageHeader) Descriptor
deprecated
func (*MessageHeader) Descriptor() ([]byte, []int)
Deprecated: Use MessageHeader.ProtoReflect.Descriptor instead.
func (*MessageHeader) GetKey ¶
func (x *MessageHeader) GetKey() string
func (*MessageHeader) GetValue ¶
func (x *MessageHeader) GetValue() string
func (*MessageHeader) ProtoMessage ¶
func (*MessageHeader) ProtoMessage()
func (*MessageHeader) ProtoReflect ¶
func (x *MessageHeader) ProtoReflect() protoreflect.Message
func (*MessageHeader) Reset ¶
func (x *MessageHeader) Reset()
func (*MessageHeader) String ¶
func (x *MessageHeader) String() string
type RawMessage ¶
type RawMessage struct { Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*RawMessage) Descriptor
deprecated
func (*RawMessage) Descriptor() ([]byte, []int)
Deprecated: Use RawMessage.ProtoReflect.Descriptor instead.
func (*RawMessage) GetPayload ¶
func (x *RawMessage) GetPayload() []byte
func (*RawMessage) GetTopic ¶
func (x *RawMessage) GetTopic() string
func (*RawMessage) ProtoMessage ¶
func (*RawMessage) ProtoMessage()
func (*RawMessage) ProtoReflect ¶
func (x *RawMessage) ProtoReflect() protoreflect.Message
func (*RawMessage) Reset ¶
func (x *RawMessage) Reset()
func (*RawMessage) String ¶
func (x *RawMessage) String() string
type SendMessage ¶
type SendMessage struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"` MessageType string `protobuf:"bytes,4,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` Headers []*MessageHeader `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"` // contains filtered or unexported fields }
func (*SendMessage) Descriptor
deprecated
func (*SendMessage) Descriptor() ([]byte, []int)
Deprecated: Use SendMessage.ProtoReflect.Descriptor instead.
func (*SendMessage) GetDestination ¶
func (x *SendMessage) GetDestination() string
func (*SendMessage) GetHeaders ¶
func (x *SendMessage) GetHeaders() []*MessageHeader
func (*SendMessage) GetId ¶
func (x *SendMessage) GetId() string
func (*SendMessage) GetMessageType ¶
func (x *SendMessage) GetMessageType() string
func (*SendMessage) GetPayload ¶
func (x *SendMessage) GetPayload() []byte
func (*SendMessage) ProtoMessage ¶
func (*SendMessage) ProtoMessage()
func (*SendMessage) ProtoReflect ¶
func (x *SendMessage) ProtoReflect() protoreflect.Message
func (*SendMessage) Reset ¶
func (x *SendMessage) Reset()
func (*SendMessage) String ¶
func (x *SendMessage) String() string
Click to show internal directories.
Click to hide internal directories.