client

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: 10 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExampleBackendUsage added in v1.9.0 

func ExampleBackendUsage()

ExampleBackendUsage demonstrates how to create clients with different backends

func RegisterBackendFactory added in v1.9.0 

func RegisterBackendFactory(factory backends.ClientBackendFactory)

RegisterBackendFactory registers a backend factory

Types

type ColoniesClient 

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

ColoniesClient is the main client for interacting with Colonies server

func CreateColoniesClient 

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

CreateColoniesClient creates a new ColoniesClient with default HTTP/Gin backend

func CreateColoniesClientWithConfig added in v1.9.0 

func CreateColoniesClientWithConfig(config *backends.ClientConfig) *ColoniesClient

CreateColoniesClientWithConfig creates a new ColoniesClient with specified configuration

func CreateColoniesClientWithMultipleBackends added in v1.9.0 

func CreateColoniesClientWithMultipleBackends(configs []*backends.ClientConfig) *ColoniesClient

CreateColoniesClientWithMultipleBackends creates a client that tries multiple backends with fallback

func (*ColoniesClient) AddAttribute 

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

func (*ColoniesClient) AddBlueprint added in v1.9.3 

func (client *ColoniesClient) AddBlueprint(blueprint *core.Blueprint, prvKey string) (*core.Blueprint, error)

AddBlueprint adds a new Blueprint instance

func (*ColoniesClient) AddBlueprintDefinition added in v1.9.3 

func (client *ColoniesClient) AddBlueprintDefinition(sd *core.BlueprintDefinition, prvKey string) (*core.BlueprintDefinition, error)

AddBlueprintDefinition adds a new BlueprintDefinition (requires colony owner privileges)

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) AddFile added in v1.5.0 

func (client *ColoniesClient) AddFile(file *core.File, prvKey string) (*core.File, 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) AddLocation added in v1.9.6 

func (client *ColoniesClient) AddLocation(location *core.Location, prvKey string) (*core.Location, error)

func (*ColoniesClient) AddLog added in v1.4.0 

func (client *ColoniesClient) AddLog(processID string, logmsg string, prvKey string) error

func (*ColoniesClient) AddLogToExecutor added in v1.9.6 

func (client *ColoniesClient) AddLogToExecutor(colonyName, executorName, logmsg, prvKey string) error

AddLogToExecutor adds a log entry for an executor without requiring a process context. This is useful for executor startup logs, background operations, and diagnostics.

func (*ColoniesClient) AddUser added in v1.7.0 

func (client *ColoniesClient) AddUser(user *core.User, prvKey string) (*core.User, error)

func (*ColoniesClient) ApproveExecutor added in v1.0.1 

func (client *ColoniesClient) ApproveExecutor(colonyName string, executorName string, prvKey string) error

func (*ColoniesClient) AreColonyAssignmentsPaused added in v1.8.19 

func (client *ColoniesClient) AreColonyAssignmentsPaused(colonyName string, prvKey string) (bool, error)

func (*ColoniesClient) Assign added in v1.0.1 

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

func (*ColoniesClient) AssignWithContext added in v1.1.1 

func (client *ColoniesClient) AssignWithContext(colonyName string,
	timeout int,
	ctx context.Context,
	availableCPU string,
	availableMem string,
	prvKey string) (*core.Process, error)

func (*ColoniesClient) ChangeColonyID added in v1.7.7 

func (client *ColoniesClient) ChangeColonyID(colonyName, colonyID string, prvKey string) error

func (*ColoniesClient) ChangeExecutorID added in v1.7.7 

func (client *ColoniesClient) ChangeExecutorID(colonyName, executorID string, prvKey string) error

func (*ColoniesClient) ChangeServerID added in v1.7.7 

func (client *ColoniesClient) ChangeServerID(serverID string, prvKey string) error

func (*ColoniesClient) ChangeUserID added in v1.7.7 

func (client *ColoniesClient) ChangeUserID(colonyName, userID string, prvKey string) error

func (*ColoniesClient) ChannelAppend added in v1.9.6 

