client

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2023 License: MIT Imports: 9 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ColoniesClient 

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

func CreateColoniesClient 

func CreateColoniesClient(host string, port int, insecure bool, skipTLSVerify bool) *ColoniesClient

func (*ColoniesClient) AddAttribute 

func (client *ColoniesClient) AddAttribute(attribute core.Attribute, prvKey string) (core.Attribute, error)

func (*ColoniesClient) AddChild 

func (client *ColoniesClient) AddChild(processGraphID string, parentProcessID string, childProcessID string, funcSpec *core.FunctionSpec, insert bool, prvKey string) (*core.Process, error)

func (*ColoniesClient) AddColony 

func (client *ColoniesClient) AddColony(colony *core.Colony, prvKey string) (*core.Colony, error)

func (*ColoniesClient) AddCron 

func (client *ColoniesClient) AddCron(cron *core.Cron, prvKey string) (*core.Cron, error)

func (*ColoniesClient) AddExecutor added in v1.0.1 

func (client *ColoniesClient) AddExecutor(executor *core.Executor, prvKey string) (*core.Executor, error)

func (*ColoniesClient) AddFunction added in v1.0.1 

func (client *ColoniesClient) AddFunction(function *core.Function, prvKey string) (*core.Function, error)

func (*ColoniesClient) AddGenerator 

func (client *ColoniesClient) AddGenerator(generator *core.Generator, prvKey string) (*core.Generator, error)

func (*ColoniesClient) ApproveExecutor added in v1.0.1 

func (client *ColoniesClient) ApproveExecutor(executorID string, prvKey string) error

func (*ColoniesClient) Assign added in v1.0.1 

func (client *ColoniesClient) Assign(colonyID string, timeout int, prvKey string) (*core.Process, error)

func (*ColoniesClient) CheckHealth 

func (client *ColoniesClient) CheckHealth() error

func (*ColoniesClient) Close 

func (client *ColoniesClient) Close(processID string, prvKey string) error

func (*ColoniesClient) CloseWithOutput 

func (client *ColoniesClient) CloseWithOutput(processID string, output []interface{}, prvKey string) error

func (*ColoniesClient) ColonyStatistics 

func (client *ColoniesClient) ColonyStatistics(colonyID string, prvKey string) (*core.Statistics, error)

func (*ColoniesClient) DeleteAllProcessGraphs 

func (client *ColoniesClient) DeleteAllProcessGraphs(colonyID string, prvKey string) error

func (*ColoniesClient) DeleteAllProcesses 

func (client *ColoniesClient) DeleteAllProcesses(colonyID string, prvKey string) error

func (*ColoniesClient) DeleteColony 

func (client *ColoniesClient) DeleteColony(colonyID string, prvKey string) error

func (*ColoniesClient) DeleteCron 

func (client *ColoniesClient) DeleteCron(cronID string, prvKey string) error

func (*ColoniesClient) DeleteExecutor added in v1.0.1 

func (client *ColoniesClient) DeleteExecutor(executorID string, prvKey string) error

func (*ColoniesClient) DeleteFunction added in v1.0.1 

func (client *ColoniesClient) DeleteFunction(functionID string, prvKey string) error

func (*ColoniesClient) DeleteGenerator 

func (client *ColoniesClient) DeleteGenerator(generatorID string, prvKey string) error

func (*ColoniesClient) DeleteProcess 

func (client *ColoniesClient) DeleteProcess(processID string, prvKey string) error

func (*ColoniesClient) DeleteProcessGraph 

func (client *ColoniesClient) DeleteProcessGraph(processGraphID string, prvKey string) error

func (*ColoniesClient) Fail 

func (client *ColoniesClient) Fail(processID string, errs []string, prvKey string) error

func (*ColoniesClient) GetAttribute 

func (client *ColoniesClient) GetAttribute(attributeID string, prvKey string) (core.Attribute, error)

func (*ColoniesClient) GetClusterInfo 

func (client *ColoniesClient) GetClusterInfo(prvKey string) (*cluster.Config, error)

func (*ColoniesClient) GetColonies 

func (client *ColoniesClient) GetColonies(prvKey string) ([]*core.Colony, error)

func (*ColoniesClient) GetColonyByID 

func (client *ColoniesClient) GetColonyByID(colonyID string, prvKey string) (*core.Colony, error)

func (*ColoniesClient) GetCron 

func (client *ColoniesClient) GetCron(cronID string, prvKey string) (*core.Cron, error)

func (*ColoniesClient) GetCrons 

func (client *ColoniesClient) GetCrons(colonyID string, count int, prvKey string) ([]*core.Cron, error)

