client

Documentation

Index

• type ColoniesClient
  • func CreateColoniesClient(host string, port int, insecure bool, skipTLSVerify bool) *ColoniesClient
  • func (client *ColoniesClient) AddAttribute(attribute core.Attribute, prvKey string) (core.Attribute, error)
  • func (client *ColoniesClient) AddChild(processGraphID string, processID string, processSpec *core.ProcessSpec, ...) (*core.Process, error)
  • func (client *ColoniesClient) AddColony(colony *core.Colony, prvKey string) (*core.Colony, error)
  • func (client *ColoniesClient) AddCron(cron *core.Cron, prvKey string) (*core.Cron, error)
  • func (client *ColoniesClient) AddGenerator(generator *core.Generator, prvKey string) (*core.Generator, error)
  • func (client *ColoniesClient) AddRuntime(runtime *core.Runtime, prvKey string) (*core.Runtime, error)
  • func (client *ColoniesClient) ApproveRuntime(runtimeID string, prvKey string) error
  • func (client *ColoniesClient) AssignLatestProcess(colonyID string, timeout int, prvKey string) (*core.Process, error)
  • func (client *ColoniesClient) AssignProcess(colonyID string, timeout int, prvKey string) (*core.Process, error)
  • func (client *ColoniesClient) CheckHealth() error
  • func (client *ColoniesClient) Close(processID string, prvKey string) error
  • func (client *ColoniesClient) CloseWithOutput(processID string, output []string, prvKey string) error
  • func (client *ColoniesClient) ColonyStatistics(colonyID string, prvKey string) (*core.Statistics, error)
  • func (client *ColoniesClient) DeleteAllProcessGraphs(colonyID string, prvKey string) error
  • func (client *ColoniesClient) DeleteAllProcesses(colonyID string, prvKey string) error
  • func (client *ColoniesClient) DeleteColony(colonyID string, prvKey string) error
  • func (client *ColoniesClient) DeleteCron(cronID string, prvKey string) error
  • func (client *ColoniesClient) DeleteGenerator(generatorID string, prvKey string) error
  • func (client *ColoniesClient) DeleteProcess(processID string, prvKey string) error
  • func (client *ColoniesClient) DeleteProcessGraph(processGraphID string, prvKey string) error
  • func (client *ColoniesClient) DeleteRuntime(runtimeID string, prvKey string) error
  • func (client *ColoniesClient) Fail(processID string, errs []string, prvKey string) error
  • func (client *ColoniesClient) GetAttribute(attributeID string, prvKey string) (core.Attribute, error)
  • func (client *ColoniesClient) GetClusterInfo(prvKey string) (*cluster.Config, error)
  • func (client *ColoniesClient) GetColonies(prvKey string) ([]*core.Colony, error)
  • func (client *ColoniesClient) GetColonyByID(colonyID string, prvKey string) (*core.Colony, error)
  • func (client *ColoniesClient) GetCron(cronID string, prvKey string) (*core.Cron, error)
  • func (client *ColoniesClient) GetCrons(colonyID string, count int, prvKey string) ([]*core.Cron, error)
  • func (client *ColoniesClient) GetFailedProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)
  • func (client *ColoniesClient) GetFailedProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) GetGenerator(generatorID string, prvKey string) (*core.Generator, error)
  • func (client *ColoniesClient) GetGenerators(colonyID string, count int, prvKey string) ([]*core.Generator, error)
  • func (client *ColoniesClient) GetProcess(processID string, prvKey string) (*core.Process, error)
  • func (client *ColoniesClient) GetProcessGraph(processGraphID string, prvKey string) (*core.ProcessGraph, error)
  • func (client *ColoniesClient) GetProcessHistForColony(state int, colonyID string, seconds int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) GetProcessHistForRuntime(state int, colonyID string, runtimeID string, seconds int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) GetRunningProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)
  • func (client *ColoniesClient) GetRunningProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) GetRuntime(runtimeID string, prvKey string) (*core.Runtime, error)
  • func (client *ColoniesClient) GetRuntimes(colonyID string, prvKey string) ([]*core.Runtime, error)
  • func (client *ColoniesClient) GetSuccessfulProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)
  • func (client *ColoniesClient) GetSuccessfulProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) GetWaitingProcessGraphs(colonyID string, count int, prvKey string) ([]*core.ProcessGraph, error)
  • func (client *ColoniesClient) GetWaitingProcesses(colonyID string, count int, prvKey string) ([]*core.Process, error)
  • func (client *ColoniesClient) PackGenerator(generatorID string, arg string, prvKey string) error
  • func (client *ColoniesClient) RejectRuntime(runtimeID string, prvKey string) error
  • func (client *ColoniesClient) ResetDatabase(prvKey string) error
  • func (client *ColoniesClient) ResolveGenerator(generatorName string, prvKey string) (*core.Generator, error)
  • func (client *ColoniesClient) RunCron(cronID string, prvKey string) (*core.Cron, error)
  • func (client *ColoniesClient) Statistics(prvKey string) (*core.Statistics, error)
  • func (client *ColoniesClient) SubmitProcessSpec(processSpec *core.ProcessSpec, prvKey string) (*core.Process, error)
  • func (client *ColoniesClient) SubmitWorkflowSpec(workflowSpec *core.WorkflowSpec, prvKey string) (*core.ProcessGraph, error)
  • func (client *ColoniesClient) SubscribeProcess(processID string, runtimeType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)
  • func (client *ColoniesClient) SubscribeProcesses(runtimeType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)
  • func (client *ColoniesClient) Version() (string, string, error)
• type ProcessSubscription
  • func (subscription *ProcessSubscription) Close() error

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, processID string, processSpec *core.ProcessSpec, 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) AddGenerator

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

func (*ColoniesClient) AddRuntime

func (client *ColoniesClient) AddRuntime(runtime *core.Runtime, prvKey string) (*core.Runtime, error)

func (*ColoniesClient) ApproveRuntime

func (client *ColoniesClient) ApproveRuntime(runtimeID string, prvKey string) error

func (*ColoniesClient) AssignLatestProcess

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

func (*ColoniesClient) AssignProcess

func (client *ColoniesClient) AssignProcess(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 []string, 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) 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) DeleteRuntime

func (client *ColoniesClient) DeleteRuntime(runtimeID 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) 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) 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) GetProcessHistForRuntime

func (client *ColoniesClient) GetProcessHistForRuntime(state int, colonyID string, runtimeID 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) GetRuntime

func (client *ColoniesClient) GetRuntime(runtimeID string, prvKey string) (*core.Runtime, error)

func (*ColoniesClient) GetRuntimes

func (client *ColoniesClient) GetRuntimes(colonyID string, prvKey string) ([]*core.Runtime, 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) RejectRuntime

func (client *ColoniesClient) RejectRuntime(runtimeID 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) Statistics

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

func (*ColoniesClient) SubmitProcessSpec

func (client *ColoniesClient) SubmitProcessSpec(processSpec *core.ProcessSpec, 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, runtimeType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)

func (*ColoniesClient) SubscribeProcesses

func (client *ColoniesClient) SubscribeProcesses(runtimeType 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