utils

Feb 23, 2023

Changes in this version

+ type FunctionManagerStatistics struct

+ FunctionIDToTasks map[string]uint64

+ type MessageTypeStatistics struct

+ FunctionRequest uint64

+ FunctionResponse uint64

+ Heartbeat uint64

+ MonitoringRequest uint64

+ MonitoringResponse uint64

+ Task uint64

+ TaskCancel uint64

+ TaskCancelEcho uint64

+ TaskEcho uint64

+ TaskResult uint64

+ type SchedulerStatistics struct

+ FunctionManager *FunctionManagerStatistics

+ Received *MessageTypeStatistics

+ Sent *MessageTypeStatistics

+ TaskManager *TaskManagerStatistics

+ WorkerManager *WorkerManagerStatistics

+ type TaskManagerStatistics struct

+ Canceled uint64

+ Canceling uint64

+ Failed uint64

+ Running uint64

+ Unassigned uint64

+ type WorkerManagerStatistics struct

+ Type string

+ WorkerToTasks map[string]uint64

Feb 20, 2023

Changes in this version

+ type RouterChanneler struct

+ ErrCh chan error

+ RecvCh chan [][]byte

+ SendCh chan [][]byte

+ func NewRouterChanneler(endpoint string, identity string) *RouterChanneler

+ func (rc *RouterChanneler) Close()

Feb 20, 2023

Changes in this version

+ const GCSweepInterval

+ type Event struct

+ func NewEvent(set bool) *Event

+ func (r *Event) Clear()

+ func (r *Event) IsSet() bool

+ func (r *Event) Set()

+ func (r *Event) Wait(ctx context.Context) error

+ type WorkerHeap struct

+ Entries []*WorkerHeapEntry

+ WorkerIDToEntry map[string]*WorkerHeapEntry

+ func NewWorkerHeap() *WorkerHeap

+ func (h *WorkerHeap) AddTasks(workerID string, count int) int

+ func (h *WorkerHeap) Peek() *WorkerHeapEntry

+ func (h *WorkerHeap) Pop() any

+ func (h *WorkerHeap) Push(x any)

+ func (h WorkerHeap) Len() int

+ func (h WorkerHeap) Less(i, j int) bool

+ func (h WorkerHeap) Swap(i, j int)

+ type WorkerHeapEntry struct

+ Index int

+ Tasks int

+ WorkerID string