groupsdb

package
v0.0.0-...-d5b6aee Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2017 License: MIT Imports: 7 Imported by: 0

Documentation

Index

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

type GroupEntryRTP struct {
	Count int64
	Low   int64
	High  int64
}

Group Entry, Realtime-Part

func ParseGroupEntryRTP

func ParseGroupEntryRTP(b []byte) (*GroupEntryRTP, error)

func (*GroupEntryRTP) Bytes

func (e *GroupEntryRTP) Bytes() []byte

type GroupNRT

type GroupNRT struct {
	DB      *bolt.DB
	Timeout time.Duration
}

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 (g *GroupNRT) Initialize() error

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

type GroupRTP struct {
	DB *bolt.DB
}

func (*GroupRTP) GetGroupRTP

func (g *GroupRTP) GetGroupRTP(group []byte) (entry *GroupEntryRTP)

func (*GroupRTP) IncrementRTP

func (g *GroupRTP) IncrementRTP(group []byte) (artnum int64, ok bool)

func (*GroupRTP) Initialize

func (g *GroupRTP) Initialize() error

func (*GroupRTP) RollbackArticleRTP

func (g *GroupRTP) RollbackArticleRTP(group []byte, artnum int64) (ok bool)

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)
}

type IGroupRTP

type IGroupRTP interface {
	GetGroupRTP(group []byte) (entry *GroupEntryRTP)
	IncrementRTP(group []byte) (artnum int64, ok bool)
	RollbackArticleRTP(group []byte, artnum int64) (ok bool)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL