model

package
v3.0.0-...-523606e Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventExecution_Status_name = map[int32]string{
	0: "IN_PROGRESS",
	1: "COMPLETED",
	2: "FAILED",
	3: "SKIPPED",
}
View Source 
var EventExecution_Status_value = map[string]int32{
	"IN_PROGRESS": 0,
	"COMPLETED":   1,
	"FAILED":      2,
	"SKIPPED":     3,
}
View Source 
var EventHandler_Action_Type_name = map[int32]string{
	0: "START_WORKFLOW",
	1: "COMPLETE_TASK",
	2: "FAIL_TASK",
}
View Source 
var EventHandler_Action_Type_value = map[string]int32{
	"START_WORKFLOW": 0,
	"COMPLETE_TASK":  1,
	"FAIL_TASK":      2,
}
View Source 
var TaskDef_RetryLogic_name = map[int32]string{
	0: "FIXED",
	1: "EXPONENTIAL_BACKOFF",
}
View Source 
var TaskDef_RetryLogic_value = map[string]int32{
	"FIXED":               0,
	"EXPONENTIAL_BACKOFF": 1,
}
View Source 
var TaskDef_TimeoutPolicy_name = map[int32]string{
	0: "RETRY",
	1: "TIME_OUT_WF",
	2: "ALERT_ONLY",
}
View Source 
var TaskDef_TimeoutPolicy_value = map[string]int32{
	"RETRY":       0,
	"TIME_OUT_WF": 1,
	"ALERT_ONLY":  2,
}
View Source 
var TaskResult_Status_name = map[int32]string{
	0: "IN_PROGRESS",
	1: "FAILED",
	2: "FAILED_WITH_TERMINAL_ERROR",
	3: "COMPLETED",
}
View Source 
var TaskResult_Status_value = map[string]int32{
	"IN_PROGRESS":                0,
	"FAILED":                     1,
	"FAILED_WITH_TERMINAL_ERROR": 2,
	"COMPLETED":                  3,
}
View Source 
var Task_Status_name = map[int32]string{
	0: "IN_PROGRESS",
	1: "CANCELED",
	2: "FAILED",
	3: "FAILED_WITH_TERMINAL_ERROR",
	4: "COMPLETED",
	5: "COMPLETED_WITH_ERRORS",
	6: "SCHEDULED",
	7: "TIMED_OUT",
	8: "SKIPPED",
}
View Source 
var Task_Status_value = map[string]int32{
	"IN_PROGRESS":                0,
	"CANCELED":                   1,
	"FAILED":                     2,
	"FAILED_WITH_TERMINAL_ERROR": 3,
	"COMPLETED":                  4,
	"COMPLETED_WITH_ERRORS":      5,
	"SCHEDULED":                  6,
	"TIMED_OUT":                  7,
	"SKIPPED":                    8,
}
View Source 
var Workflow_WorkflowStatus_name = map[int32]string{
	0: "RUNNING",
	1: "COMPLETED",
	2: "FAILED",
	3: "TIMED_OUT",
	4: "TERMINATED",
	5: "PAUSED",
}
View Source 
var Workflow_WorkflowStatus_value = map[string]int32{
	"RUNNING":    0,
	"COMPLETED":  1,
	"FAILED":     2,
	"TIMED_OUT":  3,
	"TERMINATED": 4,
	"PAUSED":     5,
}

Functions

This section is empty.

Types

type DynamicForkJoinTask 

