server

package
v1.9.6 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func VerifyFunctionSpec 

func VerifyFunctionSpec(funcSpec *core.FunctionSpec) error

func VerifyWorkflowSpec 

func VerifyWorkflowSpec(workflowSpec *core.WorkflowSpec) error

Types

type DatabaseMock 

type DatabaseMock struct {
	ReturnError string
	ReturnValue string
}

DatabaseMock implements all database interfaces for testing

func (*DatabaseMock) AddColony 

func (db *DatabaseMock) AddColony(colony *core.Colony) error

Implement key database interface methods as no-ops for testing ColonyDatabase interface

func (*DatabaseMock) AddExecutor 

func (db *DatabaseMock) AddExecutor(executor *core.Executor) error

ExecutorDatabase interface

func (*DatabaseMock) AddProcess 

func (db *DatabaseMock) AddProcess(process *core.Process) error

ProcessDatabase interface

func (*DatabaseMock) AddUser 

func (db *DatabaseMock) AddUser(user *core.User) error

UserDatabase interface

func (*DatabaseMock) Assign 

func (db *DatabaseMock) Assign(executorID string, colonyName string, cpu int64, memory int64) (*core.Process, error)

func (*DatabaseMock) Close 

func (db *DatabaseMock) Close() error

func (*DatabaseMock) CountExecutors 

func (db *DatabaseMock) CountExecutors() (int, error)

func (*DatabaseMock) CountFailedProcesses 

func (db *DatabaseMock) CountFailedProcesses() (int, error)

func (*DatabaseMock) CountProcesses 

func (db *DatabaseMock) CountProcesses() (int, error)

func (*DatabaseMock) CountRunningProcesses 

func (db *DatabaseMock) CountRunningProcesses() (int, error)

func (*DatabaseMock) CountSuccessfulProcesses 

func (db *DatabaseMock) CountSuccessfulProcesses() (int, error)

func (*DatabaseMock) CountUsers 

func (db *DatabaseMock) CountUsers() (int, error)

func (*DatabaseMock) CountWaitingProcesses 

func (db *DatabaseMock) CountWaitingProcesses() (int, error)

func (*DatabaseMock) CreateTables 

func (db *DatabaseMock) CreateTables() error

Implement basic database interface methods

func (*DatabaseMock) DropTables 

func (db *DatabaseMock) DropTables() error

func (*DatabaseMock) FindAllProcesses 

func (db *DatabaseMock) FindAllProcesses() ([]*core.Process, error)

func (*DatabaseMock) FindFailedProcesses 

func (db *DatabaseMock) FindFailedProcesses(colonyName string, count int) ([]*core.Process, error)

func (*DatabaseMock) FindProcessHistory 

func (db *DatabaseMock) FindProcessHistory(colonyName string, executorID string, seconds int, state int) ([]*core.Process, error)

func (*DatabaseMock) FindProcessesByColonyName 

func (db *DatabaseMock) FindProcessesByColonyName(colonyName string, count int, state int) ([]*core.Process, error)

func (*DatabaseMock) FindProcessesByExecutorID 

func (db *DatabaseMock) FindProcessesByExecutorID(executorID string, count int, state int) ([]*core.Process, error)

func (*DatabaseMock) FindRunningProcesses 

func (db *DatabaseMock) FindRunningProcesses(colonyName string, count int) ([]*core.Process, error)

func (*DatabaseMock) FindSuccessfulProcesses 

func (db *DatabaseMock) FindSuccessfulProcesses(colonyName string, count int) ([]*core.Process, error)

func (*DatabaseMock) FindWaitingProcesses 

func (db *DatabaseMock) FindWaitingProcesses(colonyName string, count int) ([]*core.Process, error)

func (*DatabaseMock) GetColonies 

func (db *DatabaseMock) GetColonies() ([]*core.Colony, error)

func (*DatabaseMock) GetColonyByID 

func (db *DatabaseMock) GetColonyByID(colonyID string) (*core.Colony, error)

func (*DatabaseMock) GetColonyByName 

func (db *DatabaseMock) GetColonyByName(name string) (*core.Colony, error)

func (*DatabaseMock) GetExecutorByID 

func (db *DatabaseMock) GetExecutorByID(executorID string) (*core.Executor, error)

func (*DatabaseMock) GetExecutorByName 

func (db *DatabaseMock) GetExecutorByName(colonyName string, executorName string) (*core.Executor, error)

func (*DatabaseMock) GetExecutorsByColonyName 

func (db *DatabaseMock) GetExecutorsByColonyName(colonyName string) ([]*core.Executor, error)

func (*DatabaseMock) GetProcessByID 

func (db *DatabaseMock) GetProcessByID(processID string) (*core.Process, error)

func (*DatabaseMock) GetUserByID 

func (db *DatabaseMock) GetUserByID(colonyName string, userID string) (*core.User, error)

func (*DatabaseMock) GetUserByName 

