Documentation ¶
Index ¶
- Variables
- type Session
- func (*Session) Descriptor() ([]byte, []int)
- func (m *Session) GetID() string
- func (m *Session) GetLastActiveTime() int64
- func (m *Session) GetTopics() map[string]*SessionTopic
- func (m *Session) Marshal() (dAtA []byte, err error)
- func (m *Session) MarshalTo(dAtA []byte) (int, error)
- func (m *Session) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Session) ProtoMessage()
- func (m *Session) Reset()
- func (m *Session) Size() (n int)
- func (m *Session) String() string
- func (m *Session) Unmarshal(dAtA []byte) error
- func (m *Session) XXX_DiscardUnknown()
- func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Session) XXX_Merge(src proto.Message)
- func (m *Session) XXX_Size() int
- func (m *Session) XXX_Unmarshal(b []byte) error
- type SessionTopic
- func (*SessionTopic) Descriptor() ([]byte, []int)
- func (m *SessionTopic) GetLastAckMessageID() string
- func (m *SessionTopic) GetQoS() int32
- func (m *SessionTopic) GetTopic() string
- func (m *SessionTopic) GetUnAckMessageID() []string
- func (m *SessionTopic) GetUnCompletePacketID() []uint32
- func (m *SessionTopic) GetUnReceivePacketID() []uint32
- func (m *SessionTopic) Marshal() (dAtA []byte, err error)
- func (m *SessionTopic) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionTopic) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionTopic) ProtoMessage()
- func (m *SessionTopic) Reset()
- func (m *SessionTopic) Size() (n int)
- func (m *SessionTopic) String() string
- func (m *SessionTopic) Unmarshal(dAtA []byte) error
- func (m *SessionTopic) XXX_DiscardUnknown()
- func (m *SessionTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionTopic) XXX_Merge(src proto.Message)
- func (m *SessionTopic) XXX_Size() int
- func (m *SessionTopic) XXX_Unmarshal(b []byte) error
- type SystemState
- func (*SystemState) Descriptor() ([]byte, []int)
- func (m *SystemState) GetSession() *Session
- func (m *SystemState) Marshal() (dAtA []byte, err error)
- func (m *SystemState) MarshalTo(dAtA []byte) (int, error)
- func (m *SystemState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SystemState) ProtoMessage()
- func (m *SystemState) Reset()
- func (m *SystemState) Size() (n int)
- func (m *SystemState) String() string
- func (m *SystemState) Unmarshal(dAtA []byte) error
- func (m *SystemState) XXX_DiscardUnknown()
- func (m *SystemState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SystemState) XXX_Merge(src proto.Message)
- func (m *SystemState) XXX_Size() int
- func (m *SystemState) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Session ¶
type Session struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Topics map[string]*SessionTopic `` /* 153-byte string literal not displayed */ LastActiveTime int64 `protobuf:"varint,3,opt,name=LastActiveTime,proto3" json:"LastActiveTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Session) Descriptor ¶
func (*Session) GetLastActiveTime ¶
func (*Session) GetTopics ¶
func (m *Session) GetTopics() map[string]*SessionTopic
func (*Session) MarshalToSizedBuffer ¶
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) XXX_DiscardUnknown ¶
func (m *Session) XXX_DiscardUnknown()
func (*Session) XXX_Marshal ¶
func (*Session) XXX_Unmarshal ¶
type SessionTopic ¶
type SessionTopic struct { Topic string `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"` QoS int32 `protobuf:"varint,2,opt,name=QoS,proto3" json:"QoS,omitempty"` UnAckMessageID []string `protobuf:"bytes,3,rep,name=UnAckMessageID,proto3" json:"UnAckMessageID,omitempty"` UnReceivePacketID []uint32 `protobuf:"varint,4,rep,packed,name=UnReceivePacketID,proto3" json:"UnReceivePacketID,omitempty"` UnCompletePacketID []uint32 `protobuf:"varint,5,rep,packed,name=UnCompletePacketID,proto3" json:"UnCompletePacketID,omitempty"` LastAckMessageID string `protobuf:"bytes,6,opt,name=LastAckMessageID,proto3" json:"LastAckMessageID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SessionTopic) Descriptor ¶
func (*SessionTopic) Descriptor() ([]byte, []int)
func (*SessionTopic) GetLastAckMessageID ¶
func (m *SessionTopic) GetLastAckMessageID() string
func (*SessionTopic) GetQoS ¶
func (m *SessionTopic) GetQoS() int32
func (*SessionTopic) GetTopic ¶
func (m *SessionTopic) GetTopic() string
func (*SessionTopic) GetUnAckMessageID ¶
func (m *SessionTopic) GetUnAckMessageID() []string
func (*SessionTopic) GetUnCompletePacketID ¶
func (m *SessionTopic) GetUnCompletePacketID() []uint32
func (*SessionTopic) GetUnReceivePacketID ¶
func (m *SessionTopic) GetUnReceivePacketID() []uint32
func (*SessionTopic) Marshal ¶
func (m *SessionTopic) Marshal() (dAtA []byte, err error)
func (*SessionTopic) MarshalToSizedBuffer ¶
func (m *SessionTopic) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionTopic) ProtoMessage ¶
func (*SessionTopic) ProtoMessage()
func (*SessionTopic) Reset ¶
func (m *SessionTopic) Reset()
func (*SessionTopic) Size ¶
func (m *SessionTopic) Size() (n int)
func (*SessionTopic) String ¶
func (m *SessionTopic) String() string
func (*SessionTopic) Unmarshal ¶
func (m *SessionTopic) Unmarshal(dAtA []byte) error
func (*SessionTopic) XXX_DiscardUnknown ¶
func (m *SessionTopic) XXX_DiscardUnknown()
func (*SessionTopic) XXX_Marshal ¶
func (m *SessionTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionTopic) XXX_Merge ¶
func (m *SessionTopic) XXX_Merge(src proto.Message)
func (*SessionTopic) XXX_Size ¶
func (m *SessionTopic) XXX_Size() int
func (*SessionTopic) XXX_Unmarshal ¶
func (m *SessionTopic) XXX_Unmarshal(b []byte) error
type SystemState ¶
type SystemState struct { Session *Session `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SystemState) Descriptor ¶
func (*SystemState) Descriptor() ([]byte, []int)
func (*SystemState) GetSession ¶
func (m *SystemState) GetSession() *Session
func (*SystemState) Marshal ¶
func (m *SystemState) Marshal() (dAtA []byte, err error)
func (*SystemState) MarshalToSizedBuffer ¶
func (m *SystemState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SystemState) ProtoMessage ¶
func (*SystemState) ProtoMessage()
func (*SystemState) Reset ¶
func (m *SystemState) Reset()
func (*SystemState) Size ¶
func (m *SystemState) Size() (n int)
func (*SystemState) String ¶
func (m *SystemState) String() string
func (*SystemState) Unmarshal ¶
func (m *SystemState) Unmarshal(dAtA []byte) error
func (*SystemState) XXX_DiscardUnknown ¶
func (m *SystemState) XXX_DiscardUnknown()
func (*SystemState) XXX_Marshal ¶
func (m *SystemState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SystemState) XXX_Merge ¶
func (m *SystemState) XXX_Merge(src proto.Message)
func (*SystemState) XXX_Size ¶
func (m *SystemState) XXX_Size() int
func (*SystemState) XXX_Unmarshal ¶
func (m *SystemState) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.