managers

Documentation

Index

• type ClientManager
  • func NewClientManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *ClientManager
• type FunctionManager
  • func NewFunctionManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics, ...) *FunctionManager
  • func (m *FunctionManager) AddFunction(functionID uuid.UUID, function []byte) error
  • func (m *FunctionManager) GetStatistics() *utils.FunctionManagerStatistics
  • func (m *FunctionManager) HandleFunctionRequest(source string, request *protocol.FunctionRequest)
  • func (m *FunctionManager) HasFunction(functionID uuid.UUID) bool
  • func (m *FunctionManager) OnFunctionAdd(source string, functionID uuid.UUID, function []byte)
  • func (m *FunctionManager) OnFunctionCheck(source string, functionID uuid.UUID)
  • func (m *FunctionManager) OnFunctionDelete(source string, functionID uuid.UUID)
  • func (m *FunctionManager) OnFunctionRequest(source string, functionID uuid.UUID)
  • func (m *FunctionManager) RemoveFunction(functionID uuid.UUID) error
  • func (m *FunctionManager) RunGC(ctx context.Context, wg *sync.WaitGroup)
  • func (m *FunctionManager) SetTaskDone(taskID, functionID uuid.UUID) error
  • func (m *FunctionManager) SetTaskUse(taskID, functionID uuid.UUID) error
• type TaskManager
  • func NewTaskManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *TaskManager
  • func (m *TaskManager) GetStatistics() *utils.TaskManagerStatistics
  • func (m *TaskManager) OnAssignTask(ctx context.Context, entry *TaskQueueEntry) error
  • func (m *TaskManager) OnTaskCancel(clientID string, taskID uuid.UUID) error
  • func (m *TaskManager) OnTaskCanceled(result *protocol.TaskResult) error
  • func (m *TaskManager) OnTaskDone(result *protocol.TaskResult) error
  • func (m *TaskManager) OnTaskFailed(result *protocol.TaskResult) error
  • func (m *TaskManager) OnTaskNew(clientID string, task *protocol.Task) error
  • func (m *TaskManager) OnTaskReroute(taskID uuid.UUID) error
  • func (m *TaskManager) OnTaskSuccess(result *protocol.TaskResult) error
  • func (m *TaskManager) RunTaskAssignLoop(ctx context.Context, wg *sync.WaitGroup)
  • func (m *TaskManager) SetFunctionManager(functionManager *FunctionManager)
  • func (m *TaskManager) SetWorkerManager(workerManager *WorkerManager)
• type TaskQueueEntry
• type WorkerManager
  • func NewWorkerManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics, ...) *WorkerManager
  • func (m *WorkerManager) GetStatistics() *utils.WorkerManagerStatistics
  • func (m *WorkerManager) OnAssignTask(ctx context.Context, task *protocol.Task) error
  • func (m *WorkerManager) OnHeartbeat(workerID string)
  • func (m *WorkerManager) OnTaskCancel(taskID uuid.UUID) error
  • func (m *WorkerManager) OnTaskDone(taskResult *protocol.TaskResult) error
  • func (m *WorkerManager) RunGC(ctx context.Context, wg *sync.WaitGroup)
  • func (m *WorkerManager) SetTaskManager(taskManager *TaskManager)

Types

type ClientManager

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

func NewClientManager

func NewClientManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *ClientManager

type FunctionManager

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

func NewFunctionManager

func NewFunctionManager(
	router *protocol.Socket,
	sentStatistics *utils.MessageTypeStatistics,
	functionRetention time.Duration,
) *FunctionManager

func (*FunctionManager) AddFunction

func (m *FunctionManager) AddFunction(functionID uuid.UUID, function []byte) error

func (*FunctionManager) GetStatistics

func (m *FunctionManager) GetStatistics() *utils.FunctionManagerStatistics

func (*FunctionManager) HandleFunctionRequest

func (m *FunctionManager) HandleFunctionRequest(source string, request *protocol.FunctionRequest)

func (*FunctionManager) HasFunction

func (m *FunctionManager) HasFunction(functionID uuid.UUID) bool

