managers

package

v0.0.11 Latest Latest Go to latest Published: Feb 26, 2023 License: BSD-3-Clause Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/darenliang/scaled-scheduler-go

Links

Open Source Insights

Documentation ¶

Index ¶

type ClientManager
- func NewClientManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *ClientManager
type FunctionManager
- func NewFunctionManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics, ...) *FunctionManager
type TaskManager
- func NewTaskManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics) *TaskManager
type TaskQueueEntry
type WorkerManager
- func NewWorkerManager(router *protocol.Socket, sentStatistics *utils.MessageTypeStatistics, ...) *WorkerManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.0.6

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 ¶ added in v0.0.6

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 ¶ added in v0.0.6

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)

Source Files ¶

View all Source files

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