model

package
v1.3.9 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Overview

* Orkes Conductor API Server * * Orkes Conductor API Server * * API version: v2 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* Orkes Conductor API Server * * Orkes Conductor API Server * * API version: v2 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* Orkes Conductor API Server * * Orkes Conductor API Server * * API version: v2 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

Index

Constants

This section is empty.

Variables

View Source 
var (
	WorkflowTerminalStates = []WorkflowStatus{
		CompletedWorkflow,
		FailedWorkflow,
		TimedOutWorkflow,
		TerminatedWorkflow,
	}
)

Functions

func ConvertToMap 

func ConvertToMap(input interface{}) (map[string]interface{}, error)

Types

type Action 

type Action struct {
	Action           string         `json:"action,omitempty"`
	StartWorkflow    *StartWorkflow `json:"start_workflow,omitempty"`
	CompleteTask     *TaskDetails   `json:"complete_task,omitempty"`
	FailTask         *TaskDetails   `json:"fail_task,omitempty"`
	ExpandInlineJSON bool           `json:"expandInlineJSON,omitempty"`
}

type BulkResponse 

type BulkResponse struct {
	BulkErrorResults      map[string]string `json:"bulkErrorResults,omitempty"`
	BulkSuccessfulResults []string          `json:"bulkSuccessfulResults,omitempty"`
}

type CacheConfig added in v1.3.9 

type CacheConfig struct {
	Key          string `json:"key,omitempty"`
	TtlInSeconds int    `json:"ttlInSecond,omitempty"`
}

type EventHandler 

type EventHandler struct {
	Name          string   `json:"name"`
	Event         string   `json:"event"`
	Condition     string   `json:"condition,omitempty"`
	Actions       []Action `json:"actions"`
	Active        bool     `json:"active,omitempty"`
	EvaluatorType string   `json:"evaluatorType,omitempty"`
}

type ExecuteTaskFunction 

type ExecuteTaskFunction func(t *Task) (interface{}, error)

type ExternalStorageHandler 

type ExternalStorageHandler func(data map[string]interface{}) (string, error)

type ExternalStorageLocation 

type ExternalStorageLocation struct {
	Uri  string `json:"uri,omitempty"`
	Path string `json:"path,omitempty"`
}

type Health 

type Health struct {
	Details      map[string]interface{} `json:"details,omitempty"`
	ErrorMessage string                 `json:"errorMessage,omitempty"`
	Healthy      bool                   `json:"healthy,omitempty"`
}

type HealthCheckStatus 

type HealthCheckStatus struct {
	HealthResults           []Health `json:"healthResults,omitempty"`
	SuppressedHealthResults []Health `json:"suppressedHealthResults,omitempty"`
	Healthy                 bool     `json:"healthy,omitempty"`
}

type IdempotencyStrategy added in v1.3.8 

type IdempotencyStrategy string
const (
	FailOnConflict IdempotencyStrategy = "FAIL"
	ReturnExisting IdempotencyStrategy = "RETURN_EXISTING"
)

type MetadataTag added in v1.3.5 