func (client *ColoniesClient) ChannelAppend(processID string, channelName string, sequence int64, inReplyTo int64, payload []byte, prvKey string) error

ChannelAppend appends a message to a channel

func (*ColoniesClient) ChannelAppendWithType added in v1.9.6 

func (client *ColoniesClient) ChannelAppendWithType(processID string, channelName string, sequence int64, inReplyTo int64, payload []byte, msgType string, prvKey string) error

ChannelAppendWithType appends a typed message to a channel (e.g., "end" for end-of-stream)

func (*ColoniesClient) ChannelRead added in v1.9.6 

func (client *ColoniesClient) ChannelRead(processID string, channelName string, afterIndex int64, limit int, prvKey string) ([]*channel.MsgEntry, error)

ChannelRead reads messages from a channel after a given index

func (*ColoniesClient) CheckHealth 

func (client *ColoniesClient) CheckHealth() error

func (*ColoniesClient) Close 

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

func (*ColoniesClient) CloseClient added in v1.9.0 

func (client *ColoniesClient) CloseClient() error

CloseClient closes the client and cleans up blueprints

func (*ColoniesClient) CloseWithOutput 

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

func (*ColoniesClient) ColonyStatistics 

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

func (*ColoniesClient) CreateSnapshot added in v1.5.0 

func (client *ColoniesClient) CreateSnapshot(colonyName string, label string, name string, prvKey string) (*core.Snapshot, 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) GetBlueprint added in v1.9.3 

func (client *ColoniesClient) GetBlueprint(namespace, name string, prvKey string) (*core.Blueprint, error)

GetBlueprint retrieves a Blueprint by namespace and name

func (*ColoniesClient) GetBlueprintDefinition added in v1.9.3 

func (client *ColoniesClient) GetBlueprintDefinition(colonyName, name string, prvKey string) (*core.BlueprintDefinition, error)

GetBlueprintDefinition retrieves a BlueprintDefinition by name

func (*ColoniesClient) GetBlueprintDefinitionByKind added in v1.9.6 

func (client *ColoniesClient) GetBlueprintDefinitionByKind(colonyName, kind string, prvKey string) (*core.BlueprintDefinition, error)

GetBlueprintDefinitionByKind retrieves a BlueprintDefinition by its Kind name

func (*ColoniesClient) GetBlueprintDefinitions added in v1.9.3 

func (client *ColoniesClient) GetBlueprintDefinitions(colonyName string, prvKey string) ([]*core.BlueprintDefinition, error)

GetBlueprintDefinitions retrieves all BlueprintDefinitions in a colony

func (*ColoniesClient) GetBlueprintHistory added in v1.9.3 

func (client *ColoniesClient) GetBlueprintHistory(blueprintID string, limit int, prvKey string) ([]*core.BlueprintHistory, error)

GetBlueprintHistory retrieves history for a blueprint

func (*ColoniesClient) GetBlueprints added in v1.9.3 

func (client *ColoniesClient) GetBlueprints(namespace, kind string, prvKey string) ([]*core.Blueprint, error)

GetBlueprints retrieves Blueprints by namespace and optionally by kind

func (*ColoniesClient) GetBlueprintsByLocation added in v1.9.6 

func (client *ColoniesClient) GetBlueprintsByLocation(namespace, kind, locationName string, prvKey string) ([]*core.Blueprint, error)

GetBlueprintsByLocation retrieves Blueprints by namespace, kind, and location If locationName is empty, all blueprints matching namespace and kind are returned

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) GetColonyByName added in v1.7.0 

func (client *ColoniesClient) GetColonyByName(colonyName string, prvKey string) (*core.Colony, error)

func (*ColoniesClient) GetConfig added in v1.9.0 

func (client *ColoniesClient) GetConfig() *backends.ClientConfig

GetConfig returns the client configuration

func (*ColoniesClient) GetCron 

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

func (*ColoniesClient) GetCrons 

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

func (*ColoniesClient) GetExecutor added in v1.0.1 

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

func (*ColoniesClient) GetExecutorByID added in v1.9.3 

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

