utils

package
v0.0.2-0...-6735cf7 Latest Latest
Warning

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

Go to latest
Published: May 2, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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{}

Jump to

Keyboard shortcuts

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