func (*ColoniesClient) GetExecutor added in v1.0.1 

func (client *ColoniesClient) GetExecutor(executorID string, prvKey string) (*core.Executor, error)

func (*ColoniesClient) GetExecutors added in v1.0.1 

func (client *ColoniesClient) GetExecutors(colonyID string, prvKey string) ([]*core.Executor, error)

func (*ColoniesClient) GetFailedProcessGraphs 

func (client *ColoniesClient) GetFailedProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)

func (*ColoniesClient) GetFailedProcesses 

func (client *ColoniesClient) GetFailedProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetFunctionsByColonyID added in v1.0.1 

func (client *ColoniesClient) GetFunctionsByColonyID(colonyID string, prvKey string) ([]*core.Function, error)

func (*ColoniesClient) GetFunctionsByExecutorID added in v1.0.1 

func (client *ColoniesClient) GetFunctionsByExecutorID(executorID string, prvKey string) ([]*core.Function, error)

func (*ColoniesClient) GetGenerator 

func (client *ColoniesClient) GetGenerator(generatorID string, prvKey string) (*core.Generator, error)

func (*ColoniesClient) GetGenerators 

func (client *ColoniesClient) GetGenerators(colonyID string, count int, prvKey string) ([]*core.Generator, error)

func (*ColoniesClient) GetProcess 

func (client *ColoniesClient) GetProcess(processID string, prvKey string) (*core.Process, error)

func (*ColoniesClient) GetProcessGraph 

func (client *ColoniesClient) GetProcessGraph(processGraphID string, prvKey string) (*core.ProcessGraph, error)

func (*ColoniesClient) GetProcessHistForColony 

func (client *ColoniesClient) GetProcessHistForColony(state int, colonyID string, seconds int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetProcessHistForExecutor added in v1.0.1 

func (client *ColoniesClient) GetProcessHistForExecutor(state int, colonyID string, executorID string, seconds int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetRunningProcessGraphs 

func (client *ColoniesClient) GetRunningProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)

func (*ColoniesClient) GetRunningProcesses 

func (client *ColoniesClient) GetRunningProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetSuccessfulProcessGraphs 

func (client *ColoniesClient) GetSuccessfulProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)

func (*ColoniesClient) GetSuccessfulProcesses 

func (client *ColoniesClient) GetSuccessfulProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetWaitingProcessGraphs 

func (client *ColoniesClient) GetWaitingProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)

func (*ColoniesClient) GetWaitingProcesses 

func (client *ColoniesClient) GetWaitingProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) PackGenerator 

func (client *ColoniesClient) PackGenerator(generatorID string, arg string, prvKey string) error

func (*ColoniesClient) RejectExecutor added in v1.0.1 

func (client *ColoniesClient) RejectExecutor(executorID string, prvKey string) error

func (*ColoniesClient) ResetDatabase 

func (client *ColoniesClient) ResetDatabase(prvKey string) error

func (*ColoniesClient) ResolveGenerator 

func (client *ColoniesClient) ResolveGenerator(generatorName string, prvKey string) (*core.Generator, error)

func (*ColoniesClient) RunCron 

func (client *ColoniesClient) RunCron(cronID string, prvKey string) (*core.Cron, error)

func (*ColoniesClient) SendRawMessage 

func (client *ColoniesClient) SendRawMessage(jsonString string, insecure bool) (string, error)

func (*ColoniesClient) Statistics 

func (client *ColoniesClient) Statistics(prvKey string) (*core.Statistics, error)

func (*ColoniesClient) Submit added in v1.0.1 

func (client *ColoniesClient) Submit(funcSpec *core.FunctionSpec, prvKey string) (*core.Process, error)

func (*ColoniesClient) SubmitWorkflowSpec 

func (client *ColoniesClient) SubmitWorkflowSpec(workflowSpec *core.WorkflowSpec, prvKey string) (*core.ProcessGraph, error)

func (*ColoniesClient) SubscribeProcess 

func (client *ColoniesClient) SubscribeProcess(processID string, executorType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)

func (*ColoniesClient) SubscribeProcesses 

func (client *ColoniesClient) SubscribeProcesses(executorType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)

func (*ColoniesClient) Version 

func (client *ColoniesClient) Version() (string, string, error)

type ProcessSubscription 

type ProcessSubscription struct {
	ProcessChan chan *core.Process
	ErrChan     chan error
	// contains filtered or unexported fields
}

func (*ProcessSubscription) Close 

func (subscription *ProcessSubscription) Close() 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.