func (*ColoniesClient) GetExecutors added in v1.0.1 

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

func (*ColoniesClient) GetFailedProcessGraphs 

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

func (*ColoniesClient) GetFailedProcesses 

func (client *ColoniesClient) GetFailedProcesses(colonyName string, executorType string, label string, initiator string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetFileByID added in v1.5.0 

func (client *ColoniesClient) GetFileByID(colonyName string, fileID string, prvKey string) ([]*core.File, error)

func (*ColoniesClient) GetFileByName added in v1.5.0 

func (client *ColoniesClient) GetFileByName(colonyName string, label string, name string, prvKey string) ([]*core.File, error)

func (*ColoniesClient) GetFileData added in v1.7.4 

func (client *ColoniesClient) GetFileData(colonyName string, label string, prvKey string) ([]*core.FileData, error)

func (*ColoniesClient) GetFileLabels added in v1.5.0 

func (client *ColoniesClient) GetFileLabels(colonyName string, prvKey string) ([]*core.Label, error)

func (*ColoniesClient) GetFileLabelsByName added in v1.6.0 

func (client *ColoniesClient) GetFileLabelsByName(colonyName string, name string, exact bool, prvKey string) ([]*core.Label, error)

func (*ColoniesClient) GetFunctionsByColony added in v1.7.7 

func (client *ColoniesClient) GetFunctionsByColony(colonyName string, prvKey string) ([]*core.Function, error)

func (*ColoniesClient) GetFunctionsByExecutor added in v1.7.7 

func (client *ColoniesClient) GetFunctionsByExecutor(colonyName string, executorName 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(colonyName string, count int, prvKey string) ([]*core.Generator, error)

func (*ColoniesClient) GetLatestFileByName added in v1.5.0 

func (client *ColoniesClient) GetLatestFileByName(colonyName string, label string, name string, prvKey string) ([]*core.File, error)

func (*ColoniesClient) GetLocation added in v1.9.6 

func (client *ColoniesClient) GetLocation(colonyName string, locationName string, prvKey string) (*core.Location, error)

func (*ColoniesClient) GetLocations added in v1.9.6 

func (client *ColoniesClient) GetLocations(colonyName string, prvKey string) ([]*core.Location, error)

func (*ColoniesClient) GetLogsByExecutor added in v1.7.7 

func (client *ColoniesClient) GetLogsByExecutor(colonyName, executorName string, count int, prvKey string) ([]*core.Log, error)

func (*ColoniesClient) GetLogsByExecutorLatest added in v1.9.6 

func (client *ColoniesClient) GetLogsByExecutorLatest(colonyName, executorName string, count int, prvKey string) ([]*core.Log, error)

GetLogsByExecutorLatest returns the latest logs for an executor (most recent count logs)

func (*ColoniesClient) GetLogsByExecutorSince added in v1.7.7 

func (client *ColoniesClient) GetLogsByExecutorSince(colonyName, executorName string, count int, since int64, prvKey string) ([]*core.Log, error)

func (*ColoniesClient) GetLogsByProcess added in v1.7.7 

func (client *ColoniesClient) GetLogsByProcess(colonyName string, processID string, count int, prvKey string) ([]*core.Log, error)

func (*ColoniesClient) GetLogsByProcessLatest added in v1.9.6 

func (client *ColoniesClient) GetLogsByProcessLatest(colonyName string, processID string, count int, prvKey string) ([]*core.Log, error)

GetLogsByProcessLatest returns the latest logs for a process (most recent count logs)

func (*ColoniesClient) GetLogsByProcessSince added in v1.7.7 

func (client *ColoniesClient) GetLogsByProcessSince(colonyName string, processID string, count int, since int64, prvKey string) ([]*core.Log, 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, colonyName string, seconds int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetProcessHistForExecutor added in v1.0.1 

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

func (*ColoniesClient) GetRunningProcessGraphs 

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

func (*ColoniesClient) GetRunningProcesses 

func (client *ColoniesClient) GetRunningProcesses(colonyName string, executorType string, label string, initiator string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetServerInfo added in v1.9.0 

func (client *ColoniesClient) GetServerInfo() (*core.ServerInfo, error)

func (*ColoniesClient) GetSnapshotByID added in v1.5.0 

func (client *ColoniesClient) GetSnapshotByID(colonyName string, snapshotID string, prvKey string) (*core.Snapshot, error)

func (*ColoniesClient) GetSnapshotByName added in v1.5.0 

func (client *ColoniesClient) GetSnapshotByName(colonyName string, name string, prvKey string) (*core.Snapshot, error)

func (*ColoniesClient) GetSnapshotsByColonyName added in v1.7.0 

func (client *ColoniesClient) GetSnapshotsByColonyName(colonyName string, prvKey string) ([]*core.Snapshot, error)

func (*ColoniesClient) GetSuccessfulProcessGraphs 

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

func (*ColoniesClient) GetSuccessfulProcesses 

func (client *ColoniesClient) GetSuccessfulProcesses(colonyName string, executorType string, label string, initiator string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) GetUser added in v1.7.0 

func (client *ColoniesClient) GetUser(colonyName string, username string, prvKey string) (*core.User, error)

func (*ColoniesClient) GetUserByID added in v1.9.3 

func (client *ColoniesClient) GetUserByID(colonyName string, userID string, prvKey string) (*core.User, error)

func (*ColoniesClient) GetUsers added in v1.7.0 

func (client *ColoniesClient) GetUsers(colonyName string, prvKey string) ([]*core.User, error)

func (*ColoniesClient) GetWaitingProcessGraphs 

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

func (*ColoniesClient) GetWaitingProcesses 

func (client *ColoniesClient) GetWaitingProcesses(colonyName string, executorType string, label string, initiator string, count int, prvKey string) ([]*core.Process, error)

func (*ColoniesClient) PackGenerator 

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

func (*ColoniesClient) PauseColonyAssignments added in v1.8.19 

func (client *ColoniesClient) PauseColonyAssignments(colonyName string, prvKey string) error

func (*ColoniesClient) ReconcileBlueprint added in v1.9.6 

func (client *ColoniesClient) ReconcileBlueprint(namespace, name string, force bool, prvKey string) (*core.Process, error)

ReconcileBlueprint triggers immediate reconciliation of a blueprint The server looks up the executor type from the blueprint's handler configuration If force is true, the generation will be bumped to trigger redeployment

func (*ColoniesClient) RejectExecutor added in v1.0.1 

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

func (*ColoniesClient) RemoveAllProcessGraphs added in v1.7.0 

func (client *ColoniesClient) RemoveAllProcessGraphs(colonyName string, prvKey string) error

func (*ColoniesClient) RemoveAllProcessGraphsWithState added in v1.7.0 

func (client *ColoniesClient) RemoveAllProcessGraphsWithState(colonyName string, state int, prvKey string) error

func (*ColoniesClient) RemoveAllProcesses added in v1.7.0 

func (client *ColoniesClient) RemoveAllProcesses(colonyName string, prvKey string) error

func (*ColoniesClient) RemoveAllProcessesWithState added in v1.7.0 

func (client *ColoniesClient) RemoveAllProcessesWithState(colonyName string, state int, prvKey string) error

func (*ColoniesClient) RemoveAllSnapshots added in v1.7.7 

func (client *ColoniesClient) RemoveAllSnapshots(colonyName string, prvKey string) error

func (*ColoniesClient) RemoveBlueprint added in v1.9.3 

func (client *ColoniesClient) RemoveBlueprint(namespace, name string, prvKey string) error

RemoveBlueprint removes a Blueprint by namespace and name

func (*ColoniesClient) RemoveBlueprintDefinition added in v1.9.3 

func (client *ColoniesClient) RemoveBlueprintDefinition(namespace, name string, prvKey string) error

RemoveBlueprintDefinition removes a BlueprintDefinition by namespace and name (requires colony owner privileges)

func (*ColoniesClient) RemoveColony added in v1.7.0 

func (client *ColoniesClient) RemoveColony(colonyName string, prvKey string) error

func (*ColoniesClient) RemoveCron added in v1.7.0 

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

func (*ColoniesClient) RemoveExecutor added in v1.7.0 

func (client *ColoniesClient) RemoveExecutor(colonyName string, executorName string, prvKey string) error

func (*ColoniesClient) RemoveFileByID added in v1.5.0 

func (client *ColoniesClient) RemoveFileByID(colonyName string, fileID string, prvKey string) error

func (*ColoniesClient) RemoveFileByName added in v1.5.0 

func (client *ColoniesClient) RemoveFileByName(colonyName string, label string, name string, prvKey string) error

func (*ColoniesClient) RemoveFunction added in v1.7.0 

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

func (*ColoniesClient) RemoveGenerator added in v1.7.0 

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

func (*ColoniesClient) RemoveLocation added in v1.9.6 

func (client *ColoniesClient) RemoveLocation(colonyName string, locationName string, prvKey string) error

func (*ColoniesClient) RemoveProcess added in v1.7.0 

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

func (*ColoniesClient) RemoveProcessGraph added in v1.7.0 

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

func (*ColoniesClient) RemoveSnapshotByID added in v1.7.0 

func (client *ColoniesClient) RemoveSnapshotByID(colonyName string, snapshotID string, prvKey string) error

func (*ColoniesClient) RemoveSnapshotByName added in v1.7.0 

func (client *ColoniesClient) RemoveSnapshotByName(colonyName string, name string, prvKey string) error

func (*ColoniesClient) RemoveUser added in v1.7.0 

func (client *ColoniesClient) RemoveUser(colonyName string, username string, prvKey string) error

func (*ColoniesClient) ReportAllocation added in v1.7.8 

func (client *ColoniesClient) ReportAllocation(colonyName string, executorName string, alloc core.Allocations, prvKey string) error

func (*ColoniesClient) ResolveGenerator 

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

func (*ColoniesClient) ResumeColonyAssignments added in v1.8.19 

func (client *ColoniesClient) ResumeColonyAssignments(colonyName string, prvKey string) error

func (*ColoniesClient) RunCron 

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

func (*ColoniesClient) SearchLogs added in v1.7.7 

func (client *ColoniesClient) SearchLogs(colonyName, text string, days int, count int, prvKey string) ([]*core.Log, error)

func (*ColoniesClient) SendRawMessage 

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

SendRawMessage sends a raw JSON message using the underlying backend

func (*ColoniesClient) SetOutput added in v1.4.0 

func (client *ColoniesClient) SetOutput(processID string, output []interface{}, prvKey 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(colonyName string, processID string, executorType string, state int, timeout int, prvKey string) (*ProcessSubscription, error)

func (*ColoniesClient) SubscribeProcesses 

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

func (*ColoniesClient) UpdateBlueprint added in v1.9.3 

func (client *ColoniesClient) UpdateBlueprint(blueprint *core.Blueprint, prvKey string) (*core.Blueprint, error)

UpdateBlueprint updates an existing Blueprint

func (*ColoniesClient) UpdateBlueprintStatus added in v1.9.6 

func (client *ColoniesClient) UpdateBlueprintStatus(colonyName, blueprintName string, status map[string]interface{}, prvKey string) error

UpdateBlueprintStatus updates only the status field of a blueprint This is used by reconcilers to report status without triggering a full update or generation bump

func (*ColoniesClient) UpdateBlueprintWithForce added in v1.9.6 

func (client *ColoniesClient) UpdateBlueprintWithForce(blueprint *core.Blueprint, forceGeneration bool, prvKey string) (*core.Blueprint, error)

UpdateBlueprintWithForce updates an existing Blueprint with optional force generation bump If forceGeneration is true, the generation will be incremented even if the spec hasn't changed

func (*ColoniesClient) UpdateExecutorCapabilities added in v1.9.6 

func (client *ColoniesClient) UpdateExecutorCapabilities(colonyName, executorName string, capabilities core.Capabilities, prvKey string) 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

Directories

Path Synopsis

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.