Documentation ¶
Index ¶
- Variables
- type OnlineMap
- type OnlineSync
- type StreamMType
- func (StreamMType) Descriptor() protoreflect.EnumDescriptor
- func (x StreamMType) Enum() *StreamMType
- func (StreamMType) EnumDescriptor() ([]byte, []int)deprecated
- func (x StreamMType) Number() protoreflect.EnumNumber
- func (x StreamMType) String() string
- func (StreamMType) Type() protoreflect.EnumType
- type StreamMsg
- func (x *StreamMsg) Data() []byte
- func (*StreamMsg) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMsg) GetMTyp() StreamMType
- func (x *StreamMsg) GetOnlineAck() *OnlineMap
- func (x *StreamMsg) GetOnlineSync() *OnlineSync
- func (m *StreamMsg) GetPayload() isStreamMsg_Payload
- func (*StreamMsg) ProtoMessage()
- func (x *StreamMsg) ProtoReflect() protoreflect.Message
- func (x *StreamMsg) Reset()
- func (x *StreamMsg) String() string
- func (x *StreamMsg) SyncOnline(nodeId string) []byte
- func (x *StreamMsg) SyncOnlineAck(uid []string) []byte
- type StreamMsg_OnlineAck
- type StreamMsg_OnlineSync
Constants ¶
This section is empty.
Variables ¶
View Source
var ( StreamMType_name = map[int32]string{ 0: "MTOnlineAck", 1: "MTOnlineSync", 2: "MTContactSync", 3: "MTContactAck", } StreamMType_value = map[string]int32{ "MTOnlineAck": 0, "MTOnlineSync": 1, "MTContactSync": 2, "MTContactAck": 3, } )
Enum value maps for StreamMType.
View Source
var File_stream_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type OnlineMap ¶
type OnlineMap struct { UID []string `protobuf:"bytes,1,rep,name=UID,proto3" json:"UID,omitempty"` // contains filtered or unexported fields }
func (*OnlineMap) Descriptor
deprecated
func (*OnlineMap) ProtoMessage ¶
func (*OnlineMap) ProtoMessage()
func (*OnlineMap) ProtoReflect ¶
func (x *OnlineMap) ProtoReflect() protoreflect.Message
type OnlineSync ¶
type OnlineSync struct { NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"` // contains filtered or unexported fields }
func (*OnlineSync) Descriptor
deprecated
func (*OnlineSync) Descriptor() ([]byte, []int)
Deprecated: Use OnlineSync.ProtoReflect.Descriptor instead.
func (*OnlineSync) GetNodeID ¶
func (x *OnlineSync) GetNodeID() string
func (*OnlineSync) ProtoMessage ¶
func (*OnlineSync) ProtoMessage()
func (*OnlineSync) ProtoReflect ¶
func (x *OnlineSync) ProtoReflect() protoreflect.Message
func (*OnlineSync) Reset ¶
func (x *OnlineSync) Reset()
func (*OnlineSync) String ¶
func (x *OnlineSync) String() string
type StreamMType ¶
type StreamMType int32
const ( StreamMType_MTOnlineAck StreamMType = 0 StreamMType_MTOnlineSync StreamMType = 1 StreamMType_MTContactSync StreamMType = 2 StreamMType_MTContactAck StreamMType = 3 )
func (StreamMType) Descriptor ¶
func (StreamMType) Descriptor() protoreflect.EnumDescriptor
func (StreamMType) Enum ¶
func (x StreamMType) Enum() *StreamMType
func (StreamMType) EnumDescriptor
deprecated
func (StreamMType) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamMType.Descriptor instead.
func (StreamMType) Number ¶
func (x StreamMType) Number() protoreflect.EnumNumber
func (StreamMType) String ¶
func (x StreamMType) String() string
func (StreamMType) Type ¶
func (StreamMType) Type() protoreflect.EnumType
type StreamMsg ¶
type StreamMsg struct { MTyp StreamMType `protobuf:"varint,1,opt,name=MTyp,proto3,enum=pbs.stream.StreamMType" json:"MTyp,omitempty"` // Types that are assignable to Payload: // *StreamMsg_OnlineSync // *StreamMsg_OnlineAck Payload isStreamMsg_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*StreamMsg) Descriptor
deprecated
func (*StreamMsg) GetMTyp ¶
func (x *StreamMsg) GetMTyp() StreamMType
func (*StreamMsg) GetOnlineAck ¶
func (*StreamMsg) GetOnlineSync ¶
func (x *StreamMsg) GetOnlineSync() *OnlineSync
func (*StreamMsg) GetPayload ¶
func (m *StreamMsg) GetPayload() isStreamMsg_Payload
func (*StreamMsg) ProtoMessage ¶
func (*StreamMsg) ProtoMessage()
func (*StreamMsg) ProtoReflect ¶
func (x *StreamMsg) ProtoReflect() protoreflect.Message
func (*StreamMsg) SyncOnline ¶
func (*StreamMsg) SyncOnlineAck ¶
type StreamMsg_OnlineAck ¶
type StreamMsg_OnlineAck struct {
OnlineAck *OnlineMap `protobuf:"bytes,5,opt,name=onlineAck,proto3,oneof"`
}
type StreamMsg_OnlineSync ¶
type StreamMsg_OnlineSync struct {
OnlineSync *OnlineSync `protobuf:"bytes,2,opt,name=onlineSync,proto3,oneof"`
}
Click to show internal directories.
Click to hide internal directories.