Documentation ¶
Index ¶
- func CeGroupEntryNRT() serializer.CodecElement
- func CeGroupEntryRTP() serializer.CodecElement
- func CeGroupPairNRT() serializer.CodecElement
- func CeGroupPairRTP() serializer.CodecElement
- type GroupEntryNRT
- type GroupEntryRTP
- type GroupNRT
- func (g *GroupNRT) GetGroupBulkNRT(groups [][]byte) (entries []GroupPairNRT)
- func (g *GroupNRT) GetGroupNRT(group []byte) (entry *GroupEntryNRT)
- func (g *GroupNRT) GetGroupsNRT(after, prefix, suffix []byte) (entries []GroupPairNRT)
- func (g *GroupNRT) Initialize() error
- func (g *GroupNRT) PutGroupNRT(group []byte, entry *GroupEntryNRT) (other *GroupEntryNRT, ok bool)
- type GroupPairNRT
- type GroupPairRTP
- type GroupRTP
- type IGroupNRT
- type IGroupRTP
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CeGroupEntryNRT ¶
func CeGroupEntryNRT() serializer.CodecElement
func CeGroupEntryRTP ¶
func CeGroupEntryRTP() serializer.CodecElement
func CeGroupPairNRT ¶
func CeGroupPairNRT() serializer.CodecElement
func CeGroupPairRTP ¶
func CeGroupPairRTP() serializer.CodecElement
Types ¶
type GroupEntryNRT ¶
type GroupEntryNRT struct { Description []byte Status byte // The timestamp is mandatory to propagate updates. TimeStamp int64 // Timestamp (UNIX-format) }
Group Entry, Non-Realtime-Part
func ParseGroupEntryNRT ¶
func ParseGroupEntryNRT(b []byte) (*GroupEntryNRT, error)
func (*GroupEntryNRT) Bytes ¶
func (e *GroupEntryNRT) Bytes() []byte
func (GroupEntryNRT) String ¶
func (g GroupEntryNRT) String() string
type GroupEntryRTP ¶
Group Entry, Realtime-Part
func ParseGroupEntryRTP ¶
func ParseGroupEntryRTP(b []byte) (*GroupEntryRTP, error)
func (*GroupEntryRTP) Bytes ¶
func (e *GroupEntryRTP) Bytes() []byte
type GroupNRT ¶
func (*GroupNRT) GetGroupBulkNRT ¶
func (g *GroupNRT) GetGroupBulkNRT(groups [][]byte) (entries []GroupPairNRT)
func (*GroupNRT) GetGroupNRT ¶
func (g *GroupNRT) GetGroupNRT(group []byte) (entry *GroupEntryNRT)
func (*GroupNRT) GetGroupsNRT ¶
func (g *GroupNRT) GetGroupsNRT(after, prefix, suffix []byte) (entries []GroupPairNRT)
func (*GroupNRT) Initialize ¶
func (*GroupNRT) PutGroupNRT ¶
func (g *GroupNRT) PutGroupNRT(group []byte, entry *GroupEntryNRT) (other *GroupEntryNRT, ok bool)
type GroupPairNRT ¶
type GroupPairNRT struct { Key []byte Value GroupEntryNRT }
func (GroupPairNRT) String ¶
func (g GroupPairNRT) String() string
type GroupPairRTP ¶
type GroupPairRTP struct { Key []byte Value GroupEntryRTP }
func (GroupPairRTP) String ¶
func (g GroupPairRTP) String() string
type GroupRTP ¶
func (*GroupRTP) GetGroupRTP ¶
func (g *GroupRTP) GetGroupRTP(group []byte) (entry *GroupEntryRTP)
func (*GroupRTP) IncrementRTP ¶
func (*GroupRTP) Initialize ¶
type IGroupNRT ¶
type IGroupNRT interface { GetGroupNRT(group []byte) (entry *GroupEntryNRT) GetGroupBulkNRT(groups [][]byte) (entries []GroupPairNRT) GetGroupsNRT(after, prefix, suffix []byte) (entries []GroupPairNRT) PutGroupNRT(group []byte, entry *GroupEntryNRT) (other *GroupEntryNRT, ok bool) }
Click to show internal directories.
Click to hide internal directories.