type DynamicForkJoinTask struct {
	TaskName             string              `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	WorkflowName         string              `protobuf:"bytes,2,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	ReferenceName        string              `protobuf:"bytes,3,opt,name=reference_name,json=referenceName,proto3" json:"reference_name,omitempty"`
	Input                map[string]*any.Any `` /* 151-byte string literal not displayed */
	Type                 string              `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DynamicForkJoinTask) Descriptor 

func (*DynamicForkJoinTask) Descriptor() ([]byte, []int)

func (*DynamicForkJoinTask) GetInput 

func (m *DynamicForkJoinTask) GetInput() map[string]*any.Any

func (*DynamicForkJoinTask) GetReferenceName 

func (m *DynamicForkJoinTask) GetReferenceName() string

func (*DynamicForkJoinTask) GetTaskName 

func (m *DynamicForkJoinTask) GetTaskName() string

func (*DynamicForkJoinTask) GetType 

func (m *DynamicForkJoinTask) GetType() string

func (*DynamicForkJoinTask) GetWorkflowName 

func (m *DynamicForkJoinTask) GetWorkflowName() string

func (*DynamicForkJoinTask) ProtoMessage 

func (*DynamicForkJoinTask) ProtoMessage()

func (*DynamicForkJoinTask) Reset 

func (m *DynamicForkJoinTask) Reset()

func (*DynamicForkJoinTask) String 

func (m *DynamicForkJoinTask) String() string

func (*DynamicForkJoinTask) XXX_DiscardUnknown 

func (m *DynamicForkJoinTask) XXX_DiscardUnknown()

func (*DynamicForkJoinTask) XXX_Marshal 

func (m *DynamicForkJoinTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicForkJoinTask) XXX_Merge 

func (dst *DynamicForkJoinTask) XXX_Merge(src proto.Message)

func (*DynamicForkJoinTask) XXX_Size 

func (m *DynamicForkJoinTask) XXX_Size() int

func (*DynamicForkJoinTask) XXX_Unmarshal 

func (m *DynamicForkJoinTask) XXX_Unmarshal(b []byte) error

type DynamicForkJoinTaskList 

type DynamicForkJoinTaskList struct {
	DynamicTasks         []*DynamicForkJoinTask `protobuf:"bytes,1,rep,name=dynamic_tasks,json=dynamicTasks,proto3" json:"dynamic_tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DynamicForkJoinTaskList) Descriptor 

func (*DynamicForkJoinTaskList) Descriptor() ([]byte, []int)

func (*DynamicForkJoinTaskList) GetDynamicTasks 

func (m *DynamicForkJoinTaskList) GetDynamicTasks() []*DynamicForkJoinTask

func (*DynamicForkJoinTaskList) ProtoMessage 

func (*DynamicForkJoinTaskList) ProtoMessage()

func (*DynamicForkJoinTaskList) Reset 

func (m *DynamicForkJoinTaskList) Reset()

func (*DynamicForkJoinTaskList) String 

func (m *DynamicForkJoinTaskList) String() string

func (*DynamicForkJoinTaskList) XXX_DiscardUnknown 

func (m *DynamicForkJoinTaskList) XXX_DiscardUnknown()

func (*DynamicForkJoinTaskList) XXX_Marshal 

func (m *DynamicForkJoinTaskList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicForkJoinTaskList) XXX_Merge 

func (dst *DynamicForkJoinTaskList) XXX_Merge(src proto.Message)

func (*DynamicForkJoinTaskList) XXX_Size 

func (m *DynamicForkJoinTaskList) XXX_Size() int

func (*DynamicForkJoinTaskList) XXX_Unmarshal 

func (m *DynamicForkJoinTaskList) XXX_Unmarshal(b []byte) error

type EventExecution 

type EventExecution struct {
	Id                   string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	MessageId            string                   `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Name                 string                   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Event                string                   `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	Created              int64                    `protobuf:"varint,5,opt,name=created,proto3" json:"created,omitempty"`
	Status               EventExecution_Status    `protobuf:"varint,6,opt,name=status,proto3,enum=conductor.proto.EventExecution_Status" json:"status,omitempty"`
	Action               EventHandler_Action_Type `protobuf:"varint,7,opt,name=action,proto3,enum=conductor.proto.EventHandler_Action_Type" json:"action,omitempty"`
	Output               map[string]*any.Any      `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*EventExecution) Descriptor 

func (*EventExecution) Descriptor() ([]byte, []int)

func (*EventExecution) GetAction 

func (m *EventExecution) GetAction() EventHandler_Action_Type

func (*EventExecution) GetCreated 

func (m *EventExecution) GetCreated() int64

func (*EventExecution) GetEvent 

func (m *EventExecution) GetEvent() string

func (*EventExecution) GetId 

func (m *EventExecution) GetId() string

func (*EventExecution) GetMessageId 

func (m *EventExecution) GetMessageId() string

func (*EventExecution) GetName 

func (m *EventExecution) GetName() string

func (*EventExecution) GetOutput 

func (m *EventExecution) GetOutput() map[string]*any.Any

func (*EventExecution) GetStatus 

func (m *EventExecution) GetStatus() EventExecution_Status

func (*EventExecution) ProtoMessage 

func (*EventExecution) ProtoMessage()

func (*EventExecution) Reset 

func (m *EventExecution) Reset()

func (*EventExecution) String 

func (m *EventExecution) String() string

func (*EventExecution) XXX_DiscardUnknown 

func (m *EventExecution) XXX_DiscardUnknown()

func (*EventExecution) XXX_Marshal 

func (m *EventExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventExecution) XXX_Merge 

func (dst *EventExecution) XXX_Merge(src proto.Message)

func (*EventExecution) XXX_Size 

func (m *EventExecution) XXX_Size() int

func (*EventExecution) XXX_Unmarshal 

func (m *EventExecution) XXX_Unmarshal(b []byte) error

type EventExecution_Status 

type EventExecution_Status int32
const (
	EventExecution_IN_PROGRESS EventExecution_Status = 0
	EventExecution_COMPLETED   EventExecution_Status = 1
	EventExecution_FAILED      EventExecution_Status = 2
	EventExecution_SKIPPED     EventExecution_Status = 3
)

func (EventExecution_Status) EnumDescriptor 

func (EventExecution_Status) EnumDescriptor() ([]byte, []int)

func (EventExecution_Status) String 

func (x EventExecution_Status) String() string

type EventHandler 

type EventHandler struct {
	Name                 string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Event                string                 `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	Condition            string                 `protobuf:"bytes,3,opt,name=condition,proto3" json:"condition,omitempty"`
	Actions              []*EventHandler_Action `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
	Active               bool                   `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*EventHandler) Descriptor 

func (*EventHandler) Descriptor() ([]byte, []int)

func (*EventHandler) GetActions 

func (m *EventHandler) GetActions() []*EventHandler_Action

func (*EventHandler) GetActive 

func (m *EventHandler) GetActive() bool

func (*EventHandler) GetCondition 

func (m *EventHandler) GetCondition() string

func (*EventHandler) GetEvent 

func (m *EventHandler) GetEvent() string

func (*EventHandler) GetName 

func (m *EventHandler) GetName() string

func (*EventHandler) ProtoMessage 

func (*EventHandler) ProtoMessage()

func (*EventHandler) Reset 

func (m *EventHandler) Reset()

func (*EventHandler) String 

func (m *EventHandler) String() string

func (*EventHandler) XXX_DiscardUnknown 

func (m *EventHandler) XXX_DiscardUnknown()

func (*EventHandler) XXX_Marshal 

func (m *EventHandler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventHandler) XXX_Merge 

func (dst *EventHandler) XXX_Merge(src proto.Message)

func (*EventHandler) XXX_Size 

func (m *EventHandler) XXX_Size() int

func (*EventHandler) XXX_Unmarshal 

func (m *EventHandler) XXX_Unmarshal(b []byte) error

type EventHandler_Action 

type EventHandler_Action struct {
	Action               EventHandler_Action_Type    `protobuf:"varint,1,opt,name=action,proto3,enum=conductor.proto.EventHandler_Action_Type" json:"action,omitempty"`
	StartWorkflow        *EventHandler_StartWorkflow `protobuf:"bytes,2,opt,name=start_workflow,json=startWorkflow,proto3" json:"start_workflow,omitempty"`
	CompleteTask         *EventHandler_TaskDetails   `protobuf:"bytes,3,opt,name=complete_task,json=completeTask,proto3" json:"complete_task,omitempty"`
	FailTask             *EventHandler_TaskDetails   `protobuf:"bytes,4,opt,name=fail_task,json=failTask,proto3" json:"fail_task,omitempty"`
	ExpandInlineJson     bool                        `protobuf:"varint,5,opt,name=expand_inline_json,json=expandInlineJson,proto3" json:"expand_inline_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*EventHandler_Action) Descriptor 

func (*EventHandler_Action) Descriptor() ([]byte, []int)

func (*EventHandler_Action) GetAction 

func (m *EventHandler_Action) GetAction() EventHandler_Action_Type

func (*EventHandler_Action) GetCompleteTask 

func (m *EventHandler_Action) GetCompleteTask() *EventHandler_TaskDetails

func (*EventHandler_Action) GetExpandInlineJson 

func (m *EventHandler_Action) GetExpandInlineJson() bool

func (*EventHandler_Action) GetFailTask 

func (m *EventHandler_Action) GetFailTask() *EventHandler_TaskDetails

func (*EventHandler_Action) GetStartWorkflow 

func (m *EventHandler_Action) GetStartWorkflow() *EventHandler_StartWorkflow

func (*EventHandler_Action) ProtoMessage 

func (*EventHandler_Action) ProtoMessage()

func (*EventHandler_Action) Reset 

func (m *EventHandler_Action) Reset()

func (*EventHandler_Action) String 

func (m *EventHandler_Action) String() string

func (*EventHandler_Action) XXX_DiscardUnknown 

func (m *EventHandler_Action) XXX_DiscardUnknown()

func (*EventHandler_Action) XXX_Marshal 

func (m *EventHandler_Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventHandler_Action) XXX_Merge 

func (dst *EventHandler_Action) XXX_Merge(src proto.Message)

func (*EventHandler_Action) XXX_Size 

func (m *EventHandler_Action) XXX_Size() int

func (*EventHandler_Action) XXX_Unmarshal 

func (m *EventHandler_Action) XXX_Unmarshal(b []byte) error

type EventHandler_Action_Type 

type EventHandler_Action_Type int32
const (
	EventHandler_Action_START_WORKFLOW EventHandler_Action_Type = 0
	EventHandler_Action_COMPLETE_TASK  EventHandler_Action_Type = 1
	EventHandler_Action_FAIL_TASK      EventHandler_Action_Type = 2
)

func (EventHandler_Action_Type) EnumDescriptor 

func (EventHandler_Action_Type) EnumDescriptor() ([]byte, []int)

func (EventHandler_Action_Type) String 

func (x EventHandler_Action_Type) String() string

type EventHandler_StartWorkflow 

type EventHandler_StartWorkflow struct {
	Name                 string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              int32               `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	CorrelationId        string              `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Input                map[string]*any.Any `` /* 151-byte string literal not displayed */
	InputMessage         *any.Any            `protobuf:"bytes,5,opt,name=input_message,json=inputMessage,proto3" json:"input_message,omitempty"`
	TaskToDomain         map[string]string   `` /* 187-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EventHandler_StartWorkflow) Descriptor 

func (*EventHandler_StartWorkflow) Descriptor() ([]byte, []int)

func (*EventHandler_StartWorkflow) GetCorrelationId 

func (m *EventHandler_StartWorkflow) GetCorrelationId() string

func (*EventHandler_StartWorkflow) GetInput 

func (m *EventHandler_StartWorkflow) GetInput() map[string]*any.Any

func (*EventHandler_StartWorkflow) GetInputMessage 

func (m *EventHandler_StartWorkflow) GetInputMessage() *any.Any

func (*EventHandler_StartWorkflow) GetName 

func (m *EventHandler_StartWorkflow) GetName() string

func (*EventHandler_StartWorkflow) GetTaskToDomain 

func (m *EventHandler_StartWorkflow) GetTaskToDomain() map[string]string

func (*EventHandler_StartWorkflow) GetVersion 

func (m *EventHandler_StartWorkflow) GetVersion() int32

func (*EventHandler_StartWorkflow) ProtoMessage 

func (*EventHandler_StartWorkflow) ProtoMessage()

func (*EventHandler_StartWorkflow) Reset 

func (m *EventHandler_StartWorkflow) Reset()

func (*EventHandler_StartWorkflow) String 

func (m *EventHandler_StartWorkflow) String() string

func (*EventHandler_StartWorkflow) XXX_DiscardUnknown 

func (m *EventHandler_StartWorkflow) XXX_DiscardUnknown()

func (*EventHandler_StartWorkflow) XXX_Marshal 

func (m *EventHandler_StartWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventHandler_StartWorkflow) XXX_Merge 

func (dst *EventHandler_StartWorkflow) XXX_Merge(src proto.Message)

func (*EventHandler_StartWorkflow) XXX_Size 

func (m *EventHandler_StartWorkflow) XXX_Size() int

func (*EventHandler_StartWorkflow) XXX_Unmarshal 

func (m *EventHandler_StartWorkflow) XXX_Unmarshal(b []byte) error

type EventHandler_TaskDetails 

type EventHandler_TaskDetails struct {
	WorkflowId           string              `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	TaskRefName          string              `protobuf:"bytes,2,opt,name=task_ref_name,json=taskRefName,proto3" json:"task_ref_name,omitempty"`
	Output               map[string]*any.Any `` /* 153-byte string literal not displayed */
	OutputMessage        *any.Any            `protobuf:"bytes,4,opt,name=output_message,json=outputMessage,proto3" json:"output_message,omitempty"`
	TaskId               string              `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EventHandler_TaskDetails) Descriptor 

func (*EventHandler_TaskDetails) Descriptor() ([]byte, []int)

func (*EventHandler_TaskDetails) GetOutput 

func (m *EventHandler_TaskDetails) GetOutput() map[string]*any.Any

func (*EventHandler_TaskDetails) GetOutputMessage 

func (m *EventHandler_TaskDetails) GetOutputMessage() *any.Any

func (*EventHandler_TaskDetails) GetTaskId 

func (m *EventHandler_TaskDetails) GetTaskId() string

func (*EventHandler_TaskDetails) GetTaskRefName 

func (m *EventHandler_TaskDetails) GetTaskRefName() string

func (*EventHandler_TaskDetails) GetWorkflowId 

func (m *EventHandler_TaskDetails) GetWorkflowId() string

func (*EventHandler_TaskDetails) ProtoMessage 

func (*EventHandler_TaskDetails) ProtoMessage()

func (*EventHandler_TaskDetails) Reset 

func (m *EventHandler_TaskDetails) Reset()

func (*EventHandler_TaskDetails) String 

func (m *EventHandler_TaskDetails) String() string

func (*EventHandler_TaskDetails) XXX_DiscardUnknown 

func (m *EventHandler_TaskDetails) XXX_DiscardUnknown()

func (*EventHandler_TaskDetails) XXX_Marshal 

func (m *EventHandler_TaskDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventHandler_TaskDetails) XXX_Merge 

func (dst *EventHandler_TaskDetails) XXX_Merge(src proto.Message)

func (*EventHandler_TaskDetails) XXX_Size 

func (m *EventHandler_TaskDetails) XXX_Size() int

func (*EventHandler_TaskDetails) XXX_Unmarshal 

func (m *EventHandler_TaskDetails) XXX_Unmarshal(b []byte) error

type PollData 

type PollData struct {
	QueueName            string   `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	Domain               string   `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkerId             string   `protobuf:"bytes,3,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	LastPollTime         int64    `protobuf:"varint,4,opt,name=last_poll_time,json=lastPollTime,proto3" json:"last_poll_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PollData) Descriptor 

func (*PollData) Descriptor() ([]byte, []int)

func (*PollData) GetDomain 

func (m *PollData) GetDomain() string

func (*PollData) GetLastPollTime 

func (m *PollData) GetLastPollTime() int64

func (*PollData) GetQueueName 

func (m *PollData) GetQueueName() string

func (*PollData) GetWorkerId 

func (m *PollData) GetWorkerId() string

func (*PollData) ProtoMessage 

func (*PollData) ProtoMessage()

func (*PollData) Reset 

func (m *PollData) Reset()

func (*PollData) String 

func (m *PollData) String() string

func (*PollData) XXX_DiscardUnknown 

func (m *PollData) XXX_DiscardUnknown()

func (*PollData) XXX_Marshal 

func (m *PollData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollData) XXX_Merge 

func (dst *PollData) XXX_Merge(src proto.Message)

func (*PollData) XXX_Size 

func (m *PollData) XXX_Size() int

func (*PollData) XXX_Unmarshal 

func (m *PollData) XXX_Unmarshal(b []byte) error

type RerunWorkflowRequest 

type RerunWorkflowRequest struct {
	ReRunFromWorkflowId  string              `protobuf:"bytes,1,opt,name=re_run_from_workflow_id,json=reRunFromWorkflowId,proto3" json:"re_run_from_workflow_id,omitempty"`
	WorkflowInput        map[string]*any.Any `` /* 188-byte string literal not displayed */
	ReRunFromTaskId      string              `protobuf:"bytes,3,opt,name=re_run_from_task_id,json=reRunFromTaskId,proto3" json:"re_run_from_task_id,omitempty"`
	TaskInput            map[string]*any.Any `` /* 176-byte string literal not displayed */
	CorrelationId        string              `protobuf:"bytes,5,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RerunWorkflowRequest) Descriptor 

func (*RerunWorkflowRequest) Descriptor() ([]byte, []int)

func (*RerunWorkflowRequest) GetCorrelationId 

func (m *RerunWorkflowRequest) GetCorrelationId() string

func (*RerunWorkflowRequest) GetReRunFromTaskId 

func (m *RerunWorkflowRequest) GetReRunFromTaskId() string

func (*RerunWorkflowRequest) GetReRunFromWorkflowId 

func (m *RerunWorkflowRequest) GetReRunFromWorkflowId() string

func (*RerunWorkflowRequest) GetTaskInput 

func (m *RerunWorkflowRequest) GetTaskInput() map[string]*any.Any

func (*RerunWorkflowRequest) GetWorkflowInput 

func (m *RerunWorkflowRequest) GetWorkflowInput() map[string]*any.Any

func (*RerunWorkflowRequest) ProtoMessage 

func (*RerunWorkflowRequest) ProtoMessage()

func (*RerunWorkflowRequest) Reset 

func (m *RerunWorkflowRequest) Reset()

func (*RerunWorkflowRequest) String 

func (m *RerunWorkflowRequest) String() string

func (*RerunWorkflowRequest) XXX_DiscardUnknown 

func (m *RerunWorkflowRequest) XXX_DiscardUnknown()

func (*RerunWorkflowRequest) XXX_Marshal 

func (m *RerunWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RerunWorkflowRequest) XXX_Merge 

func (dst *RerunWorkflowRequest) XXX_Merge(src proto.Message)

func (*RerunWorkflowRequest) XXX_Size 

func (m *RerunWorkflowRequest) XXX_Size() int

func (*RerunWorkflowRequest) XXX_Unmarshal 

func (m *RerunWorkflowRequest) XXX_Unmarshal(b []byte) error

type SkipTaskRequest 

type SkipTaskRequest struct {
	TaskInput            map[string]*any.Any `` /* 176-byte string literal not displayed */
	TaskOutput           map[string]*any.Any `` /* 179-byte string literal not displayed */
	TaskInputMessage     *any.Any            `protobuf:"bytes,3,opt,name=task_input_message,json=taskInputMessage,proto3" json:"task_input_message,omitempty"`
	TaskOutputMessage    *any.Any            `protobuf:"bytes,4,opt,name=task_output_message,json=taskOutputMessage,proto3" json:"task_output_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SkipTaskRequest) Descriptor 

func (*SkipTaskRequest) Descriptor() ([]byte, []int)

func (*SkipTaskRequest) GetTaskInput 

func (m *SkipTaskRequest) GetTaskInput() map[string]*any.Any

func (*SkipTaskRequest) GetTaskInputMessage 

func (m *SkipTaskRequest) GetTaskInputMessage() *any.Any

func (*SkipTaskRequest) GetTaskOutput 

func (m *SkipTaskRequest) GetTaskOutput() map[string]*any.Any

func (*SkipTaskRequest) GetTaskOutputMessage 

func (m *SkipTaskRequest) GetTaskOutputMessage() *any.Any

func (*SkipTaskRequest) ProtoMessage 

func (*SkipTaskRequest) ProtoMessage()

func (*SkipTaskRequest) Reset 

func (m *SkipTaskRequest) Reset()

func (*SkipTaskRequest) String 

func (m *SkipTaskRequest) String() string

func (*SkipTaskRequest) XXX_DiscardUnknown 

func (m *SkipTaskRequest) XXX_DiscardUnknown()

func (*SkipTaskRequest) XXX_Marshal 

func (m *SkipTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SkipTaskRequest) XXX_Merge 

func (dst *SkipTaskRequest) XXX_Merge(src proto.Message)

func (*SkipTaskRequest) XXX_Size 

func (m *SkipTaskRequest) XXX_Size() int

func (*SkipTaskRequest) XXX_Unmarshal 

func (m *SkipTaskRequest) XXX_Unmarshal(b []byte) error

type StartWorkflowRequest 

type StartWorkflowRequest struct {
	Name                            string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version                         int32               `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	CorrelationId                   string              `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Input                           map[string]*any.Any `` /* 151-byte string literal not displayed */
	TaskToDomain                    map[string]string   `` /* 187-byte string literal not displayed */
	WorkflowDef                     *WorkflowDef        `protobuf:"bytes,6,opt,name=workflow_def,json=workflowDef,proto3" json:"workflow_def,omitempty"`
	ExternalInputPayloadStoragePath string              `` /* 160-byte string literal not displayed */
	Priority                        int32               `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral            struct{}            `json:"-"`
	XXX_unrecognized                []byte              `json:"-"`
	XXX_sizecache                   int32               `json:"-"`
}

func (*StartWorkflowRequest) Descriptor 

func (*StartWorkflowRequest) Descriptor() ([]byte, []int)

func (*StartWorkflowRequest) GetCorrelationId 

func (m *StartWorkflowRequest) GetCorrelationId() string

func (*StartWorkflowRequest) GetExternalInputPayloadStoragePath 

func (m *StartWorkflowRequest) GetExternalInputPayloadStoragePath() string

func (*StartWorkflowRequest) GetInput 

func (m *StartWorkflowRequest) GetInput() map[string]*any.Any

func (*StartWorkflowRequest) GetName 

func (m *StartWorkflowRequest) GetName() string

func (*StartWorkflowRequest) GetPriority 

func (m *StartWorkflowRequest) GetPriority() int32

func (*StartWorkflowRequest) GetTaskToDomain 

func (m *StartWorkflowRequest) GetTaskToDomain() map[string]string

func (*StartWorkflowRequest) GetVersion 

func (m *StartWorkflowRequest) GetVersion() int32

func (*StartWorkflowRequest) GetWorkflowDef 

func (m *StartWorkflowRequest) GetWorkflowDef() *WorkflowDef

func (*StartWorkflowRequest) ProtoMessage 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) Reset 

func (m *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) String 

func (m *StartWorkflowRequest) String() string

func (*StartWorkflowRequest) XXX_DiscardUnknown 

func (m *StartWorkflowRequest) XXX_DiscardUnknown()

func (*StartWorkflowRequest) XXX_Marshal 

func (m *StartWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartWorkflowRequest) XXX_Merge 

func (dst *StartWorkflowRequest) XXX_Merge(src proto.Message)

func (*StartWorkflowRequest) XXX_Size 

func (m *StartWorkflowRequest) XXX_Size() int

func (*StartWorkflowRequest) XXX_Unmarshal 

func (m *StartWorkflowRequest) XXX_Unmarshal(b []byte) error

type SubWorkflowParams 

type SubWorkflowParams struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              int32             `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	TaskToDomain         map[string]string `` /* 187-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SubWorkflowParams) Descriptor 

func (*SubWorkflowParams) Descriptor() ([]byte, []int)

func (*SubWorkflowParams) GetName 

func (m *SubWorkflowParams) GetName() string

func (*SubWorkflowParams) GetTaskToDomain 

func (m *SubWorkflowParams) GetTaskToDomain() map[string]string

func (*SubWorkflowParams) GetVersion 

func (m *SubWorkflowParams) GetVersion() int32

func (*SubWorkflowParams) ProtoMessage 

func (*SubWorkflowParams) ProtoMessage()

func (*SubWorkflowParams) Reset 

func (m *SubWorkflowParams) Reset()

func (*SubWorkflowParams) String 

func (m *SubWorkflowParams) String() string

func (*SubWorkflowParams) XXX_DiscardUnknown 

func (m *SubWorkflowParams) XXX_DiscardUnknown()

func (*SubWorkflowParams) XXX_Marshal 

func (m *SubWorkflowParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubWorkflowParams) XXX_Merge 

func (dst *SubWorkflowParams) XXX_Merge(src proto.Message)

func (*SubWorkflowParams) XXX_Size 

func (m *SubWorkflowParams) XXX_Size() int

func (*SubWorkflowParams) XXX_Unmarshal 

func (m *SubWorkflowParams) XXX_Unmarshal(b []byte) error

type Task 

type Task struct {
	TaskType                         string              `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	Status                           Task_Status         `protobuf:"varint,2,opt,name=status,proto3,enum=conductor.proto.Task_Status" json:"status,omitempty"`
	InputData                        map[string]*any.Any `` /* 176-byte string literal not displayed */
	ReferenceTaskName                string              `protobuf:"bytes,4,opt,name=reference_task_name,json=referenceTaskName,proto3" json:"reference_task_name,omitempty"`
	RetryCount                       int32               `protobuf:"varint,5,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	Seq                              int32               `protobuf:"varint,6,opt,name=seq,proto3" json:"seq,omitempty"`
	CorrelationId                    string              `protobuf:"bytes,7,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	PollCount                        int32               `protobuf:"varint,8,opt,name=poll_count,json=pollCount,proto3" json:"poll_count,omitempty"`
	TaskDefName                      string              `protobuf:"bytes,9,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	ScheduledTime                    int64               `protobuf:"varint,10,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartTime                        int64               `protobuf:"varint,11,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime                          int64               `protobuf:"varint,12,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	UpdateTime                       int64               `protobuf:"varint,13,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	StartDelayInSeconds              int32               `protobuf:"varint,14,opt,name=start_delay_in_seconds,json=startDelayInSeconds,proto3" json:"start_delay_in_seconds,omitempty"`
	RetriedTaskId                    string              `protobuf:"bytes,15,opt,name=retried_task_id,json=retriedTaskId,proto3" json:"retried_task_id,omitempty"`
	Retried                          bool                `protobuf:"varint,16,opt,name=retried,proto3" json:"retried,omitempty"`
	Executed                         bool                `protobuf:"varint,17,opt,name=executed,proto3" json:"executed,omitempty"`
	CallbackFromWorker               bool                `protobuf:"varint,18,opt,name=callback_from_worker,json=callbackFromWorker,proto3" json:"callback_from_worker,omitempty"`
	ResponseTimeoutSeconds           int64               `` /* 131-byte string literal not displayed */
	WorkflowInstanceId               string              `protobuf:"bytes,20,opt,name=workflow_instance_id,json=workflowInstanceId,proto3" json:"workflow_instance_id,omitempty"`
	WorkflowType                     string              `protobuf:"bytes,21,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskId                           string              `protobuf:"bytes,22,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ReasonForIncompletion            string              `` /* 127-byte string literal not displayed */
	CallbackAfterSeconds             int64               `protobuf:"varint,24,opt,name=callback_after_seconds,json=callbackAfterSeconds,proto3" json:"callback_after_seconds,omitempty"`
	WorkerId                         string              `protobuf:"bytes,25,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	OutputData                       map[string]*any.Any `` /* 180-byte string literal not displayed */
	WorkflowTask                     *WorkflowTask       `protobuf:"bytes,27,opt,name=workflow_task,json=workflowTask,proto3" json:"workflow_task,omitempty"`
	Domain                           string              `protobuf:"bytes,28,opt,name=domain,proto3" json:"domain,omitempty"`
	InputMessage                     *any.Any            `protobuf:"bytes,29,opt,name=input_message,json=inputMessage,proto3" json:"input_message,omitempty"`
	OutputMessage                    *any.Any            `protobuf:"bytes,30,opt,name=output_message,json=outputMessage,proto3" json:"output_message,omitempty"`
	RateLimitPerFrequency            int32               `` /* 130-byte string literal not displayed */
	RateLimitFrequencyInSeconds      int32               `` /* 150-byte string literal not displayed */
	ExternalInputPayloadStoragePath  string              `` /* 161-byte string literal not displayed */
	ExternalOutputPayloadStoragePath string              `` /* 164-byte string literal not displayed */
	WorkflowPriority                 int32               `protobuf:"varint,36,opt,name=workflow_priority,json=workflowPriority,proto3" json:"workflow_priority,omitempty"`
	ExecutionNameSpace               string              `protobuf:"bytes,37,opt,name=execution_name_space,json=executionNameSpace,proto3" json:"execution_name_space,omitempty"`
	IsolationGroupId                 string              `protobuf:"bytes,38,opt,name=isolation_group_id,json=isolationGroupId,proto3" json:"isolation_group_id,omitempty"`
	Iteration                        int32               `protobuf:"varint,40,opt,name=iteration,proto3" json:"iteration,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}            `json:"-"`
	XXX_unrecognized                 []byte              `json:"-"`
	XXX_sizecache                    int32               `json:"-"`
}

func (*Task) Descriptor 

func (*Task) Descriptor() ([]byte, []int)

func (*Task) GetCallbackAfterSeconds 

func (m *Task) GetCallbackAfterSeconds() int64

func (*Task) GetCallbackFromWorker 

func (m *Task) GetCallbackFromWorker() bool

func (*Task) GetCorrelationId 

func (m *Task) GetCorrelationId() string

func (*Task) GetDomain 

func (m *Task) GetDomain() string

func (*Task) GetEndTime 

func (m *Task) GetEndTime() int64

func (*Task) GetExecuted 

func (m *Task) GetExecuted() bool

func (*Task) GetExecutionNameSpace 

func (m *Task) GetExecutionNameSpace() string

func (*Task) GetExternalInputPayloadStoragePath 

func (m *Task) GetExternalInputPayloadStoragePath() string

func (*Task) GetExternalOutputPayloadStoragePath 

func (m *Task) GetExternalOutputPayloadStoragePath() string

func (*Task) GetInputData 

func (m *Task) GetInputData() map[string]*any.Any

func (*Task) GetInputMessage 

func (m *Task) GetInputMessage() *any.Any

func (*Task) GetIsolationGroupId 

func (m *Task) GetIsolationGroupId() string

func (*Task) GetIteration 

func (m *Task) GetIteration() int32

func (*Task) GetOutputData 

func (m *Task) GetOutputData() map[string]*any.Any

func (*Task) GetOutputMessage 

func (m *Task) GetOutputMessage() *any.Any

func (*Task) GetPollCount 

func (m *Task) GetPollCount() int32

func (*Task) GetRateLimitFrequencyInSeconds 

func (m *Task) GetRateLimitFrequencyInSeconds() int32

func (*Task) GetRateLimitPerFrequency 

func (m *Task) GetRateLimitPerFrequency() int32

func (*Task) GetReasonForIncompletion 

func (m *Task) GetReasonForIncompletion() string

func (*Task) GetReferenceTaskName 

func (m *Task) GetReferenceTaskName() string

func (*Task) GetResponseTimeoutSeconds 

func (m *Task) GetResponseTimeoutSeconds() int64

func (*Task) GetRetried 

func (m *Task) GetRetried() bool

func (*Task) GetRetriedTaskId 

func (m *Task) GetRetriedTaskId() string

func (*Task) GetRetryCount 

func (m *Task) GetRetryCount() int32

func (*Task) GetScheduledTime 

func (m *Task) GetScheduledTime() int64

func (*Task) GetSeq 

func (m *Task) GetSeq() int32

func (*Task) GetStartDelayInSeconds 

func (m *Task) GetStartDelayInSeconds() int32

func (*Task) GetStartTime 

func (m *Task) GetStartTime() int64

func (*Task) GetStatus 

func (m *Task) GetStatus() Task_Status

func (*Task) GetTaskDefName 

func (m *Task) GetTaskDefName() string

func (*Task) GetTaskId 

func (m *Task) GetTaskId() string

func (*Task) GetTaskType 

func (m *Task) GetTaskType() string

func (*Task) GetUpdateTime 

func (m *Task) GetUpdateTime() int64

func (*Task) GetWorkerId 

func (m *Task) GetWorkerId() string

func (*Task) GetWorkflowInstanceId 

func (m *Task) GetWorkflowInstanceId() string

func (*Task) GetWorkflowPriority 

func (m *Task) GetWorkflowPriority() int32

func (*Task) GetWorkflowTask 

func (m *Task) GetWorkflowTask() *WorkflowTask

func (*Task) GetWorkflowType 

func (m *Task) GetWorkflowType() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Task) XXX_Merge 

func (dst *Task) XXX_Merge(src proto.Message)

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

func (m *Task) XXX_Unmarshal(b []byte) error

type TaskDef 

type TaskDef struct {
	Name                        string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description                 string                `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	RetryCount                  int32                 `protobuf:"varint,3,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	TimeoutSeconds              int64                 `protobuf:"varint,4,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	InputKeys                   []string              `protobuf:"bytes,5,rep,name=input_keys,json=inputKeys,proto3" json:"input_keys,omitempty"`
	OutputKeys                  []string              `protobuf:"bytes,6,rep,name=output_keys,json=outputKeys,proto3" json:"output_keys,omitempty"`
	TimeoutPolicy               TaskDef_TimeoutPolicy `` /* 144-byte string literal not displayed */
	RetryLogic                  TaskDef_RetryLogic    `` /* 132-byte string literal not displayed */
	RetryDelaySeconds           int32                 `protobuf:"varint,9,opt,name=retry_delay_seconds,json=retryDelaySeconds,proto3" json:"retry_delay_seconds,omitempty"`
	ResponseTimeoutSeconds      int64                 `` /* 131-byte string literal not displayed */
	ConcurrentExecLimit         int32                 `protobuf:"varint,11,opt,name=concurrent_exec_limit,json=concurrentExecLimit,proto3" json:"concurrent_exec_limit,omitempty"`
	InputTemplate               map[string]*any.Any   `` /* 189-byte string literal not displayed */
	RateLimitPerFrequency       int32                 `` /* 130-byte string literal not displayed */
	RateLimitFrequencyInSeconds int32                 `` /* 150-byte string literal not displayed */
	IsolationGroupId            string                `protobuf:"bytes,16,opt,name=isolation_group_id,json=isolationGroupId,proto3" json:"isolation_group_id,omitempty"`
	ExecutionNameSpace          string                `protobuf:"bytes,17,opt,name=execution_name_space,json=executionNameSpace,proto3" json:"execution_name_space,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}              `json:"-"`
	XXX_unrecognized            []byte                `json:"-"`
	XXX_sizecache               int32                 `json:"-"`
}

func (*TaskDef) Descriptor 

func (*TaskDef) Descriptor() ([]byte, []int)

func (*TaskDef) GetConcurrentExecLimit 

func (m *TaskDef) GetConcurrentExecLimit() int32

func (*TaskDef) GetDescription 

func (m *TaskDef) GetDescription() string

func (*TaskDef) GetExecutionNameSpace 

func (m *TaskDef) GetExecutionNameSpace() string

func (*TaskDef) GetInputKeys 

func (m *TaskDef) GetInputKeys() []string

func (*TaskDef) GetInputTemplate 

func (m *TaskDef) GetInputTemplate() map[string]*any.Any

func (*TaskDef) GetIsolationGroupId 

func (m *TaskDef) GetIsolationGroupId() string

func (*TaskDef) GetName 

func (m *TaskDef) GetName() string

func (*TaskDef) GetOutputKeys 

func (m *TaskDef) GetOutputKeys() []string

func (*TaskDef) GetRateLimitFrequencyInSeconds 

func (m *TaskDef) GetRateLimitFrequencyInSeconds() int32

func (*TaskDef) GetRateLimitPerFrequency 

func (m *TaskDef) GetRateLimitPerFrequency() int32

func (*TaskDef) GetResponseTimeoutSeconds 

func (m *TaskDef) GetResponseTimeoutSeconds() int64

func (*TaskDef) GetRetryCount 

func (m *TaskDef) GetRetryCount() int32

func (*TaskDef) GetRetryDelaySeconds 

func (m *TaskDef) GetRetryDelaySeconds() int32

func (*TaskDef) GetRetryLogic 

func (m *TaskDef) GetRetryLogic() TaskDef_RetryLogic

func (*TaskDef) GetTimeoutPolicy 

func (m *TaskDef) GetTimeoutPolicy() TaskDef_TimeoutPolicy

func (*TaskDef) GetTimeoutSeconds 

func (m *TaskDef) GetTimeoutSeconds() int64

func (*TaskDef) ProtoMessage 

func (*TaskDef) ProtoMessage()

func (*TaskDef) Reset 

func (m *TaskDef) Reset()

func (*TaskDef) String 

func (m *TaskDef) String() string

func (*TaskDef) XXX_DiscardUnknown 

func (m *TaskDef) XXX_DiscardUnknown()

func (*TaskDef) XXX_Marshal 

func (m *TaskDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskDef) XXX_Merge 

func (dst *TaskDef) XXX_Merge(src proto.Message)

func (*TaskDef) XXX_Size 

func (m *TaskDef) XXX_Size() int

func (*TaskDef) XXX_Unmarshal 

func (m *TaskDef) XXX_Unmarshal(b []byte) error

type TaskDef_RetryLogic 

type TaskDef_RetryLogic int32
const (
	TaskDef_FIXED               TaskDef_RetryLogic = 0
	TaskDef_EXPONENTIAL_BACKOFF TaskDef_RetryLogic = 1
)

func (TaskDef_RetryLogic) EnumDescriptor 

func (TaskDef_RetryLogic) EnumDescriptor() ([]byte, []int)

func (TaskDef_RetryLogic) String 

func (x TaskDef_RetryLogic) String() string

type TaskDef_TimeoutPolicy 

type TaskDef_TimeoutPolicy int32
const (
	TaskDef_RETRY       TaskDef_TimeoutPolicy = 0
	TaskDef_TIME_OUT_WF TaskDef_TimeoutPolicy = 1
	TaskDef_ALERT_ONLY  TaskDef_TimeoutPolicy = 2
)

func (TaskDef_TimeoutPolicy) EnumDescriptor 

func (TaskDef_TimeoutPolicy) EnumDescriptor() ([]byte, []int)

func (TaskDef_TimeoutPolicy) String 

func (x TaskDef_TimeoutPolicy) String() string

type TaskExecLog 

type TaskExecLog struct {
	Log                  string   `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	TaskId               string   `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	CreatedTime          int64    `protobuf:"varint,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskExecLog) Descriptor 

func (*TaskExecLog) Descriptor() ([]byte, []int)

func (*TaskExecLog) GetCreatedTime 

func (m *TaskExecLog) GetCreatedTime() int64

func (*TaskExecLog) GetLog 

func (m *TaskExecLog) GetLog() string

func (*TaskExecLog) GetTaskId 

func (m *TaskExecLog) GetTaskId() string

func (*TaskExecLog) ProtoMessage 

func (*TaskExecLog) ProtoMessage()

func (*TaskExecLog) Reset 

func (m *TaskExecLog) Reset()

func (*TaskExecLog) String 

func (m *TaskExecLog) String() string

func (*TaskExecLog) XXX_DiscardUnknown 

func (m *TaskExecLog) XXX_DiscardUnknown()

func (*TaskExecLog) XXX_Marshal 

func (m *TaskExecLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskExecLog) XXX_Merge 

func (dst *TaskExecLog) XXX_Merge(src proto.Message)

func (*TaskExecLog) XXX_Size 

func (m *TaskExecLog) XXX_Size() int

func (*TaskExecLog) XXX_Unmarshal 

func (m *TaskExecLog) XXX_Unmarshal(b []byte) error

type TaskResult 

type TaskResult struct {
	WorkflowInstanceId    string              `protobuf:"bytes,1,opt,name=workflow_instance_id,json=workflowInstanceId,proto3" json:"workflow_instance_id,omitempty"`
	TaskId                string              `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ReasonForIncompletion string              `` /* 126-byte string literal not displayed */
	CallbackAfterSeconds  int64               `protobuf:"varint,4,opt,name=callback_after_seconds,json=callbackAfterSeconds,proto3" json:"callback_after_seconds,omitempty"`
	WorkerId              string              `protobuf:"bytes,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Status                TaskResult_Status   `protobuf:"varint,6,opt,name=status,proto3,enum=conductor.proto.TaskResult_Status" json:"status,omitempty"`
	OutputData            map[string]*any.Any `` /* 179-byte string literal not displayed */
	OutputMessage         *any.Any            `protobuf:"bytes,8,opt,name=output_message,json=outputMessage,proto3" json:"output_message,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}            `json:"-"`
	XXX_unrecognized      []byte              `json:"-"`
	XXX_sizecache         int32               `json:"-"`
}

func (*TaskResult) Descriptor 

func (*TaskResult) Descriptor() ([]byte, []int)

func (*TaskResult) GetCallbackAfterSeconds 

func (m *TaskResult) GetCallbackAfterSeconds() int64

func (*TaskResult) GetOutputData 

func (m *TaskResult) GetOutputData() map[string]*any.Any

func (*TaskResult) GetOutputMessage 

func (m *TaskResult) GetOutputMessage() *any.Any

func (*TaskResult) GetReasonForIncompletion 

func (m *TaskResult) GetReasonForIncompletion() string

func (*TaskResult) GetStatus 

func (m *TaskResult) GetStatus() TaskResult_Status

func (*TaskResult) GetTaskId 

func (m *TaskResult) GetTaskId() string

func (*TaskResult) GetWorkerId 

func (m *TaskResult) GetWorkerId() string

func (*TaskResult) GetWorkflowInstanceId 

func (m *TaskResult) GetWorkflowInstanceId() string

func (*TaskResult) ProtoMessage 

func (*TaskResult) ProtoMessage()

func (*TaskResult) Reset 

func (m *TaskResult) Reset()

func (*TaskResult) String 

func (m *TaskResult) String() string

func (*TaskResult) XXX_DiscardUnknown 

func (m *TaskResult) XXX_DiscardUnknown()

func (*TaskResult) XXX_Marshal 

func (m *TaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskResult) XXX_Merge 

func (dst *TaskResult) XXX_Merge(src proto.Message)

func (*TaskResult) XXX_Size 

func (m *TaskResult) XXX_Size() int

func (*TaskResult) XXX_Unmarshal 

func (m *TaskResult) XXX_Unmarshal(b []byte) error

type TaskResult_Status 

type TaskResult_Status int32
const (
	TaskResult_IN_PROGRESS                TaskResult_Status = 0
	TaskResult_FAILED                     TaskResult_Status = 1
	TaskResult_FAILED_WITH_TERMINAL_ERROR TaskResult_Status = 2
	TaskResult_COMPLETED                  TaskResult_Status = 3
)

func (TaskResult_Status) EnumDescriptor 

func (TaskResult_Status) EnumDescriptor() ([]byte, []int)

func (TaskResult_Status) String 

func (x TaskResult_Status) String() string

type TaskSummary 

type TaskSummary struct {
	WorkflowId                       string      `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType                     string      `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	CorrelationId                    string      `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ScheduledTime                    string      `protobuf:"bytes,4,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartTime                        string      `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	UpdateTime                       string      `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	EndTime                          string      `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Status                           Task_Status `protobuf:"varint,8,opt,name=status,proto3,enum=conductor.proto.Task_Status" json:"status,omitempty"`
	ReasonForIncompletion            string      `` /* 126-byte string literal not displayed */
	ExecutionTime                    int64       `protobuf:"varint,10,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	QueueWaitTime                    int64       `protobuf:"varint,11,opt,name=queue_wait_time,json=queueWaitTime,proto3" json:"queue_wait_time,omitempty"`
	TaskDefName                      string      `protobuf:"bytes,12,opt,name=task_def_name,json=taskDefName,proto3" json:"task_def_name,omitempty"`
	TaskType                         string      `protobuf:"bytes,13,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	Input                            string      `protobuf:"bytes,14,opt,name=input,proto3" json:"input,omitempty"`
	Output                           string      `protobuf:"bytes,15,opt,name=output,proto3" json:"output,omitempty"`
	TaskId                           string      `protobuf:"bytes,16,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExternalInputPayloadStoragePath  string      `` /* 161-byte string literal not displayed */
	ExternalOutputPayloadStoragePath string      `` /* 164-byte string literal not displayed */
	WorkflowPriority                 int32       `protobuf:"varint,19,opt,name=workflow_priority,json=workflowPriority,proto3" json:"workflow_priority,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}    `json:"-"`
	XXX_unrecognized                 []byte      `json:"-"`
	XXX_sizecache                    int32       `json:"-"`
}

func (*TaskSummary) Descriptor 

func (*TaskSummary) Descriptor() ([]byte, []int)

func (*TaskSummary) GetCorrelationId 

func (m *TaskSummary) GetCorrelationId() string

func (*TaskSummary) GetEndTime 

func (m *TaskSummary) GetEndTime() string

func (*TaskSummary) GetExecutionTime 

func (m *TaskSummary) GetExecutionTime() int64

func (*TaskSummary) GetExternalInputPayloadStoragePath 

func (m *TaskSummary) GetExternalInputPayloadStoragePath() string

func (*TaskSummary) GetExternalOutputPayloadStoragePath 

func (m *TaskSummary) GetExternalOutputPayloadStoragePath() string

func (*TaskSummary) GetInput 

func (m *TaskSummary) GetInput() string

func (*TaskSummary) GetOutput 

func (m *TaskSummary) GetOutput() string

func (*TaskSummary) GetQueueWaitTime 

func (m *TaskSummary) GetQueueWaitTime() int64

func (*TaskSummary) GetReasonForIncompletion 

func (m *TaskSummary) GetReasonForIncompletion() string

func (*TaskSummary) GetScheduledTime 

func (m *TaskSummary) GetScheduledTime() string

func (*TaskSummary) GetStartTime 

func (m *TaskSummary) GetStartTime() string

func (*TaskSummary) GetStatus 

func (m *TaskSummary) GetStatus() Task_Status

func (*TaskSummary) GetTaskDefName 

func (m *TaskSummary) GetTaskDefName() string

func (*TaskSummary) GetTaskId 

func (m *TaskSummary) GetTaskId() string

func (*TaskSummary) GetTaskType 

func (m *TaskSummary) GetTaskType() string

func (*TaskSummary) GetUpdateTime 

func (m *TaskSummary) GetUpdateTime() string

func (*TaskSummary) GetWorkflowId 

func (m *TaskSummary) GetWorkflowId() string

func (*TaskSummary) GetWorkflowPriority 

func (m *TaskSummary) GetWorkflowPriority() int32

func (*TaskSummary) GetWorkflowType 

func (m *TaskSummary) GetWorkflowType() string

func (*TaskSummary) ProtoMessage 

func (*TaskSummary) ProtoMessage()

func (*TaskSummary) Reset 

func (m *TaskSummary) Reset()

func (*TaskSummary) String 

func (m *TaskSummary) String() string

func (*TaskSummary) XXX_DiscardUnknown 

func (m *TaskSummary) XXX_DiscardUnknown()

func (*TaskSummary) XXX_Marshal 

func (m *TaskSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskSummary) XXX_Merge 

func (dst *TaskSummary) XXX_Merge(src proto.Message)

func (*TaskSummary) XXX_Size 

func (m *TaskSummary) XXX_Size() int

func (*TaskSummary) XXX_Unmarshal 

func (m *TaskSummary) XXX_Unmarshal(b []byte) error

type Task_Status 

type Task_Status int32
const (
	Task_IN_PROGRESS                Task_Status = 0
	Task_CANCELED                   Task_Status = 1
	Task_FAILED                     Task_Status = 2
	Task_FAILED_WITH_TERMINAL_ERROR Task_Status = 3
	Task_COMPLETED                  Task_Status = 4
	Task_COMPLETED_WITH_ERRORS      Task_Status = 5
	Task_SCHEDULED                  Task_Status = 6
	Task_TIMED_OUT                  Task_Status = 7
	Task_SKIPPED                    Task_Status = 8
)

func (Task_Status) EnumDescriptor 

func (Task_Status) EnumDescriptor() ([]byte, []int)

func (Task_Status) String 

func (x Task_Status) String() string

type Workflow 

type Workflow struct {
	Status                           Workflow_WorkflowStatus `protobuf:"varint,1,opt,name=status,proto3,enum=conductor.proto.Workflow_WorkflowStatus" json:"status,omitempty"`
	EndTime                          int64                   `protobuf:"varint,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	WorkflowId                       string                  `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	ParentWorkflowId                 string                  `protobuf:"bytes,4,opt,name=parent_workflow_id,json=parentWorkflowId,proto3" json:"parent_workflow_id,omitempty"`
	ParentWorkflowTaskId             string                  `protobuf:"bytes,5,opt,name=parent_workflow_task_id,json=parentWorkflowTaskId,proto3" json:"parent_workflow_task_id,omitempty"`
	Tasks                            []*Task                 `protobuf:"bytes,6,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Input                            map[string]*any.Any     `` /* 151-byte string literal not displayed */
	Output                           map[string]*any.Any     `` /* 153-byte string literal not displayed */
	WorkflowType                     string                  `protobuf:"bytes,10,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	Version                          int32                   `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
	CorrelationId                    string                  `protobuf:"bytes,12,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ReRunFromWorkflowId              string                  `protobuf:"bytes,13,opt,name=re_run_from_workflow_id,json=reRunFromWorkflowId,proto3" json:"re_run_from_workflow_id,omitempty"`
	ReasonForIncompletion            string                  `` /* 127-byte string literal not displayed */
	SchemaVersion                    int32                   `protobuf:"varint,15,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	Event                            string                  `protobuf:"bytes,16,opt,name=event,proto3" json:"event,omitempty"`
	TaskToDomain                     map[string]string       `` /* 188-byte string literal not displayed */
	FailedReferenceTaskNames         []string                `` /* 138-byte string literal not displayed */
	WorkflowDefinition               *WorkflowDef            `protobuf:"bytes,19,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	ExternalInputPayloadStoragePath  string                  `` /* 161-byte string literal not displayed */
	ExternalOutputPayloadStoragePath string                  `` /* 164-byte string literal not displayed */
	Priority                         int32                   `protobuf:"varint,22,opt,name=priority,proto3" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}                `json:"-"`
	XXX_unrecognized                 []byte                  `json:"-"`
	XXX_sizecache                    int32                   `json:"-"`
}

func (*Workflow) Descriptor 

func (*Workflow) Descriptor() ([]byte, []int)

func (*Workflow) GetCorrelationId 

func (m *Workflow) GetCorrelationId() string

func (*Workflow) GetEndTime 

func (m *Workflow) GetEndTime() int64

func (*Workflow) GetEvent 

func (m *Workflow) GetEvent() string

func (*Workflow) GetExternalInputPayloadStoragePath 

func (m *Workflow) GetExternalInputPayloadStoragePath() string

func (*Workflow) GetExternalOutputPayloadStoragePath 

func (m *Workflow) GetExternalOutputPayloadStoragePath() string

func (*Workflow) GetFailedReferenceTaskNames 

func (m *Workflow) GetFailedReferenceTaskNames() []string

func (*Workflow) GetInput 

func (m *Workflow) GetInput() map[string]*any.Any

func (*Workflow) GetOutput 

func (m *Workflow) GetOutput() map[string]*any.Any

func (*Workflow) GetParentWorkflowId 

func (m *Workflow) GetParentWorkflowId() string

func (*Workflow) GetParentWorkflowTaskId 

func (m *Workflow) GetParentWorkflowTaskId() string

func (*Workflow) GetPriority 

func (m *Workflow) GetPriority() int32

func (*Workflow) GetReRunFromWorkflowId 

func (m *Workflow) GetReRunFromWorkflowId() string

func (*Workflow) GetReasonForIncompletion 

func (m *Workflow) GetReasonForIncompletion() string

func (*Workflow) GetSchemaVersion 

func (m *Workflow) GetSchemaVersion() int32

func (*Workflow) GetStatus 

func (m *Workflow) GetStatus() Workflow_WorkflowStatus

func (*Workflow) GetTaskToDomain 

func (m *Workflow) GetTaskToDomain() map[string]string

func (*Workflow) GetTasks 

func (m *Workflow) GetTasks() []*Task

func (*Workflow) GetVersion 

func (m *Workflow) GetVersion() int32

func (*Workflow) GetWorkflowDefinition 

func (m *Workflow) GetWorkflowDefinition() *WorkflowDef

func (*Workflow) GetWorkflowId 

func (m *Workflow) GetWorkflowId() string

func (*Workflow) GetWorkflowType 

func (m *Workflow) GetWorkflowType() string

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset 

func (m *Workflow) Reset()

func (*Workflow) String 

func (m *Workflow) String() string

func (*Workflow) XXX_DiscardUnknown 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal 

func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow) XXX_Merge 

