Documentation ¶
Index ¶
- type Session
- func (s *Session) CreateSubTopic(topic string, option *proto.SubOption)
- func (s *Session) CreateTopicUnFinishedMessage(topic string, message []broker.UnFinishedMessage)
- func (s *Session) DeleteSubTopic(topic string)
- func (s *Session) DeleteTopicLatestPushedMessageID(topic string, messageID string)
- func (s *Session) DeleteTopicUnFinishedMessage(topic string, messageID string)
- func (s *Session) GetConnectProperties() (*broker.SessionConnectProperties, error)
- func (s *Session) GetWillMessage() (*broker.WillMessage, error)
- func (s *Session) ReadSubTopics() (topics map[string]*proto.SubOption)
- func (s *Session) ReadTopicLatestPushedMessageID(topic string) (messageID string, ok bool)
- func (s *Session) ReadTopicUnFinishedMessage(topic string) (message []broker.UnFinishedMessage)
- func (s *Session) Release()
- func (s *Session) SetConnectProperties(properties *broker.SessionConnectProperties) error
- func (s *Session) SetTopicLatestPushedMessageID(topic string, messageID string)
- func (s *Session) SetWillMessage(message *broker.WillMessage) error
- type Sessions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func (*Session) CreateSubTopic ¶
func (*Session) CreateTopicUnFinishedMessage ¶
func (s *Session) CreateTopicUnFinishedMessage(topic string, message []broker.UnFinishedMessage)
func (*Session) DeleteSubTopic ¶
func (*Session) DeleteTopicLatestPushedMessageID ¶
func (*Session) DeleteTopicUnFinishedMessage ¶
func (*Session) GetConnectProperties ¶
func (s *Session) GetConnectProperties() (*broker.SessionConnectProperties, error)
func (*Session) GetWillMessage ¶
func (s *Session) GetWillMessage() (*broker.WillMessage, error)
func (*Session) ReadSubTopics ¶
func (*Session) ReadTopicLatestPushedMessageID ¶
func (*Session) ReadTopicUnFinishedMessage ¶
func (s *Session) ReadTopicUnFinishedMessage(topic string) (message []broker.UnFinishedMessage)
func (*Session) SetConnectProperties ¶
func (s *Session) SetConnectProperties(properties *broker.SessionConnectProperties) error
func (*Session) SetTopicLatestPushedMessageID ¶
func (*Session) SetWillMessage ¶
func (s *Session) SetWillMessage(message *broker.WillMessage) error
type Sessions ¶
type Sessions struct {
// contains filtered or unexported fields
}
func NewSessions ¶
func NewSessions(store broker.KeyValueStore) *Sessions
func (*Sessions) CreateSession ¶
func (*Sessions) DeleteSession ¶
Click to show internal directories.
Click to hide internal directories.