workflow

package
v1.16.3 Latest Latest
Warning

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

Go to latest
Published: Oct 31, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Purge

func Purge(ctx context.Context, opts PurgeOptions) error

func RaiseEvent

func RaiseEvent(ctx context.Context, opts RaiseEventOptions) error

func ReRun

func ReRun(ctx context.Context, opts ReRunOptions) (string, error)

func Resume

func Resume(ctx context.Context, opts ResumeOptions) error

func Run

func Run(ctx context.Context, opts RunOptions) (string, error)

func Suspend

func Suspend(ctx context.Context, opts SuspendOptions) error

func Terminate

func Terminate(ctx context.Context, opts TerminateOptions) error

Types

type DBOptions

type DBOptions struct {
	Namespace        string
	AppID            string
	Driver           string
	ConnectionString *string
	TableName        *string
}

type Filter

type Filter struct {
	Name     *string
	Status   *string
	MaxAge   *time.Time
	Terminal bool
}

type HistoryOptions

type HistoryOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
}

type HistoryOutputShort

type HistoryOutputShort struct {
	Type    string `csv:"TYPE"      json:"type"      yaml:"type"`
	Name    string `csv:"NAME"      json:"name"      yaml:"name"`
	EventID string `csv:"EVENTID,omitempty"      json:"eventId,omitempty"      yaml:"eventId,omitempty"`
	Elapsed string `csv:"ELAPSED" json:"elapsed" yaml:"elapsed"`
	Status  string `csv:"STATUS"    json:"status"    yaml:"status"`
	Details string `csv:"DETAILS"   json:"details"   yaml:"details"`
}

func HistoryShort

func HistoryShort(ctx context.Context, opts HistoryOptions) ([]*HistoryOutputShort, error)

type HistoryOutputWide

type HistoryOutputWide struct {
	Namespace   string    `csv:"-" json:"namespace,omitempty" yaml:"namespace,omitempty"`
	AppID       string    `csv:"-"    json:"appID"    yaml:"appID"`
	Play        int       `csv:"PLAY" json:"play" yaml:"play"`
	Type        string    `csv:"TYPE"      json:"type"      yaml:"type"`
	Name        *string   `csv:"NAME"      json:"name"      yaml:"name"`
	EventID     *int32    `csv:"EVENTID,omitempty"      json:"eventId,omitempty"      yaml:"eventId,omitempty"`
	Timestamp   time.Time `csv:"TIMESTAMP" json:"timestamp" yaml:"timestamp"`
	Elapsed     string    `csv:"ELAPSED" json:"elapsed" yaml:"elapsed"`
	Status      string    `csv:"STATUS"    json:"status"    yaml:"status"`
	Details     *string   `csv:"DETAILS"   json:"details"   yaml:"details"`
	Router      *string   `csv:"ROUTER,omitempty"       json:"router,omitempty"       yaml:"router,omitempty"`
	ExecutionID *string   `csv:"EXECUTION_ID,omitempty" json:"executionId,omitempty"  yaml:"executionId,omitempty"`

	Attrs *string `csv:"ATTRS,omitempty" json:"attrs,omitempty" yaml:"attrs,omitempty"`
}

func HistoryWide

func HistoryWide(ctx context.Context, opts HistoryOptions) ([]*HistoryOutputWide, error)

type ListOptions

type ListOptions struct {
	KubernetesMode   bool
	Namespace        string
	AppID            string
	ConnectionString *string
	TableName        *string
	Filter           Filter
}

type ListOutputShort

type ListOutputShort struct {
	Namespace     string `csv:"-" json:"namespace" yaml:"namespace"`
	AppID         string `csv:"-"    json:"appID"     yaml:"appID"`
	Name          string `csv:"NAME"    json:"name"     yaml:"name"`
	InstanceID    string `csv:"ID"    json:"instanceID"     yaml:"instanceID"`
	RuntimeStatus string `csv:"STATUS"    json:"runtimeStatus"     yaml:"runtimeStatus"`
	CustomStatus  string `csv:"CUSTOM STATUS"    json:"customStatus"     yaml:"customStatus"`
	Age           string `csv:"AGE"    json:"age"     yaml:"age"`
}

func ListShort

func ListShort(ctx context.Context, opts ListOptions) ([]*ListOutputShort, error)

type ListOutputWide

type ListOutputWide struct {
	Namespace      string    `csv:"NAMESPACE" json:"namespace" yaml:"namespace"`
	AppID          string    `csv:"APP ID"    json:"appID"     yaml:"appID"`
	Name           string    `csv:"Name"    json:"name"     yaml:"name"`
	InstanceID     string    `csv:"INSTANCE ID"    json:"instanceID"     yaml:"instanceID"`
	Created        time.Time `csv:"CREATED"    json:"created"     yaml:"created"`
	LastUpdate     time.Time `csv:"LAST UPDATE"    json:"lastUpdate"     yaml:"lastUpdate"`
	RuntimeStatus  string    `csv:"STATUS"    json:"runtimeStatus"     yaml:"runtimeStatus"`
	CustomStatus   string    `csv:"CUSTOM STATUS"    json:"customStatus"     yaml:"customStatus"`
	FailureMessage string    `csv:"FAILURE MESSAGE" json:"failureMessage"     yaml:"failureMessage"`
}

func ListWide

func ListWide(ctx context.Context, opts ListOptions) ([]*ListOutputWide, error)

type PurgeOptions

type PurgeOptions struct {
	KubernetesMode     bool
	Namespace          string
	SchedulerNamespace string
	AppID              string
	InstanceIDs        []string
	AllOlderThan       *time.Time
	All                bool

	ConnectionString *string
	TableName        *string
}

type RaiseEventOptions

type RaiseEventOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
	Name           string
	Input          *string
}

type ReRunOptions

type ReRunOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
	EventID        uint32
	NewInstanceID  *string
	Input          *string
}

type ResumeOptions

type ResumeOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
	Reason         string
}

type RunOptions

type RunOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	Name           string
	InstanceID     *string
	Input          *string
	StartTime      *time.Time
}

type SuspendOptions

type SuspendOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
	Reason         string
}

type TerminateOptions

type TerminateOptions struct {
	KubernetesMode bool
	Namespace      string
	AppID          string
	InstanceID     string
	Output         *string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL