storage

Documentation

Index

• Variables
• type PqChannelStorage
  • func NewPqChannelStorage() PqChannelStorage
  • func (p *PqChannelStorage) CheckScheduled(nowTimestamp int) bool
  • func (p *PqChannelStorage) Dequeue() message.Message
  • func (p *PqChannelStorage) Dump() []message.Message
  • func (p *PqChannelStorage) Enqueue(value message.Message)
  • func (p *PqChannelStorage) Flush()
  • func (p *PqChannelStorage) IsEmpty() bool
• type PqStorage
  • func NewPqStorage() *PqStorage
  • func (p *PqStorage) AddChannel(c channel.Channel) (channel.Channel, error)
  • func (p *PqStorage) DeleteChannel(channelID string) (channel.Channel, error)
  • func (p *PqStorage) Dump() ([]channel.Channel, map[string][]message.Message)
  • func (p *PqStorage) Flush()
  • func (p *PqStorage) GetChannel(channelID string) (channel.Channel, error)
  • func (p *PqStorage) GetChannelStorage(channelID string) (PqChannelStorage, bool)
  • func (p *PqStorage) GetChannels() []channel.Channel
  • func (p *PqStorage) UpdateChannel(channelID string, c channel.Channel) (channel.Channel, error)
• type PrioritizedNodePointer
  • func NewPrioritizedNodePointer(value *doublylinkedlist.Node, priority int) PrioritizedNodePointer
  • func (v PrioritizedNodePointer) GetPriority() int
  • func (v PrioritizedNodePointer) GetValue() interface{}
• type PrioritizedNodePointerMinPriorityComparator
  • func NewPrioritizedNodePointerMinPriorityComparator() *PrioritizedNodePointerMinPriorityComparator
  • func (cmp PrioritizedNodePointerMinPriorityComparator) Equal(value1 interface{}, value2 interface{}) bool
  • func (cmp PrioritizedNodePointerMinPriorityComparator) Less(value1 interface{}, value2 interface{}) bool
• type PrioritizedNodePointerValueList
  • func NewPrioritizedNodePointerValueList(arr []PrioritizedNodePointer) *PrioritizedNodePointerValueList
  • func (list *PrioritizedNodePointerValueList) Add(value interface{})
  • func (list *PrioritizedNodePointerValueList) Clean()
  • func (list *PrioritizedNodePointerValueList) Get(index int) interface{}
  • func (list *PrioritizedNodePointerValueList) GetLength() int
  • func (list *PrioritizedNodePointerValueList) RemoveLast() interface{}
  • func (list *PrioritizedNodePointerValueList) Set(index int, value interface{})

Variables

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

Types

type PqChannelStorage

type PqChannelStorage struct {
	// contains filtered or unexported fields
}

func NewPqChannelStorage

func NewPqChannelStorage() PqChannelStorage

func (*PqChannelStorage) CheckScheduled

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

func (*PqChannelStorage) Dequeue

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

func (*PqChannelStorage) Dump

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

func (*PqChannelStorage) Enqueue

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

func (*PqChannelStorage) Flush

func (p *PqChannelStorage) Flush()

func (*PqChannelStorage) IsEmpty

func (p *PqChannelStorage) IsEmpty() bool

type PqStorage

type PqStorage struct {
	// contains filtered or unexported fields
}

func NewPqStorage

func NewPqStorage() *PqStorage

func (*PqStorage) AddChannel

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

func (*PqStorage) DeleteChannel

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

func (*PqStorage) Dump

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

func (*PqStorage) Flush

func (p *PqStorage) Flush()

func (*PqStorage) GetChannel

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

func (*PqStorage) GetChannelStorage

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

func (*PqStorage) GetChannels

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

func (*PqStorage) UpdateChannel

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

type PrioritizedNodePointer

type PrioritizedNodePointer struct {
	// contains filtered or unexported fields
}

func NewPrioritizedNodePointer

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

func (PrioritizedNodePointer) GetPriority

func (v PrioritizedNodePointer) GetPriority() int

func (PrioritizedNodePointer) GetValue

func (v PrioritizedNodePointer) GetValue() interface{}

type PrioritizedNodePointerMinPriorityComparator

type PrioritizedNodePointerMinPriorityComparator struct{ comparator.AbstractComparator }

func NewPrioritizedNodePointerMinPriorityComparator

func NewPrioritizedNodePointerMinPriorityComparator() *PrioritizedNodePointerMinPriorityComparator

func (PrioritizedNodePointerMinPriorityComparator) Equal

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

func (PrioritizedNodePointerMinPriorityComparator) Less

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

type PrioritizedNodePointerValueList

type PrioritizedNodePointerValueList struct {
	arraylist.AbstractArrayList
	// contains filtered or unexported fields
}

func NewPrioritizedNodePointerValueList

func NewPrioritizedNodePointerValueList(arr []PrioritizedNodePointer) *PrioritizedNodePointerValueList

func (*PrioritizedNodePointerValueList) Add

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

func (*PrioritizedNodePointerValueList) Clean

func (list *PrioritizedNodePointerValueList) Clean()

func (*PrioritizedNodePointerValueList) Get

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

func (*PrioritizedNodePointerValueList) GetLength

func (list *PrioritizedNodePointerValueList) GetLength() int

func (*PrioritizedNodePointerValueList) RemoveLast

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

func (*PrioritizedNodePointerValueList) Set

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