func (*FunctionManager) OnFunctionAdd

func (m *FunctionManager) OnFunctionAdd(source string, functionID uuid.UUID, function []byte)

func (*FunctionManager) OnFunctionCheck

func (m *FunctionManager) OnFunctionCheck(source string, functionID uuid.UUID)

func (*FunctionManager) OnFunctionDelete

func (m *FunctionManager) OnFunctionDelete(source string, functionID uuid.UUID)

func (*FunctionManager) OnFunctionRequest

func (m *FunctionManager) OnFunctionRequest(source string, functionID uuid.UUID)

func (*FunctionManager) RemoveFunction

func (m *FunctionManager) RemoveFunction(functionID uuid.UUID) error

func (*FunctionManager) RunGC

func (m *FunctionManager) RunGC(ctx context.Context, wg *sync.WaitGroup)

func (*FunctionManager) SetTaskDone

func (m *FunctionManager) SetTaskDone(taskID, functionID uuid.UUID) error

func (*FunctionManager) SetTaskUse

func (m *FunctionManager) SetTaskUse(taskID, functionID uuid.UUID) error

type TaskManager

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

func NewTaskManager

func NewTaskManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *TaskManager

func (*TaskManager) GetStatistics

func (m *TaskManager) GetStatistics() *utils.TaskManagerStatistics

func (*TaskManager) OnAssignTask

func (m *TaskManager) OnAssignTask(ctx context.Context, entry *TaskQueueEntry) error

func (*TaskManager) OnTaskCancel

func (m *TaskManager) OnTaskCancel(clientID string, taskID uuid.UUID) error

func (*TaskManager) OnTaskCanceled

func (m *TaskManager) OnTaskCanceled(result *protocol.TaskResult) error

func (*TaskManager) OnTaskDone

func (m *TaskManager) OnTaskDone(result *protocol.TaskResult) error

func (*TaskManager) OnTaskFailed

func (m *TaskManager) OnTaskFailed(result *protocol.TaskResult) error

func (*TaskManager) OnTaskNew

func (m *TaskManager) OnTaskNew(clientID string, task *protocol.Task) error

func (*TaskManager) OnTaskReroute

func (m *TaskManager) OnTaskReroute(taskID uuid.UUID) error

func (*TaskManager) OnTaskSuccess

func (m *TaskManager) OnTaskSuccess(result *protocol.TaskResult) error

func (*TaskManager) RunTaskAssignLoop

func (m *TaskManager) RunTaskAssignLoop(ctx context.Context, wg *sync.WaitGroup)

func (*TaskManager) SetFunctionManager

func (m *TaskManager) SetFunctionManager(functionManager *FunctionManager)

func (*TaskManager) SetWorkerManager

func (m *TaskManager) SetWorkerManager(workerManager *WorkerManager)

type TaskQueueEntry

type TaskQueueEntry struct {
	Task     *protocol.Task
	ClientID string
}

type WorkerManager

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

func NewWorkerManager

func NewWorkerManager(
	router *protocol.Socket,
	sentStatistics *utils.MessageTypeStatistics,
	perWorkerQueueSize int,
	workerTimeout time.Duration,
) *WorkerManager

func (*WorkerManager) GetStatistics

func (m *WorkerManager) GetStatistics() *utils.WorkerManagerStatistics

func (*WorkerManager) OnAssignTask

func (m *WorkerManager) OnAssignTask(ctx context.Context, task *protocol.Task) error

func (*WorkerManager) OnHeartbeat

func (m *WorkerManager) OnHeartbeat(workerID string)

func (*WorkerManager) OnTaskCancel

func (m *WorkerManager) OnTaskCancel(taskID uuid.UUID) error

func (*WorkerManager) OnTaskDone

func (m *WorkerManager) OnTaskDone(taskResult *protocol.TaskResult) error

func (*WorkerManager) RunGC

func (m *WorkerManager) RunGC(ctx context.Context, wg *sync.WaitGroup)

func (*WorkerManager) SetTaskManager

func (m *WorkerManager) SetTaskManager(taskManager *TaskManager)