Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrUnexepectedEOF = errors.New("unexpected EOF")
)
Functions ¶
Types ¶
type IncrementMessage ¶
func (IncrementMessage) Type ¶
func (m IncrementMessage) Type() MessageType
type Message ¶
type Message interface {
Type() MessageType
}
type MessageType ¶
type MessageType uint8
const ( ZeroType MessageType = iota IncrementType SubscribeType UnsubscribeType NotifyType QueryType )
func (MessageType) String ¶
func (m MessageType) String() string
type NotifyMessage ¶
func (NotifyMessage) Type ¶
func (m NotifyMessage) Type() MessageType
type QueryMessage ¶
type QueryMessage struct {
Key uint64
}
func (QueryMessage) Type ¶
func (m QueryMessage) Type() MessageType
type SubscribeMessage ¶
type SubscribeMessage struct {
Key uint64
}
func (SubscribeMessage) Type ¶
func (m SubscribeMessage) Type() MessageType
type UnsubscribeMessage ¶
type UnsubscribeMessage struct {
Key uint64
}
func (UnsubscribeMessage) Type ¶
func (m UnsubscribeMessage) Type() MessageType
Click to show internal directories.
Click to hide internal directories.