func (db *DatabaseMock) GetUserByName(colonyName string, name string) (*core.User, error)

func (*DatabaseMock) GetUsersByColonyName 

func (db *DatabaseMock) GetUsersByColonyName(colonyName string) ([]*core.User, error)

func (*DatabaseMock) MarkFailed 

func (db *DatabaseMock) MarkFailed(processID string, errs []string) error

func (*DatabaseMock) MarkRunning 

func (db *DatabaseMock) MarkRunning(processID string, executorID string) error

func (*DatabaseMock) MarkSuccessful 

func (db *DatabaseMock) MarkSuccessful(processID string, output []interface{}) error

func (*DatabaseMock) RemoveAllFailedProcessesByColonyName 

func (db *DatabaseMock) RemoveAllFailedProcessesByColonyName(colonyName string) error

func (*DatabaseMock) RemoveAllSuccessfulProcessesByColonyName 

func (db *DatabaseMock) RemoveAllSuccessfulProcessesByColonyName(colonyName string) error

func (*DatabaseMock) RemoveAllWaitingProcessesByColonyName 

func (db *DatabaseMock) RemoveAllWaitingProcessesByColonyName(colonyName string) error

func (*DatabaseMock) RemoveColonyByID 

func (db *DatabaseMock) RemoveColonyByID(colonyID string) error

func (*DatabaseMock) RemoveColonyByName 

func (db *DatabaseMock) RemoveColonyByName(name string) error

func (*DatabaseMock) RemoveExecutorByID 

func (db *DatabaseMock) RemoveExecutorByID(executorID string) error

func (*DatabaseMock) RemoveExecutorByName 

func (db *DatabaseMock) RemoveExecutorByName(colonyName string, executorName string) error

func (*DatabaseMock) RemoveExecutorsByColonyName 

func (db *DatabaseMock) RemoveExecutorsByColonyName(colonyName string) error

func (*DatabaseMock) RemoveProcessByID 

func (db *DatabaseMock) RemoveProcessByID(processID string) error

func (*DatabaseMock) RemoveUserByID 

func (db *DatabaseMock) RemoveUserByID(colonyName string, userID string) error

func (*DatabaseMock) RemoveUserByName 

func (db *DatabaseMock) RemoveUserByName(colonyName string, name string) error

func (*DatabaseMock) RemoveUsersByColonyName 

func (db *DatabaseMock) RemoveUsersByColonyName(colonyName string) error

func (*DatabaseMock) ResetProcess 

func (db *DatabaseMock) ResetProcess(processID string) error

func (*DatabaseMock) SetExecutorApprovalState 

func (db *DatabaseMock) SetExecutorApprovalState(executorID string, state int) error

func (*DatabaseMock) SetExecutorCommissionTime 

func (db *DatabaseMock) SetExecutorCommissionTime(executorID string) error

func (*DatabaseMock) SetExecutorState 

func (db *DatabaseMock) SetExecutorState(executorID string, state int) error

func (*DatabaseMock) SetOutput 

func (db *DatabaseMock) SetOutput(processID string, output []interface{}) error

func (*DatabaseMock) SetProcessState 

func (db *DatabaseMock) SetProcessState(processID string, state int) error

func (*DatabaseMock) SetWaitForParents 

func (db *DatabaseMock) SetWaitForParents(processID string, waitForParents bool) error

func (*DatabaseMock) SetWaitingTime 

func (db *DatabaseMock) SetWaitingTime(processID string) error

func (*DatabaseMock) Unassign 

func (db *DatabaseMock) Unassign(processID string) error

func (*DatabaseMock) UpdateExecutor 

func (db *DatabaseMock) UpdateExecutor(executor *core.Executor) error

type ValidatorMock 

type ValidatorMock struct {
	ReturnError string
}

ValidatorMock implements the security.Validator interface for testing

func (*ValidatorMock) GetColonyDB 

func (v *ValidatorMock) GetColonyDB() interface{}

func (*ValidatorMock) GetExecutorDB 

func (v *ValidatorMock) GetExecutorDB() interface{}

func (*ValidatorMock) GetUserDB 

func (v *ValidatorMock) GetUserDB() interface{}

func (*ValidatorMock) ParseSignature 

func (v *ValidatorMock) ParseSignature(payload string, signature string) (string, error)

func (*ValidatorMock) RequireColonyOwner 

func (v *ValidatorMock) RequireColonyOwner(recoveredID string, colonyName string) error

func (*ValidatorMock) RequireExecutorMembership 

func (v *ValidatorMock) RequireExecutorMembership(recoveredID string, colonyName string, targetExecutorID string) error

func (*ValidatorMock) RequireMembership 

func (v *ValidatorMock) RequireMembership(recoveredID string, colonyName string, executorMayJoin bool) error

func (*ValidatorMock) RequireServerOwner 

func (v *ValidatorMock) RequireServerOwner(recoveredID string, serverID string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.