Version: v1.5.2 Latest Latest

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

Go to latest
Published: Mar 9, 2021 License: MIT Imports: 9 Imported by: 0




This section is empty.


View Source
var (
	ErrChannelNotFound = errors.New("channel is not found")


This section is empty.


type PqChannelStorage added in v1.5.0

type PqChannelStorage struct {
	// contains filtered or unexported fields

func NewPqChannelStorage added in v1.5.0

func NewPqChannelStorage() PqChannelStorage

func (*PqChannelStorage) CheckScheduled added in v1.5.0

func (p *PqChannelStorage) CheckScheduled(nowTimestamp int) bool

func (*PqChannelStorage) Dequeue added in v1.5.0

func (p *PqChannelStorage) Dequeue() message.Message

func (*PqChannelStorage) Dump added in v1.5.0

func (p *PqChannelStorage) Dump() []message.Message

func (*PqChannelStorage) Enqueue added in v1.5.0

func (p *PqChannelStorage) Enqueue(value message.Message)

func (*PqChannelStorage) Flush added in v1.5.0

func (p *PqChannelStorage) Flush()

func (*PqChannelStorage) IsEmpty added in v1.5.0

func (p *PqChannelStorage) IsEmpty() bool

type PqStorage

type PqStorage struct {
	// contains filtered or unexported fields

func NewPqStorage

func NewPqStorage() *PqStorage

func (*PqStorage) AddChannel added in v1.5.0

func (p *PqStorage) AddChannel(c channel.Channel) (channel.Channel, error)

func (*PqStorage) DeleteChannel added in v1.5.0

func (p *PqStorage) DeleteChannel(channelID string) (channel.Channel, error)

func (*PqStorage) Dump added in v1.3.0

func (p *PqStorage) Dump() ([]channel.Channel, map[string][]message.Message)

func (*PqStorage) Flush added in v1.3.0

func (p *PqStorage) Flush()

func (*PqStorage) GetChannel added in v1.5.0

func (p *PqStorage) GetChannel(channelID string) (channel.Channel, error)

func (*PqStorage) GetChannelStorage added in v1.5.0

func (p *PqStorage) GetChannelStorage(channelID string) (PqChannelStorage, bool)

func (*PqStorage) GetChannels added in v1.5.0

func (p *PqStorage) GetChannels() []channel.Channel

func (*PqStorage) UpdateChannel added in v1.5.0

func (p *PqStorage) UpdateChannel(channelID string, c channel.Channel) (channel.Channel, error)

type PrioritizedNodePointer added in v1.3.0

type PrioritizedNodePointer struct {
	// contains filtered or unexported fields

func NewPrioritizedNodePointer added in v1.3.0

func NewPrioritizedNodePointer(value *doublylinkedlist.Node, priority int) PrioritizedNodePointer

func (PrioritizedNodePointer) GetPriority added in v1.3.0

func (v PrioritizedNodePointer) GetPriority() int

func (PrioritizedNodePointer) GetValue added in v1.3.0

func (v PrioritizedNodePointer) GetValue() interface{}

type PrioritizedNodePointerMinPriorityComparator added in v1.3.0

type PrioritizedNodePointerMinPriorityComparator struct{ comparator.AbstractComparator }

func NewPrioritizedNodePointerMinPriorityComparator added in v1.3.0

func NewPrioritizedNodePointerMinPriorityComparator() *PrioritizedNodePointerMinPriorityComparator

func (PrioritizedNodePointerMinPriorityComparator) Equal added in v1.3.0

func (cmp PrioritizedNodePointerMinPriorityComparator) Equal(value1 interface{}, value2 interface{}) bool

func (PrioritizedNodePointerMinPriorityComparator) Less added in v1.3.0

func (cmp PrioritizedNodePointerMinPriorityComparator) Less(value1 interface{}, value2 interface{}) bool

type PrioritizedNodePointerValueList added in v1.3.0

type PrioritizedNodePointerValueList struct {
	// contains filtered or unexported fields

func NewPrioritizedNodePointerValueList added in v1.3.0

func NewPrioritizedNodePointerValueList(arr []PrioritizedNodePointer) *PrioritizedNodePointerValueList

func (*PrioritizedNodePointerValueList) Add added in v1.3.0

func (list *PrioritizedNodePointerValueList) Add(value interface{})

func (*PrioritizedNodePointerValueList) Clean added in v1.3.0

func (list *PrioritizedNodePointerValueList) Clean()

func (*PrioritizedNodePointerValueList) Get added in v1.3.0

func (list *PrioritizedNodePointerValueList) Get(index int) interface{}

func (*PrioritizedNodePointerValueList) GetLength added in v1.3.0

func (list *PrioritizedNodePointerValueList) GetLength() int

func (*PrioritizedNodePointerValueList) RemoveLast added in v1.3.0

func (list *PrioritizedNodePointerValueList) RemoveLast() interface{}

func (*PrioritizedNodePointerValueList) Set added in v1.3.0

func (list *PrioritizedNodePointerValueList) Set(index int, value interface{})

Jump to

Keyboard shortcuts

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