utils

Documentation

Index

• Variables
• func GetenvDefault(key, defaultVal string) string
• func InterruptSignal() <-chan os.Signal
• func UuidMod(x uuid.UUID, mod uint64) uint64
• type Notificator
  • func NewNotificator() *Notificator
  • func (this *Notificator) Create(bufSize int) (<-chan interface{}, uuid.UUID)
  • func (this *Notificator) Notify(id uuid.UUID, v interface{}, blocking bool) error
  • func (this *Notificator) Remove(id uuid.UUID) error
• type PriorityQueue
  • func NewMaxPriorityQueue(items ...*PriorityQueueItem) PriorityQueue
  • func NewMinPriorityQueue(items ...*PriorityQueueItem) PriorityQueue
• type PriorityQueueItem
  • func NewPriorityQueueItem(priority float32, value interface{}) *PriorityQueueItem
  • func (item *PriorityQueueItem) Priority() float32
  • func (item *PriorityQueueItem) Value() interface{}

Variables

var (
	ErrNotificatorChannelDoesNotExist  error = errors.New("Notificator channel does not exist")
	ErrNotificatorReceiverNotAvailable error = errors.New("Notificator receiver not available")
)

Functions

func GetenvDefault

func GetenvDefault(key, defaultVal string) string

func InterruptSignal

func InterruptSignal() <-chan os.Signal

func UuidMod

func UuidMod(x uuid.UUID, mod uint64) uint64

Types

type Notificator

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

func NewNotificator

func NewNotificator() *Notificator

func (*Notificator) Create

func (this *Notificator) Create(bufSize int) (<-chan interface{}, uuid.UUID)

func (*Notificator) Notify

func (this *Notificator) Notify(id uuid.UUID, v interface{}, blocking bool) error

func (*Notificator) Remove

func (this *Notificator) Remove(id uuid.UUID) error

type PriorityQueue

type PriorityQueue interface {
	Len() int
	Push(*PriorityQueueItem)
	Pop() *PriorityQueueItem
	Peek() *PriorityQueueItem
	Reverse() PriorityQueue
	ToSlice() []*PriorityQueueItem
	ToIterator() <-chan *PriorityQueueItem
	Values() []interface{}
}

func NewMaxPriorityQueue

func NewMaxPriorityQueue(items ...*PriorityQueueItem) PriorityQueue

func NewMinPriorityQueue

func NewMinPriorityQueue(items ...*PriorityQueueItem) PriorityQueue

type PriorityQueueItem

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

func NewPriorityQueueItem

func NewPriorityQueueItem(priority float32, value interface{}) *PriorityQueueItem

func (*PriorityQueueItem) Priority

func (item *PriorityQueueItem) Priority() float32

Item

func (*PriorityQueueItem) Value

func (item *PriorityQueueItem) Value() interface{}