Documentation ¶
Index ¶
- Variables
- type BroadcastConfig
- type Config
- func (*Config) Descriptor() ([]byte, []int)deprecated
- func (x *Config) GetBroadcast() *BroadcastConfig
- func (x *Config) GetReply() *ReplyConfig
- func (x *Config) GetRequest() *RequestConfig
- func (m *Config) GetType() isConfig_Type
- func (x *Config) GetUnicast() *UnicastConfig
- func (*Config) ProtoMessage()
- func (x *Config) ProtoReflect() protoreflect.Message
- func (x *Config) Reset()
- func (x *Config) String() string
- type Config_Broadcast
- type Config_Reply
- type Config_Request
- type Config_Unicast
- type ReplyConfig
- type RequestConfig
- type RequestMetadata
- func (*RequestMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *RequestMetadata) GetContext() []byte
- func (x *RequestMetadata) GetReplyTo() string
- func (*RequestMetadata) ProtoMessage()
- func (x *RequestMetadata) ProtoReflect() protoreflect.Message
- func (x *RequestMetadata) Reset()
- func (x *RequestMetadata) String() string
- type UnicastConfig
- type UpsertMetadata
- func (*UpsertMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertMetadata) GetEntityId() string
- func (x *UpsertMetadata) GetEventId() string
- func (x *UpsertMetadata) GetTimestamp() *timestamppb.Timestamp
- func (*UpsertMetadata) ProtoMessage()
- func (x *UpsertMetadata) ProtoReflect() protoreflect.Message
- func (x *UpsertMetadata) Reset()
- func (x *UpsertMetadata) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var (
// optional o5.messaging.v1.Config config = 93563434;
E_Config = &file_o5_messaging_v1_annotations_proto_extTypes[0]
)
Extension fields to descriptorpb.ServiceOptions.
View Source
var File_o5_messaging_v1_annotations_proto protoreflect.FileDescriptor
View Source
var File_o5_messaging_v1_reqres_proto protoreflect.FileDescriptor
View Source
var File_o5_messaging_v1_upsert_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BroadcastConfig ¶
type BroadcastConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*BroadcastConfig) Descriptor
deprecated
func (*BroadcastConfig) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastConfig.ProtoReflect.Descriptor instead.
func (*BroadcastConfig) GetName ¶
func (x *BroadcastConfig) GetName() string
func (*BroadcastConfig) ProtoMessage ¶
func (*BroadcastConfig) ProtoMessage()
func (*BroadcastConfig) ProtoReflect ¶
func (x *BroadcastConfig) ProtoReflect() protoreflect.Message
func (*BroadcastConfig) Reset ¶
func (x *BroadcastConfig) Reset()
func (*BroadcastConfig) String ¶
func (x *BroadcastConfig) String() string
type Config ¶
type Config struct { // Types that are assignable to Type: // // *Config_Broadcast // *Config_Unicast // *Config_Request // *Config_Reply Type isConfig_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*Config) GetBroadcast ¶
func (x *Config) GetBroadcast() *BroadcastConfig
func (*Config) GetReply ¶
func (x *Config) GetReply() *ReplyConfig
func (*Config) GetRequest ¶
func (x *Config) GetRequest() *RequestConfig
func (*Config) GetUnicast ¶
func (x *Config) GetUnicast() *UnicastConfig
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
type Config_Broadcast ¶
type Config_Broadcast struct {
Broadcast *BroadcastConfig `protobuf:"bytes,1,opt,name=broadcast,proto3,oneof"`
}
type Config_Reply ¶
type Config_Reply struct {
Reply *ReplyConfig `protobuf:"bytes,4,opt,name=reply,proto3,oneof"`
}
type Config_Request ¶
type Config_Request struct {
Request *RequestConfig `protobuf:"bytes,3,opt,name=request,proto3,oneof"`
}
type Config_Unicast ¶
type Config_Unicast struct {
Unicast *UnicastConfig `protobuf:"bytes,2,opt,name=unicast,proto3,oneof"`
}
type ReplyConfig ¶
type ReplyConfig struct { // name of the queue group (i.e. prefix), should match RequestConfig.name Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ReplyConfig) Descriptor
deprecated
func (*ReplyConfig) Descriptor() ([]byte, []int)
Deprecated: Use ReplyConfig.ProtoReflect.Descriptor instead.
func (*ReplyConfig) GetName ¶
func (x *ReplyConfig) GetName() string
func (*ReplyConfig) ProtoMessage ¶
func (*ReplyConfig) ProtoMessage()
func (*ReplyConfig) ProtoReflect ¶
func (x *ReplyConfig) ProtoReflect() protoreflect.Message
func (*ReplyConfig) Reset ¶
func (x *ReplyConfig) Reset()
func (*ReplyConfig) String ¶
func (x *ReplyConfig) String() string
type RequestConfig ¶
type RequestConfig struct { // name of the queue group (i.e. prefix), should match ReplyConfig.name Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*RequestConfig) Descriptor
deprecated
func (*RequestConfig) Descriptor() ([]byte, []int)
Deprecated: Use RequestConfig.ProtoReflect.Descriptor instead.
func (*RequestConfig) GetName ¶
func (x *RequestConfig) GetName() string
func (*RequestConfig) ProtoMessage ¶
func (*RequestConfig) ProtoMessage()
func (*RequestConfig) ProtoReflect ¶
func (x *RequestConfig) ProtoReflect() protoreflect.Message
func (*RequestConfig) Reset ¶
func (x *RequestConfig) Reset()
func (*RequestConfig) String ¶
func (x *RequestConfig) String() string
type RequestMetadata ¶
type RequestMetadata struct { ReplyTo string `protobuf:"bytes,1,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"` // Context is the responsibility of the requester, it can be whatever the // caller likes, e.g. an encoded proto message Context []byte `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` // contains filtered or unexported fields }
func (*RequestMetadata) Descriptor
deprecated
func (*RequestMetadata) Descriptor() ([]byte, []int)
Deprecated: Use RequestMetadata.ProtoReflect.Descriptor instead.
func (*RequestMetadata) GetContext ¶
func (x *RequestMetadata) GetContext() []byte
func (*RequestMetadata) GetReplyTo ¶
func (x *RequestMetadata) GetReplyTo() string
func (*RequestMetadata) ProtoMessage ¶
func (*RequestMetadata) ProtoMessage()
func (*RequestMetadata) ProtoReflect ¶
func (x *RequestMetadata) ProtoReflect() protoreflect.Message
func (*RequestMetadata) Reset ¶
func (x *RequestMetadata) Reset()
func (*RequestMetadata) String ¶
func (x *RequestMetadata) String() string
type UnicastConfig ¶
type UnicastConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*UnicastConfig) Descriptor
deprecated
func (*UnicastConfig) Descriptor() ([]byte, []int)
Deprecated: Use UnicastConfig.ProtoReflect.Descriptor instead.
func (*UnicastConfig) GetName ¶
func (x *UnicastConfig) GetName() string
func (*UnicastConfig) ProtoMessage ¶
func (*UnicastConfig) ProtoMessage()
func (*UnicastConfig) ProtoReflect ¶
func (x *UnicastConfig) ProtoReflect() protoreflect.Message
func (*UnicastConfig) Reset ¶
func (x *UnicastConfig) Reset()
func (*UnicastConfig) String ¶
func (x *UnicastConfig) String() string
type UpsertMetadata ¶
type UpsertMetadata struct { // The key of the object being updated by this message EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` // A unique ID for the event triggering this update EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` // Safe ordered timestamp of the event. The event with the // newest timestamp is current and superseeds all events. // Upsert processors should ignore old events. Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*UpsertMetadata) Descriptor
deprecated
func (*UpsertMetadata) Descriptor() ([]byte, []int)
Deprecated: Use UpsertMetadata.ProtoReflect.Descriptor instead.
func (*UpsertMetadata) GetEntityId ¶
func (x *UpsertMetadata) GetEntityId() string
func (*UpsertMetadata) GetEventId ¶
func (x *UpsertMetadata) GetEventId() string
func (*UpsertMetadata) GetTimestamp ¶
func (x *UpsertMetadata) GetTimestamp() *timestamppb.Timestamp
func (*UpsertMetadata) ProtoMessage ¶
func (*UpsertMetadata) ProtoMessage()
func (*UpsertMetadata) ProtoReflect ¶
func (x *UpsertMetadata) ProtoReflect() protoreflect.Message
func (*UpsertMetadata) Reset ¶
func (x *UpsertMetadata) Reset()
func (*UpsertMetadata) String ¶
func (x *UpsertMetadata) String() string
Click to show internal directories.
Click to hide internal directories.