func (dst *Workflow) XXX_Merge(src proto.Message)

func (*Workflow) XXX_Size 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal 

func (m *Workflow) XXX_Unmarshal(b []byte) error

type WorkflowDef 

type WorkflowDef struct {
	Name                          string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description                   string              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Version                       int32               `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Tasks                         []*WorkflowTask     `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"`
	InputParameters               []string            `protobuf:"bytes,5,rep,name=input_parameters,json=inputParameters,proto3" json:"input_parameters,omitempty"`
	OutputParameters              map[string]*any.Any `` /* 197-byte string literal not displayed */
	FailureWorkflow               string              `protobuf:"bytes,7,opt,name=failure_workflow,json=failureWorkflow,proto3" json:"failure_workflow,omitempty"`
	SchemaVersion                 int32               `protobuf:"varint,8,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	Restartable                   bool                `protobuf:"varint,9,opt,name=restartable,proto3" json:"restartable,omitempty"`
	WorkflowStatusListenerEnabled bool                `` /* 154-byte string literal not displayed */
	XXX_NoUnkeyedLiteral          struct{}            `json:"-"`
	XXX_unrecognized              []byte              `json:"-"`
	XXX_sizecache                 int32               `json:"-"`
}

func (*WorkflowDef) Descriptor 

func (*WorkflowDef) Descriptor() ([]byte, []int)

func (*WorkflowDef) GetDescription 

func (m *WorkflowDef) GetDescription() string

func (*WorkflowDef) GetFailureWorkflow 

func (m *WorkflowDef) GetFailureWorkflow() string

func (*WorkflowDef) GetInputParameters 

func (m *WorkflowDef) GetInputParameters() []string

func (*WorkflowDef) GetName 

func (m *WorkflowDef) GetName() string

func (*WorkflowDef) GetOutputParameters 

func (m *WorkflowDef) GetOutputParameters() map[string]*any.Any

func (*WorkflowDef) GetRestartable 

func (m *WorkflowDef) GetRestartable() bool

func (*WorkflowDef) GetSchemaVersion 

func (m *WorkflowDef) GetSchemaVersion() int32

func (*WorkflowDef) GetTasks 

func (m *WorkflowDef) GetTasks() []*WorkflowTask

func (*WorkflowDef) GetVersion 

func (m *WorkflowDef) GetVersion() int32

func (*WorkflowDef) GetWorkflowStatusListenerEnabled 

func (m *WorkflowDef) GetWorkflowStatusListenerEnabled() bool

func (*WorkflowDef) ProtoMessage 

func (*WorkflowDef) ProtoMessage()

func (*WorkflowDef) Reset 

func (m *WorkflowDef) Reset()

func (*WorkflowDef) String 

func (m *WorkflowDef) String() string

func (*WorkflowDef) XXX_DiscardUnknown 

func (m *WorkflowDef) XXX_DiscardUnknown()

func (*WorkflowDef) XXX_Marshal 

func (m *WorkflowDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowDef) XXX_Merge 

func (dst *WorkflowDef) XXX_Merge(src proto.Message)

func (*WorkflowDef) XXX_Size 

func (m *WorkflowDef) XXX_Size() int

func (*WorkflowDef) XXX_Unmarshal 

func (m *WorkflowDef) XXX_Unmarshal(b []byte) error

type WorkflowSummary 

type WorkflowSummary struct {
	WorkflowType                     string                  `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	Version                          int32                   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	WorkflowId                       string                  `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	CorrelationId                    string                  `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	StartTime                        string                  `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	UpdateTime                       string                  `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	EndTime                          string                  `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Status                           Workflow_WorkflowStatus `protobuf:"varint,8,opt,name=status,proto3,enum=conductor.proto.Workflow_WorkflowStatus" json:"status,omitempty"`
	Input                            string                  `protobuf:"bytes,9,opt,name=input,proto3" json:"input,omitempty"`
	Output                           string                  `protobuf:"bytes,10,opt,name=output,proto3" json:"output,omitempty"`
	ReasonForIncompletion            string                  `` /* 127-byte string literal not displayed */
	ExecutionTime                    int64                   `protobuf:"varint,12,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	Event                            string                  `protobuf:"bytes,13,opt,name=event,proto3" json:"event,omitempty"`
	FailedReferenceTaskNames         string                  `` /* 138-byte string literal not displayed */
	ExternalInputPayloadStoragePath  string                  `` /* 161-byte string literal not displayed */
	ExternalOutputPayloadStoragePath string                  `` /* 164-byte string literal not displayed */
	Priority                         int32                   `protobuf:"varint,17,opt,name=priority,proto3" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}                `json:"-"`
	XXX_unrecognized                 []byte                  `json:"-"`
	XXX_sizecache                    int32                   `json:"-"`
}

func (*WorkflowSummary) Descriptor 

func (*WorkflowSummary) Descriptor() ([]byte, []int)

func (*WorkflowSummary) GetCorrelationId 

func (m *WorkflowSummary) GetCorrelationId() string

func (*WorkflowSummary) GetEndTime 

func (m *WorkflowSummary) GetEndTime() string

func (*WorkflowSummary) GetEvent 

func (m *WorkflowSummary) GetEvent() string

func (*WorkflowSummary) GetExecutionTime 

func (m *WorkflowSummary) GetExecutionTime() int64

func (*WorkflowSummary) GetExternalInputPayloadStoragePath 

func (m *WorkflowSummary) GetExternalInputPayloadStoragePath() string

func (*WorkflowSummary) GetExternalOutputPayloadStoragePath 

func (m *WorkflowSummary) GetExternalOutputPayloadStoragePath() string

func (*WorkflowSummary) GetFailedReferenceTaskNames 

func (m *WorkflowSummary) GetFailedReferenceTaskNames() string

func (*WorkflowSummary) GetInput 

func (m *WorkflowSummary) GetInput() string

func (*WorkflowSummary) GetOutput 

func (m *WorkflowSummary) GetOutput() string

func (*WorkflowSummary) GetPriority 

func (m *WorkflowSummary) GetPriority() int32

func (*WorkflowSummary) GetReasonForIncompletion 

func (m *WorkflowSummary) GetReasonForIncompletion() string

func (*WorkflowSummary) GetStartTime 

func (m *WorkflowSummary) GetStartTime() string

func (*WorkflowSummary) GetStatus 

func (m *WorkflowSummary) GetStatus() Workflow_WorkflowStatus

func (*WorkflowSummary) GetUpdateTime 

func (m *WorkflowSummary) GetUpdateTime() string

func (*WorkflowSummary) GetVersion 

func (m *WorkflowSummary) GetVersion() int32

func (*WorkflowSummary) GetWorkflowId 

func (m *WorkflowSummary) GetWorkflowId() string

func (*WorkflowSummary) GetWorkflowType 

func (m *WorkflowSummary) GetWorkflowType() string

func (*WorkflowSummary) ProtoMessage 

func (*WorkflowSummary) ProtoMessage()

func (*WorkflowSummary) Reset 

func (m *WorkflowSummary) Reset()

func (*WorkflowSummary) String 

func (m *WorkflowSummary) String() string

func (*WorkflowSummary) XXX_DiscardUnknown 

func (m *WorkflowSummary) XXX_DiscardUnknown()

func (*WorkflowSummary) XXX_Marshal 

func (m *WorkflowSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowSummary) XXX_Merge 

func (dst *WorkflowSummary) XXX_Merge(src proto.Message)

func (*WorkflowSummary) XXX_Size 

func (m *WorkflowSummary) XXX_Size() int

func (*WorkflowSummary) XXX_Unmarshal 

func (m *WorkflowSummary) XXX_Unmarshal(b []byte) error

type WorkflowTask 

type WorkflowTask struct {
	Name                           string                                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TaskReferenceName              string                                    `protobuf:"bytes,2,opt,name=task_reference_name,json=taskReferenceName,proto3" json:"task_reference_name,omitempty"`
	Description                    string                                    `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	InputParameters                map[string]*any.Any                       `` /* 194-byte string literal not displayed */
	Type                           string                                    `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	DynamicTaskNameParam           string                                    `protobuf:"bytes,6,opt,name=dynamic_task_name_param,json=dynamicTaskNameParam,proto3" json:"dynamic_task_name_param,omitempty"`
	CaseValueParam                 string                                    `protobuf:"bytes,7,opt,name=case_value_param,json=caseValueParam,proto3" json:"case_value_param,omitempty"`
	CaseExpression                 string                                    `protobuf:"bytes,8,opt,name=case_expression,json=caseExpression,proto3" json:"case_expression,omitempty"`
	ScriptExpression               string                                    `protobuf:"bytes,22,opt,name=script_expression,json=scriptExpression,proto3" json:"script_expression,omitempty"`
	DecisionCases                  map[string]*WorkflowTask_WorkflowTaskList `` /* 188-byte string literal not displayed */
	DynamicForkTasksParam          string                                    `` /* 129-byte string literal not displayed */
	DynamicForkTasksInputParamName string                                    `` /* 160-byte string literal not displayed */
	DefaultCase                    []*WorkflowTask                           `protobuf:"bytes,12,rep,name=default_case,json=defaultCase,proto3" json:"default_case,omitempty"`
	ForkTasks                      []*WorkflowTask_WorkflowTaskList          `protobuf:"bytes,13,rep,name=fork_tasks,json=forkTasks,proto3" json:"fork_tasks,omitempty"`
	StartDelay                     int32                                     `protobuf:"varint,14,opt,name=start_delay,json=startDelay,proto3" json:"start_delay,omitempty"`
	SubWorkflowParam               *SubWorkflowParams                        `protobuf:"bytes,15,opt,name=sub_workflow_param,json=subWorkflowParam,proto3" json:"sub_workflow_param,omitempty"`
	JoinOn                         []string                                  `protobuf:"bytes,16,rep,name=join_on,json=joinOn,proto3" json:"join_on,omitempty"`
	Sink                           string                                    `protobuf:"bytes,17,opt,name=sink,proto3" json:"sink,omitempty"`
	Optional                       bool                                      `protobuf:"varint,18,opt,name=optional,proto3" json:"optional,omitempty"`
	TaskDefinition                 *TaskDef                                  `protobuf:"bytes,19,opt,name=task_definition,json=taskDefinition,proto3" json:"task_definition,omitempty"`
	RateLimited                    bool                                      `protobuf:"varint,20,opt,name=rate_limited,json=rateLimited,proto3" json:"rate_limited,omitempty"`
	DefaultExclusiveJoinTask       []string                                  `` /* 138-byte string literal not displayed */
	AsyncComplete                  bool                                      `protobuf:"varint,23,opt,name=async_complete,json=asyncComplete,proto3" json:"async_complete,omitempty"`
	LoopCondition                  string                                    `protobuf:"bytes,24,opt,name=loop_condition,json=loopCondition,proto3" json:"loop_condition,omitempty"`
	LoopOver                       []*WorkflowTask                           `protobuf:"bytes,25,rep,name=loop_over,json=loopOver,proto3" json:"loop_over,omitempty"`
	XXX_NoUnkeyedLiteral           struct{}                                  `json:"-"`
	XXX_unrecognized               []byte                                    `json:"-"`
	XXX_sizecache                  int32                                     `json:"-"`
}

func (*WorkflowTask) Descriptor 

func (*WorkflowTask) Descriptor() ([]byte, []int)

func (*WorkflowTask) GetAsyncComplete 

func (m *WorkflowTask) GetAsyncComplete() bool

func (*WorkflowTask) GetCaseExpression 

func (m *WorkflowTask) GetCaseExpression() string

func (*WorkflowTask) GetCaseValueParam 

func (m *WorkflowTask) GetCaseValueParam() string

func (*WorkflowTask) GetDecisionCases 

func (m *WorkflowTask) GetDecisionCases() map[string]*WorkflowTask_WorkflowTaskList

func (*WorkflowTask) GetDefaultCase 

func (m *WorkflowTask) GetDefaultCase() []*WorkflowTask

func (*WorkflowTask) GetDefaultExclusiveJoinTask 

func (m *WorkflowTask) GetDefaultExclusiveJoinTask() []string

func (*WorkflowTask) GetDescription 

func (m *WorkflowTask) GetDescription() string

func (*WorkflowTask) GetDynamicForkTasksInputParamName 

func (m *WorkflowTask) GetDynamicForkTasksInputParamName() string

func (*WorkflowTask) GetDynamicForkTasksParam 

func (m *WorkflowTask) GetDynamicForkTasksParam() string

func (*WorkflowTask) GetDynamicTaskNameParam 

func (m *WorkflowTask) GetDynamicTaskNameParam() string

func (*WorkflowTask) GetForkTasks 

func (m *WorkflowTask) GetForkTasks() []*WorkflowTask_WorkflowTaskList

func (*WorkflowTask) GetInputParameters 

func (m *WorkflowTask) GetInputParameters() map[string]*any.Any

func (*WorkflowTask) GetJoinOn 

func (m *WorkflowTask) GetJoinOn() []string

func (*WorkflowTask) GetLoopCondition 

func (m *WorkflowTask) GetLoopCondition() string

func (*WorkflowTask) GetLoopOver 

func (m *WorkflowTask) GetLoopOver() []*WorkflowTask

func (*WorkflowTask) GetName 

func (m *WorkflowTask) GetName() string

func (*WorkflowTask) GetOptional 

func (m *WorkflowTask) GetOptional() bool

func (*WorkflowTask) GetRateLimited 

func (m *WorkflowTask) GetRateLimited() bool

func (*WorkflowTask) GetScriptExpression 

func (m *WorkflowTask) GetScriptExpression() string

func (*WorkflowTask) GetSink 

func (m *WorkflowTask) GetSink() string

func (*WorkflowTask) GetStartDelay 

func (m *WorkflowTask) GetStartDelay() int32

func (*WorkflowTask) GetSubWorkflowParam 

func (m *WorkflowTask) GetSubWorkflowParam() *SubWorkflowParams

func (*WorkflowTask) GetTaskDefinition 

func (m *WorkflowTask) GetTaskDefinition() *TaskDef

func (*WorkflowTask) GetTaskReferenceName 

func (m *WorkflowTask) GetTaskReferenceName() string

func (*WorkflowTask) GetType 

func (m *WorkflowTask) GetType() string

func (*WorkflowTask) ProtoMessage 

func (*WorkflowTask) ProtoMessage()

func (*WorkflowTask) Reset 

func (m *WorkflowTask) Reset()

func (*WorkflowTask) String 

func (m *WorkflowTask) String() string

func (*WorkflowTask) XXX_DiscardUnknown 

func (m *WorkflowTask) XXX_DiscardUnknown()

func (*WorkflowTask) XXX_Marshal 

func (m *WorkflowTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowTask) XXX_Merge 

func (dst *WorkflowTask) XXX_Merge(src proto.Message)

func (*WorkflowTask) XXX_Size 

func (m *WorkflowTask) XXX_Size() int

func (*WorkflowTask) XXX_Unmarshal 

func (m *WorkflowTask) XXX_Unmarshal(b []byte) error

type WorkflowTask_WorkflowTaskList 

type WorkflowTask_WorkflowTaskList struct {
	Tasks                []*WorkflowTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WorkflowTask_WorkflowTaskList) Descriptor 

func (*WorkflowTask_WorkflowTaskList) Descriptor() ([]byte, []int)

func (*WorkflowTask_WorkflowTaskList) GetTasks 

func (m *WorkflowTask_WorkflowTaskList) GetTasks() []*WorkflowTask

func (*WorkflowTask_WorkflowTaskList) ProtoMessage 

func (*WorkflowTask_WorkflowTaskList) ProtoMessage()

func (*WorkflowTask_WorkflowTaskList) Reset 

func (m *WorkflowTask_WorkflowTaskList) Reset()

func (*WorkflowTask_WorkflowTaskList) String 

func (m *WorkflowTask_WorkflowTaskList) String() string

func (*WorkflowTask_WorkflowTaskList) XXX_DiscardUnknown 

func (m *WorkflowTask_WorkflowTaskList) XXX_DiscardUnknown()

func (*WorkflowTask_WorkflowTaskList) XXX_Marshal 

func (m *WorkflowTask_WorkflowTaskList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowTask_WorkflowTaskList) XXX_Merge 

func (dst *WorkflowTask_WorkflowTaskList) XXX_Merge(src proto.Message)

func (*WorkflowTask_WorkflowTaskList) XXX_Size 

func (m *WorkflowTask_WorkflowTaskList) XXX_Size() int

func (*WorkflowTask_WorkflowTaskList) XXX_Unmarshal 

func (m *WorkflowTask_WorkflowTaskList) XXX_Unmarshal(b []byte) error

type Workflow_WorkflowStatus 

type Workflow_WorkflowStatus int32
const (
	Workflow_RUNNING    Workflow_WorkflowStatus = 0
	Workflow_COMPLETED  Workflow_WorkflowStatus = 1
	Workflow_FAILED     Workflow_WorkflowStatus = 2
	Workflow_TIMED_OUT  Workflow_WorkflowStatus = 3
	Workflow_TERMINATED Workflow_WorkflowStatus = 4
	Workflow_PAUSED     Workflow_WorkflowStatus = 5
)

func (Workflow_WorkflowStatus) EnumDescriptor 

func (Workflow_WorkflowStatus) EnumDescriptor() ([]byte, []int)

func (Workflow_WorkflowStatus) String 

func (x Workflow_WorkflowStatus) String() string

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.