queue

Documentation

Index

• type Add
  • func NewAdd(shard uint32) *Add
  • func (a *Add) Add(items []Item) error
• type Get
  • func NewGet(shard uint32) *Get
  • func (r *Get) GetAndWait(topic string, start []byte) error
  • func (r *Get) GetByPrefixes(topic string, prefixes [][]byte) error
• type Item

Types

type Add

type Add struct {
	Shard uint32
}

func NewAdd

func NewAdd(shard uint32) *Add

func (*Add) Add

func (a *Add) Add(items []Item) error

type Get

type Get struct {
	Shard uint32
	Items []Item
}

func NewGet

func NewGet(shard uint32) *Get

func (*Get) GetAndWait

func (r *Get) GetAndWait(topic string, start []byte) error

func (*Get) GetByPrefixes

func (r *Get) GetByPrefixes(topic string, prefixes [][]byte) error

type Item

type Item struct {
	Topic string
	Uid   []byte
	Data  []byte
}