type MetadataTag struct {
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type NonRetryableError added in v1.2.21 

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

func NewNonRetryableError added in v1.2.21 

func NewNonRetryableError(err error) *NonRetryableError

func (*NonRetryableError) Error added in v1.2.21 

func (e *NonRetryableError) Error() string

type PollData 

type PollData struct {
	QueueName    string `json:"queueName,omitempty"`
	Domain       string `json:"domain,omitempty"`
	WorkerId     string `json:"workerId,omitempty"`
	LastPollTime int64  `json:"lastPollTime,omitempty"`
}

type RerunWorkflowRequest 

type RerunWorkflowRequest struct {
	ReRunFromWorkflowId string                 `json:"reRunFromWorkflowId,omitempty"`
	WorkflowInput       map[string]interface{} `json:"workflowInput,omitempty"`
	ReRunFromTaskId     string                 `json:"reRunFromTaskId,omitempty"`
	TaskInput           map[string]interface{} `json:"taskInput,omitempty"`
	CorrelationId       string                 `json:"correlationId,omitempty"`
}

type SaveScheduleRequest added in v1.3.2 

type SaveScheduleRequest struct {
	CreatedBy                   string                `json:"createdBy,omitempty"`
	CronExpression              string                `json:"cronExpression"`
	Name                        string                `json:"name"`
	Paused                      bool                  `json:"paused,omitempty"`
	RunCatchupScheduleInstances bool                  `json:"runCatchupScheduleInstances,omitempty"`
	ScheduleEndTime             int64                 `json:"scheduleEndTime,omitempty"`
	ScheduleStartTime           int64                 `json:"scheduleStartTime,omitempty"`
	StartWorkflowRequest        *StartWorkflowRequest `json:"startWorkflowRequest"`
	UpdatedBy                   string                `json:"updatedBy,omitempty"`
}

type SearchResultTask 

type SearchResultTask struct {
	TotalHits int64  `json:"totalHits,omitempty"`
	Results   []Task `json:"results,omitempty"`
}

type SearchResultTaskSummary 

type SearchResultTaskSummary struct {
	TotalHits int64         `json:"totalHits,omitempty"`
	Results   []TaskSummary `json:"results,omitempty"`
}

type SearchResultWorkflow 

type SearchResultWorkflow struct {
	TotalHits int64      `json:"totalHits,omitempty"`
	Results   []Workflow `json:"results,omitempty"`
}

type SearchResultWorkflowSchedule added in v1.3.2 

type SearchResultWorkflowSchedule struct {
	Results   []WorkflowScheduleExecution `json:"results,omitempty"`
	TotalHits int64                       `json:"totalHits,omitempty"`
}

type SearchResultWorkflowSummary 

type SearchResultWorkflowSummary struct {
	TotalHits int64             `json:"totalHits,omitempty"`
	Results   []WorkflowSummary `json:"results,omitempty"`
}

type SkipTaskRequest 

type SkipTaskRequest struct {
	TaskInput  map[string]interface{} `json:"taskInput,omitempty"`
	TaskOutput map[string]interface{} `json:"taskOutput,omitempty"`
}

type StartWorkflow 

type StartWorkflow struct {
	Name          string                 `json:"name,omitempty"`
	Version       int32                  `json:"version,omitempty"`
	CorrelationId string                 `json:"correlationId,omitempty"`
	Input         map[string]interface{} `json:"input,omitempty"`
	TaskToDomain  map[string]string      `json:"taskToDomain,omitempty"`
}

type StartWorkflowRequest 

type StartWorkflowRequest struct {
	Name                            string              `json:"name"`
	Version                         int32               `json:"version,omitempty"`
	CorrelationId                   string              `json:"correlationId,omitempty"`
	Input                           interface{}         `json:"input,omitempty"`
	TaskToDomain                    map[string]string   `json:"taskToDomain,omitempty"`
	WorkflowDef                     *WorkflowDef        `json:"workflowDef,omitempty"`
	ExternalInputPayloadStoragePath string              `json:"externalInputPayloadStoragePath,omitempty"`
	Priority                        int32               `json:"priority,omitempty"`
	IdempotencyKey                  string              `json:"idempotencyKey,omitempty"`
	IdempotencyStrategy             IdempotencyStrategy `json:"idempotencyStrategy,omitempty"`
}

func NewIdempotentStartWorkflowRequest added in v1.3.8 

func NewIdempotentStartWorkflowRequest(name string, version int32, correlationId string,
	idempotencyKey string, idempotencyStrategy IdempotencyStrategy, input interface{}) *StartWorkflowRequest

func NewStartWorkflowRequest 

func NewStartWorkflowRequest(name string, version int32, correlationId string, input interface{}) *StartWorkflowRequest

func NewStartWorkflowRequestLegacy added in v1.2.22 

func NewStartWorkflowRequestLegacy(name string, version int32, correlationId string, input interface{}) *StartWorkflowRequest

type StateChangeEvent added in v1.3.5 

type StateChangeEvent struct {
	Payload map[string]interface{} `json:"payload,omitempty"`
	Type_   string                 `json:"type"`
}

type SubWorkflowParams 

type SubWorkflowParams struct {
	Name               string            `json:"name"`
	Version            int32             `json:"version,omitempty"`
	TaskToDomain       map[string]string `json:"taskToDomain,omitempty"`
	WorkflowDefinition *WorkflowDef      `json:"workflowDefinition,omitempty"`
}

type Tag added in v1.3.2 

type Tag struct {
	Key   string       `json:"key,omitempty"`
	Type_ string       `json:"type,omitempty"`
	Value *interface{} `json:"value,omitempty"`
}

type TagObject added in v1.3.5 

type TagObject struct {
	Key   string       `json:"key,omitempty"`
	Type_ string       `json:"type,omitempty"`
	Value *interface{} `json:"value,omitempty"`
}

func NewTagObject added in v1.3.5 

func NewTagObject(metadataTag MetadataTag) TagObject

type TagString added in v1.3.5 

type TagString struct {
	Key   string `json:"key,omitempty"`
	Type_ string `json:"type,omitempty"`
	Value string `json:"value,omitempty"`
}

type Task 

type Task struct {
	TaskType                         string                 `json:"taskType,omitempty"`
	Status                           TaskResultStatus       `json:"status,omitempty"`
	InputData                        map[string]interface{} `json:"inputData,omitempty"`
	ReferenceTaskName                string                 `json:"referenceTaskName,omitempty"`
	RetryCount                       int32                  `json:"retryCount,omitempty"`
	Seq                              int32                  `json:"seq,omitempty"`
	CorrelationId                    string                 `json:"correlationId,omitempty"`
	PollCount                        int32                  `json:"pollCount,omitempty"`
	TaskDefName                      string                 `json:"taskDefName,omitempty"`
	ScheduledTime                    int64                  `json:"scheduledTime,omitempty"`
	StartTime                        int64                  `json:"startTime,omitempty"`
	EndTime                          int64                  `json:"endTime,omitempty"`
	UpdateTime                       int64                  `json:"updateTime,omitempty"`
	StartDelayInSeconds              int32                  `json:"startDelayInSeconds,omitempty"`
	RetriedTaskId                    string                 `json:"retriedTaskId,omitempty"`
	Retried                          bool                   `json:"retried,omitempty"`
	Executed                         bool                   `json:"executed,omitempty"`
	CallbackFromWorker               bool                   `json:"callbackFromWorker,omitempty"`
	ResponseTimeoutSeconds           int64                  `json:"responseTimeoutSeconds,omitempty"`
	WorkflowInstanceId               string                 `json:"workflowInstanceId,omitempty"`
	WorkflowType                     string                 `json:"workflowType,omitempty"`
	TaskId                           string                 `json:"taskId,omitempty"`
	ReasonForIncompletion            string                 `json:"reasonForIncompletion,omitempty"`
	CallbackAfterSeconds             int64                  `json:"callbackAfterSeconds,omitempty"`
	WorkerId                         string                 `json:"workerId,omitempty"`
	OutputData                       map[string]interface{} `json:"outputData,omitempty"`
	WorkflowTask                     *WorkflowTask          `json:"workflowTask,omitempty"`
	Domain                           string                 `json:"domain,omitempty"`
	RateLimitPerFrequency            int32                  `json:"rateLimitPerFrequency,omitempty"`
	RateLimitFrequencyInSeconds      int32                  `json:"rateLimitFrequencyInSeconds,omitempty"`
	ExternalInputPayloadStoragePath  string                 `json:"externalInputPayloadStoragePath,omitempty"`
	ExternalOutputPayloadStoragePath string                 `json:"externalOutputPayloadStoragePath,omitempty"`
	WorkflowPriority                 int32                  `json:"workflowPriority,omitempty"`
	ExecutionNameSpace               string                 `json:"executionNameSpace,omitempty"`
	IsolationGroupId                 string                 `json:"isolationGroupId,omitempty"`
	Iteration                        int32                  `json:"iteration,omitempty"`
	SubWorkflowId                    string                 `json:"subWorkflowId,omitempty"`
	SubworkflowChanged               bool                   `json:"subworkflowChanged,omitempty"`
	QueueWaitTime                    int64                  `json:"queueWaitTime,omitempty"`
	TaskDefinition                   *TaskDef               `json:"taskDefinition,omitempty"`
	LoopOverTask                     bool                   `json:"loopOverTask,omitempty"`
}

type TaskDef 

type TaskDef struct {
	OwnerApp                    string                 `json:"ownerApp,omitempty"`
	CreateTime                  int64                  `json:"createTime,omitempty"`
	UpdateTime                  int64                  `json:"updateTime,omitempty"`
	CreatedBy                   string                 `json:"createdBy,omitempty"`
	UpdatedBy                   string                 `json:"updatedBy,omitempty"`
	Name                        string                 `json:"name"`
	Description                 string                 `json:"description,omitempty"`
	RetryCount                  int32                  `json:"retryCount"`
	TimeoutSeconds              int64                  `json:"timeoutSeconds"`
	InputKeys                   []string               `json:"inputKeys,omitempty"`
	OutputKeys                  []string               `json:"outputKeys,omitempty"`
	TimeoutPolicy               string                 `json:"timeoutPolicy,omitempty"`
	RetryLogic                  string                 `json:"retryLogic,omitempty"`
	RetryDelaySeconds           int32                  `json:"retryDelaySeconds,omitempty"`
	ResponseTimeoutSeconds      int64                  `json:"responseTimeoutSeconds,omitempty"`
	ConcurrentExecLimit         int32                  `json:"concurrentExecLimit,omitempty"`
	InputTemplate               map[string]interface{} `json:"inputTemplate,omitempty"`
	RateLimitPerFrequency       int32                  `json:"rateLimitPerFrequency,omitempty"`
	RateLimitFrequencyInSeconds int32                  `json:"rateLimitFrequencyInSeconds,omitempty"`
	IsolationGroupId            string                 `json:"isolationGroupId,omitempty"`
	ExecutionNameSpace          string                 `json:"executionNameSpace,omitempty"`
	OwnerEmail                  string                 `json:"ownerEmail,omitempty"`
	PollTimeoutSeconds          int32                  `json:"pollTimeoutSeconds,omitempty"`
	BackoffScaleFactor          int32                  `json:"backoffScaleFactor,omitempty"`
	Tags                        []TagObject            `json:"tags,omitempty"`
	OverwriteTags               bool                   `json:"overwriteTags"`
}

type TaskDetails 

type TaskDetails struct {
	WorkflowId  string                 `json:"workflowId,omitempty"`
	TaskRefName string                 `json:"taskRefName,omitempty"`
	Output      map[string]interface{} `json:"output,omitempty"`
	TaskId      string                 `json:"taskId,omitempty"`
}

type TaskExecLog 

type TaskExecLog struct {
	Log         string `json:"log,omitempty"`
	TaskId      string `json:"taskId,omitempty"`
	CreatedTime int64  `json:"createdTime,omitempty"`
}

type TaskResult 

type TaskResult struct {
	WorkflowInstanceId               string                 `json:"workflowInstanceId"`
	TaskId                           string                 `json:"taskId"`
	ReasonForIncompletion            string                 `json:"reasonForIncompletion,omitempty"`
	CallbackAfterSeconds             int64                  `json:"callbackAfterSeconds,omitempty"`
	WorkerId                         string                 `json:"workerId,omitempty"`
	Status                           TaskResultStatus       `json:"status,omitempty"`
	OutputData                       map[string]interface{} `json:"outputData,omitempty"`
	Logs                             []TaskExecLog          `json:"logs,omitempty"`
	ExternalOutputPayloadStoragePath string                 `json:"externalOutputPayloadStoragePath,omitempty"`
	SubWorkflowId                    string                 `json:"subWorkflowId,omitempty"`
}

func GetTaskResultFromTaskExecutionOutput 

func GetTaskResultFromTaskExecutionOutput(t *Task, taskExecutionOutput interface{}) (*TaskResult, error)

func NewTaskResult 

func NewTaskResult(taskId string, workflowInstanceId string) *TaskResult

func NewTaskResultFromTask 

func NewTaskResultFromTask(task *Task) *TaskResult

func NewTaskResultFromTaskWithError 

func NewTaskResultFromTaskWithError(t *Task, err error) *TaskResult

type TaskResultStatus 

type TaskResultStatus string
const (
	InProgressTask              TaskResultStatus = "IN_PROGRESS"
	FailedTask                  TaskResultStatus = "FAILED"
	FailedWithTerminalErrorTask TaskResultStatus = "FAILED_WITH_TERMINAL_ERROR"
	CompletedTask               TaskResultStatus = "COMPLETED"
)

type TaskSummary 

type TaskSummary struct {
	WorkflowId                       string `json:"workflowId,omitempty"`
	WorkflowType                     string `json:"workflowType,omitempty"`
	CorrelationId                    string `json:"correlationId,omitempty"`
	ScheduledTime                    string `json:"scheduledTime,omitempty"`
	StartTime                        string `json:"startTime,omitempty"`
	UpdateTime                       string `json:"updateTime,omitempty"`
	EndTime                          string `json:"endTime,omitempty"`
	Status                           string `json:"status,omitempty"`
	ReasonForIncompletion            string `json:"reasonForIncompletion,omitempty"`
	ExecutionTime                    int64  `json:"executionTime,omitempty"`
	QueueWaitTime                    int64  `json:"queueWaitTime,omitempty"`
	TaskDefName                      string `json:"taskDefName,omitempty"`
	TaskType                         string `json:"taskType,omitempty"`
	Input                            string `json:"input,omitempty"`
	Output                           string `json:"output,omitempty"`
	TaskId                           string `json:"taskId,omitempty"`
	ExternalInputPayloadStoragePath  string `json:"externalInputPayloadStoragePath,omitempty"`
	ExternalOutputPayloadStoragePath string `json:"externalOutputPayloadStoragePath,omitempty"`
	WorkflowPriority                 int32  `json:"workflowPriority,omitempty"`
}

type Token 

type Token struct {
	Token string `json:"token"`
}

type ValidateWorkflowFunction 

type ValidateWorkflowFunction func(w *Workflow) (bool, error)

type Workflow 

type Workflow struct {
	OwnerApp                         string                 `json:"ownerApp,omitempty"`
	CreateTime                       int64                  `json:"createTime,omitempty"`
	UpdateTime                       int64                  `json:"updateTime,omitempty"`
	CreatedBy                        string                 `json:"createdBy,omitempty"`
	UpdatedBy                        string                 `json:"updatedBy,omitempty"`
	Status                           WorkflowStatus         `json:"status,omitempty"`
	EndTime                          int64                  `json:"endTime,omitempty"`
	WorkflowId                       string                 `json:"workflowId,omitempty"`
	ParentWorkflowId                 string                 `json:"parentWorkflowId,omitempty"`
	ParentWorkflowTaskId             string                 `json:"parentWorkflowTaskId,omitempty"`
	Tasks                            []Task                 `json:"tasks,omitempty"`
	Input                            map[string]interface{} `json:"input,omitempty"`
	Output                           map[string]interface{} `json:"output,omitempty"`
	CorrelationId                    string                 `json:"correlationId,omitempty"`
	ReRunFromWorkflowId              string                 `json:"reRunFromWorkflowId,omitempty"`
	ReasonForIncompletion            string                 `json:"reasonForIncompletion,omitempty"`
	Event                            string                 `json:"event,omitempty"`
	TaskToDomain                     map[string]string      `json:"taskToDomain,omitempty"`
	FailedReferenceTaskNames         []string               `json:"failedReferenceTaskNames,omitempty"`
	WorkflowDefinition               *WorkflowDef           `json:"workflowDefinition,omitempty"`
	ExternalInputPayloadStoragePath  string                 `json:"externalInputPayloadStoragePath,omitempty"`
	ExternalOutputPayloadStoragePath string                 `json:"externalOutputPayloadStoragePath,omitempty"`
	Priority                         int32                  `json:"priority,omitempty"`
	Variables                        map[string]interface{} `json:"variables,omitempty"`
	LastRetriedTime                  int64                  `json:"lastRetriedTime,omitempty"`
	StartTime                        int64                  `json:"startTime,omitempty"`
	WorkflowName                     string                 `json:"workflowName,omitempty"`
	WorkflowVersion                  int32                  `json:"workflowVersion,omitempty"`
}

type WorkflowDef 

type WorkflowDef struct {
	OwnerApp                      string                 `json:"ownerApp,omitempty"`
	CreateTime                    int64                  `json:"createTime,omitempty"`
	UpdateTime                    int64                  `json:"updateTime,omitempty"`
	CreatedBy                     string                 `json:"createdBy,omitempty"`
	UpdatedBy                     string                 `json:"updatedBy,omitempty"`
	Name                          string                 `json:"name"`
	Description                   string                 `json:"description,omitempty"`
	Version                       int32                  `json:"version,omitempty"`
	Tasks                         []WorkflowTask         `json:"tasks"`
	InputParameters               []string               `json:"inputParameters,omitempty"`
	OutputParameters              map[string]interface{} `json:"outputParameters,omitempty"`
	FailureWorkflow               string                 `json:"failureWorkflow,omitempty"`
	SchemaVersion                 int32                  `json:"schemaVersion,omitempty"`
	Restartable                   bool                   `json:"restartable,omitempty"`
	WorkflowStatusListenerEnabled bool                   `json:"workflowStatusListenerEnabled,omitempty"`
	OwnerEmail                    string                 `json:"ownerEmail,omitempty"`
	TimeoutPolicy                 string                 `json:"timeoutPolicy,omitempty"`
	TimeoutSeconds                int64                  `json:"timeoutSeconds"`
	Variables                     map[string]interface{} `json:"variables,omitempty"`
	InputTemplate                 map[string]interface{} `json:"inputTemplate,omitempty"`
	Tags                          []TagObject            `json:"tags,omitempty"`
	OverwriteTags                 bool                   `json:"overwriteTags"`
}

type WorkflowRun added in v1.2.15 

type WorkflowRun struct {
	CorrelationId string                 `json:"correlationId,omitempty"`
	CreateTime    int64                  `json:"createTime,omitempty"`
	CreatedBy     string                 `json:"createdBy,omitempty"`
	Input         map[string]interface{} `json:"input,omitempty"`
	Output        map[string]interface{} `json:"output,omitempty"`
	Priority      int32                  `json:"priority,omitempty"`
	RequestId     string                 `json:"requestId,omitempty"`
	Status        string                 `json:"status,omitempty"`
	Tasks         []Task                 `json:"tasks,omitempty"`
	UpdateTime    int64                  `json:"updateTime,omitempty"`
	Variables     map[string]interface{} `json:"variables,omitempty"`
	WorkflowId    string                 `json:"workflowId,omitempty"`
}

type WorkflowSchedule added in v1.3.2 

type WorkflowSchedule struct {
	CreateTime                  int64                 `json:"createTime,omitempty"`
	CreatedBy                   string                `json:"createdBy,omitempty"`
	CronExpression              string                `json:"cronExpression,omitempty"`
	Name                        string                `json:"name,omitempty"`
	Paused                      bool                  `json:"paused,omitempty"`
	PausedReason                string                `json:"pausedReason,omitempty"`
	RunCatchupScheduleInstances bool                  `json:"runCatchupScheduleInstances,omitempty"`
	ScheduleEndTime             int64                 `json:"scheduleEndTime,omitempty"`
	ScheduleStartTime           int64                 `json:"scheduleStartTime,omitempty"`
	StartWorkflowRequest        *StartWorkflowRequest `json:"startWorkflowRequest,omitempty"`
	Tags                        []Tag                 `json:"tags,omitempty"`
	UpdatedBy                   string                `json:"updatedBy,omitempty"`
	UpdatedTime                 int64                 `json:"updatedTime,omitempty"`
}

type WorkflowScheduleExecution added in v1.3.2 

type WorkflowScheduleExecution struct {
	ExecutionId          string                `json:"executionId,omitempty"`
	ExecutionTime        int64                 `json:"executionTime,omitempty"`
	Reason               string                `json:"reason,omitempty"`
	ScheduleName         string                `json:"scheduleName,omitempty"`
	ScheduledTime        int64                 `json:"scheduledTime,omitempty"`
	StackTrace           string                `json:"stackTrace,omitempty"`
	StartWorkflowRequest *StartWorkflowRequest `json:"startWorkflowRequest,omitempty"`
	State                string                `json:"state,omitempty"`
	WorkflowId           string                `json:"workflowId,omitempty"`
	WorkflowName         string                `json:"workflowName,omitempty"`
}

type WorkflowState 

type WorkflowState struct {
	WorkflowId    string                 `json:"workflowId,omitempty"`
	Output        map[string]interface{} `json:"output,omitempty"`
	CorrelationId string                 `json:"correlationId,omitempty"`
	Variables     map[string]interface{} `json:"variables,omitempty"`
	Status        string                 `json:"status,omitempty"`
}

type WorkflowStatus 

type WorkflowStatus string
const (
	RunningWorkflow    WorkflowStatus = "RUNNING"
	CompletedWorkflow  WorkflowStatus = "COMPLETED"
	FailedWorkflow     WorkflowStatus = "FAILED"
	TimedOutWorkflow   WorkflowStatus = "TIMED_OUT"
	TerminatedWorkflow WorkflowStatus = "TERMINATED"
	PausedWorkflow     WorkflowStatus = "PAUSED"
)

type WorkflowSummary 

type WorkflowSummary struct {
	WorkflowType                     string `json:"workflowType,omitempty"`
	Version                          int32  `json:"version,omitempty"`
	WorkflowId                       string `json:"workflowId,omitempty"`
	CorrelationId                    string `json:"correlationId,omitempty"`
	StartTime                        string `json:"startTime,omitempty"`
	UpdateTime                       string `json:"updateTime,omitempty"`
	EndTime                          string `json:"endTime,omitempty"`
	Status                           string `json:"status,omitempty"`
	Input                            string `json:"input,omitempty"`
	Output                           string `json:"output,omitempty"`
	ReasonForIncompletion            string `json:"reasonForIncompletion,omitempty"`
	ExecutionTime                    int64  `json:"executionTime,omitempty"`
	Event                            string `json:"event,omitempty"`
	FailedReferenceTaskNames         string `json:"failedReferenceTaskNames,omitempty"`
	ExternalInputPayloadStoragePath  string `json:"externalInputPayloadStoragePath,omitempty"`
	ExternalOutputPayloadStoragePath string `json:"externalOutputPayloadStoragePath,omitempty"`
	Priority                         int32  `json:"priority,omitempty"`
	OutputSize                       int64  `json:"outputSize,omitempty"`
	InputSize                        int64  `json:"inputSize,omitempty"`
}

type WorkflowTask 

type WorkflowTask struct {
	Name                           string                    `json:"name"`
	TaskReferenceName              string                    `json:"taskReferenceName"`
	Description                    string                    `json:"description,omitempty"`
	InputParameters                map[string]interface{}    `json:"inputParameters,omitempty"`
	Type_                          string                    `json:"type,omitempty"`
	DynamicTaskNameParam           string                    `json:"dynamicTaskNameParam,omitempty"`
	CaseValueParam                 string                    `json:"caseValueParam,omitempty"`
	CaseExpression                 string                    `json:"caseExpression,omitempty"`
	ScriptExpression               string                    `json:"scriptExpression,omitempty"`
	DecisionCases                  map[string][]WorkflowTask `json:"decisionCases,omitempty"`
	DynamicForkJoinTasksParam      string                    `json:"dynamicForkJoinTasksParam,omitempty"`
	DynamicForkTasksParam          string                    `json:"dynamicForkTasksParam,omitempty"`
	DynamicForkTasksInputParamName string                    `json:"dynamicForkTasksInputParamName,omitempty"`
	DefaultCase                    []WorkflowTask            `json:"defaultCase,omitempty"`
	ForkTasks                      [][]WorkflowTask          `json:"forkTasks,omitempty"`
	StartDelay                     int32                     `json:"startDelay,omitempty"`
	SubWorkflowParam               *SubWorkflowParams        `json:"subWorkflowParam,omitempty"`
	JoinOn                         []string                  `json:"joinOn,omitempty"`
	Sink                           string                    `json:"sink,omitempty"`
	Optional                       bool                      `json:"optional,omitempty"`
	TaskDefinition                 *TaskDef                  `json:"taskDefinition,omitempty"`
	RateLimited                    bool                      `json:"rateLimited,omitempty"`
	DefaultExclusiveJoinTask       []string                  `json:"defaultExclusiveJoinTask,omitempty"`
	AsyncComplete                  bool                      `json:"asyncComplete,omitempty"`
	LoopCondition                  string                    `json:"loopCondition,omitempty"`
	LoopOver                       []WorkflowTask            `json:"loopOver,omitempty"`
	RetryCount                     int32                     `json:"retryCount,omitempty"`
	EvaluatorType                  string                    `json:"evaluatorType,omitempty"`
	Expression                     string                    `json:"expression,omitempty"`
	WorkflowTaskType               string                    `json:"workflowTaskType,omitempty"`
	CacheConfig                    *CacheConfig              `json:"cacheConfig,omitempty"`
}

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.