module

Documentation

Index

• type Client
  • func NewClient() *Client
• type WorkerIntentClient
  • func NewWorkerIntentClient() *WorkerIntentClient
  • func (v *WorkerIntentClient) CreateOrUpdateWorkerIntent(wi model.WorkerIntent, tac, project, cApp, cAppVer, dig string, exists bool) (model.WorkerIntent, error)
  • func (v WorkerIntentClient) DeleteWorkerIntents(project, cApp, cAppVer, dig, tac, workerName string) error
  • func (v WorkerIntentClient) GetWorkerIntent(workerName, project, cApp, cAppVer, dig, tac string) (model.WorkerIntent, error)
  • func (v WorkerIntentClient) GetWorkerIntents(project, cApp, cAppVer, dig, tac string) ([]model.WorkerIntent, error)
• type WorkerIntentManager
• type WorkflowIntentClient
  • func NewWorkflowIntentClient() *WorkflowIntentClient
  • func (v *WorkflowIntentClient) CancelWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, ...) error
  • func (v *WorkflowIntentClient) CreateWorkflowHookIntent(ctx context.Context, wfh model.WorkflowHookIntent, ...) (model.WorkflowHookIntent, error)
  • func (v *WorkflowIntentClient) DeleteWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) error
  • func (v *WorkflowIntentClient) GetSpecificHooks(ctx context.Context, project, cApp, cAppVer, dig, hook string) ([]model.WorkflowHookIntent, error)
  • func (v *WorkflowIntentClient) GetStatusWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, ...) (*wfMod.WfTemporalStatusResponse, error)
  • func (v *WorkflowIntentClient) GetWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) (model.WorkflowHookIntent, error)
  • func (v *WorkflowIntentClient) GetWorkflowHookIntents(ctx context.Context, project, cApp, cAppVer, dig string) ([]model.WorkflowHookIntent, error)
• type WorkflowIntentManager

Types

type Client

type Client struct {
	WorkflowIntentClient *WorkflowIntentClient
	WorkerIntentClient   *WorkerIntentClient
}

Client used to manage exposed client interfaces.

func NewClient

func NewClient() *Client

NewClient returns a new client instance

type WorkerIntentClient

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

WorkflowIntentClient implements the Manager It will also be used to maintain some localized state

func NewWorkerIntentClient

func NewWorkerIntentClient() *WorkerIntentClient

func (*WorkerIntentClient) CreateOrUpdateWorkerIntent

func (v *WorkerIntentClient) CreateOrUpdateWorkerIntent(wi model.WorkerIntent, tac, project, cApp, cAppVer, dig string, exists bool) (model.WorkerIntent, error)

func (WorkerIntentClient) DeleteWorkerIntents

func (v WorkerIntentClient) DeleteWorkerIntents(project, cApp, cAppVer, dig, tac, workerName string) error

func (WorkerIntentClient) GetWorkerIntent

func (v WorkerIntentClient) GetWorkerIntent(workerName, project, cApp, cAppVer, dig, tac string) (model.WorkerIntent, error)

func (WorkerIntentClient) GetWorkerIntents

func (v WorkerIntentClient) GetWorkerIntents(project, cApp, cAppVer, dig, tac string) ([]model.WorkerIntent, error)

type WorkerIntentManager

type WorkerIntentManager interface {
	// worker backend functions
	CreateOrUpdateWorkerIntent(wi model.WorkerIntent, tac, project, cApp, cAppVer, dig string, exists bool) (model.WorkerIntent, error)
	GetWorkerIntent(workerName, project, cApp, cAppVer, dig, tac string) (model.WorkerIntent, error)
	GetWorkerIntents(project, cApp, cAppVer, dig, tac string) ([]model.WorkerIntent, error)
	DeleteWorkerIntents(project, cApp, cAppVer, dig, tac, workerName string) error
}

type WorkflowIntentClient

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

WorkflowIntentClient implements the Manager It will also be used to maintain some localized state

func NewWorkflowIntentClient

func NewWorkflowIntentClient() *WorkflowIntentClient

func (*WorkflowIntentClient) CancelWorkflowIntent

func (v *WorkflowIntentClient) CancelWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, req *model.WfhTemporalCancelRequest) error

Cancel/terminate the Workflow

func (*WorkflowIntentClient) CreateWorkflowHookIntent

func (v *WorkflowIntentClient) CreateWorkflowHookIntent(ctx context.Context, wfh model.WorkflowHookIntent, project, cApp, cAppVer, dig string, exists bool) (model.WorkflowHookIntent, error)

CreateWorkflowHookIntent - create a new hook for a workflow intent

func (*WorkflowIntentClient) DeleteWorkflowHookIntent

func (v *WorkflowIntentClient) DeleteWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) error

DeleteWorkflowHookIntent - delete specific hook

func (*WorkflowIntentClient) GetSpecificHooks

func (v *WorkflowIntentClient) GetSpecificHooks(ctx context.Context, project, cApp, cAppVer, dig, hook string) ([]model.WorkflowHookIntent, error)

get all of the hooks of a specific kind (ie pre-install, post-install, pre-delete, etc.)

func (*WorkflowIntentClient) GetStatusWorkflowIntent

func (v *WorkflowIntentClient) GetStatusWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, query *wfMod.WfTemporalStatusQuery) (*wfMod.WfTemporalStatusResponse, error)

GetStatusWorkflowIntent performs different types of Temporal workflow status queries depending on the flags specified in the status API call.

func (*WorkflowIntentClient) GetWorkflowHookIntent

func (v *WorkflowIntentClient) GetWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) (model.WorkflowHookIntent, error)

GetWorkflowHookIntent - get specific hook

func (*WorkflowIntentClient) GetWorkflowHookIntents

func (v *WorkflowIntentClient) GetWorkflowHookIntents(ctx context.Context, project, cApp, cAppVer, dig string) ([]model.WorkflowHookIntent, error)

GetWorkflowHookIntents - get all current registered hooks

type WorkflowIntentManager

type WorkflowIntentManager interface {
	// LCM hook Routes
	CreateWorkflowHookIntent(ctx context.Context, wfh model.WorkflowHookIntent, project, cApp, cAppVer, dig string, exists bool) (model.WorkflowHookIntent, error)
	GetWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) (model.WorkflowHookIntent, error)
	GetWorkflowHookIntents(ctx context.Context, project, cApp, cAppVer, dig string) ([]model.WorkflowHookIntent, error)
	DeleteWorkflowHookIntent(ctx context.Context, name, project, cApp, cAppVer, dig string) error
	// monitor the status of workflows, and cancel workflows
	GetStatusWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, query *wfMod.WfTemporalStatusQuery) (*wfMod.WfTemporalStatusResponse, error)
	CancelWorkflowIntent(ctx context.Context, name, project, cApp, cAppVer, dig string, req *model.WfhTemporalCancelRequest) error
	// action controller helper functions
	GetSpecificHooks(ctx context.Context, project, cApp, cAppVer, dig, hook string) ([]model.WorkflowHookIntent, error)
}

Manager to expose the workflow intent functions