workflow

package
v1.18.1 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 License: MIT Imports: 14 Imported by: 53

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type NewWorkflowExecutionInfo added in v1.8.0 

type NewWorkflowExecutionInfo struct {
	WorkflowId   string           `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v1.WorkflowType `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v12.TaskQueue   `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Serialized arguments to the workflow.
	Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *time.Duration `` /* 132-byte string literal not displayed */
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 178-byte string literal not displayed */
	// The retry policy for the workflow. Will never exceed `workflow_execution_timeout`.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,9,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// See https://docs.temporal.io/docs/content/what-is-a-temporal-cron-job/
	CronSchedule     string               `protobuf:"bytes,10,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v1.Memo             `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,12,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v1.Header           `protobuf:"bytes,13,opt,name=header,proto3" json:"header,omitempty"`
}

NewWorkflowExecutionInfo is a shared message that encapsulates all the required arguments to starting a workflow in different contexts.

func (*NewWorkflowExecutionInfo) Descriptor added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) Equal added in v1.8.0 

func (this *NewWorkflowExecutionInfo) Equal(that interface{}) bool

func (*NewWorkflowExecutionInfo) GetCronSchedule added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetCronSchedule() string

func (*NewWorkflowExecutionInfo) GetHeader added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetHeader() *v1.Header

func (*NewWorkflowExecutionInfo) GetInput added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetInput() *v1.Payloads

func (*NewWorkflowExecutionInfo) GetMemo added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetMemo() *v1.Memo

func (*NewWorkflowExecutionInfo) GetRetryPolicy added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetRetryPolicy() *v1.RetryPolicy

func (*NewWorkflowExecutionInfo) GetSearchAttributes added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes

func (*NewWorkflowExecutionInfo) GetTaskQueue added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetTaskQueue() *v12.TaskQueue

func (*NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout() *time.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowId added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowId() string

func (*NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*NewWorkflowExecutionInfo) GetWorkflowRunTimeout added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowRunTimeout() *time.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowTaskTimeout added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowTaskTimeout() *time.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowType added in v1.8.0 

func (m *NewWorkflowExecutionInfo) GetWorkflowType() *v1.WorkflowType

func (*NewWorkflowExecutionInfo) GoString added in v1.8.0 

func (this *NewWorkflowExecutionInfo) GoString() string

func (*NewWorkflowExecutionInfo) Marshal added in v1.8.0 

func (m *NewWorkflowExecutionInfo) Marshal() (dAtA []byte, err error)

func (*NewWorkflowExecutionInfo) MarshalTo added in v1.8.0 

func (m *NewWorkflowExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*NewWorkflowExecutionInfo) MarshalToSizedBuffer added in v1.8.0 

func (m *NewWorkflowExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NewWorkflowExecutionInfo) ProtoMessage added in v1.8.0 

func (*NewWorkflowExecutionInfo) ProtoMessage()

func (*NewWorkflowExecutionInfo) Reset added in v1.8.0 

func (m *NewWorkflowExecutionInfo) Reset()

func (*NewWorkflowExecutionInfo) Size added in v1.8.0 

func (m *NewWorkflowExecutionInfo) Size() (n int)

func (*NewWorkflowExecutionInfo) String added in v1.8.0 

func (this *NewWorkflowExecutionInfo) String() string

func (*NewWorkflowExecutionInfo) Unmarshal added in v1.8.0 

func (m *NewWorkflowExecutionInfo) Unmarshal(dAtA []byte) error

func (*NewWorkflowExecutionInfo) XXX_DiscardUnknown added in v1.8.0 

func (m *NewWorkflowExecutionInfo) XXX_DiscardUnknown()

func (*NewWorkflowExecutionInfo) XXX_Marshal added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) XXX_Merge added in v1.8.0 

func (m *NewWorkflowExecutionInfo) XXX_Merge(src proto.Message)

func (*NewWorkflowExecutionInfo) XXX_Size added in v1.8.0 

func (m *NewWorkflowExecutionInfo) XXX_Size() int

func (*NewWorkflowExecutionInfo) XXX_Unmarshal added in v1.8.0 

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

type PendingActivityInfo 

type PendingActivityInfo struct {
	ActivityId         string                   `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType       *v1.ActivityType         `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	State              v11.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"state,omitempty"`
	HeartbeatDetails   *v1.Payloads             `protobuf:"bytes,4,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	LastHeartbeatTime  *time.Time               `protobuf:"bytes,5,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"last_heartbeat_time,omitempty"`
	LastStartedTime    *time.Time               `protobuf:"bytes,6,opt,name=last_started_time,json=lastStartedTime,proto3,stdtime" json:"last_started_time,omitempty"`
	Attempt            int32                    `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaximumAttempts    int32                    `protobuf:"varint,8,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	ScheduledTime      *time.Time               `protobuf:"bytes,9,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	ExpirationTime     *time.Time               `protobuf:"bytes,10,opt,name=expiration_time,json=expirationTime,proto3,stdtime" json:"expiration_time,omitempty"`
	LastFailure        *v13.Failure             `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string                   `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
}

func (*PendingActivityInfo) Descriptor 

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

func (*PendingActivityInfo) Equal 

func (this *PendingActivityInfo) Equal(that interface{}) bool

func (*PendingActivityInfo) GetActivityId 

func (m *PendingActivityInfo) GetActivityId() string

func (*PendingActivityInfo) GetActivityType 

func (m *PendingActivityInfo) GetActivityType() *v1.ActivityType

func (*PendingActivityInfo) GetAttempt 

func (m *PendingActivityInfo) GetAttempt() int32

func (*PendingActivityInfo) GetExpirationTime added in v0.28.0 

func (m *PendingActivityInfo) GetExpirationTime() *time.Time

func (*PendingActivityInfo) GetHeartbeatDetails 

func (m *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads

func (*PendingActivityInfo) GetLastFailure 

func (m *PendingActivityInfo) GetLastFailure() *v13.Failure

func (*PendingActivityInfo) GetLastHeartbeatTime added in v0.28.0 

func (m *PendingActivityInfo) GetLastHeartbeatTime() *time.Time

func (*PendingActivityInfo) GetLastStartedTime added in v0.28.0 

func (m *PendingActivityInfo) GetLastStartedTime() *time.Time

func (*PendingActivityInfo) GetLastWorkerIdentity 

func (m *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetMaximumAttempts 

func (m *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetScheduledTime added in v0.28.0 

func (m *PendingActivityInfo) GetScheduledTime() *time.Time

func (*PendingActivityInfo) GetState 

func (m *PendingActivityInfo) GetState() v11.PendingActivityState

func (*PendingActivityInfo) GoString 

func (this *PendingActivityInfo) GoString() string

func (*PendingActivityInfo) Marshal 

func (m *PendingActivityInfo) Marshal() (dAtA []byte, err error)

func (*PendingActivityInfo) MarshalTo 

func (m *PendingActivityInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingActivityInfo) MarshalToSizedBuffer 

func (m *PendingActivityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingActivityInfo) ProtoMessage 

func (*PendingActivityInfo) ProtoMessage()

func (*PendingActivityInfo) Reset 

func (m *PendingActivityInfo) Reset()

func (*PendingActivityInfo) Size 

func (m *PendingActivityInfo) Size() (n int)

func (*PendingActivityInfo) String 

func (this *PendingActivityInfo) String() string

func (*PendingActivityInfo) Unmarshal 

func (m *PendingActivityInfo) Unmarshal(dAtA []byte) error

func (*PendingActivityInfo) XXX_DiscardUnknown 

func (m *PendingActivityInfo) XXX_DiscardUnknown()

func (*PendingActivityInfo) XXX_Marshal 

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

func (*PendingActivityInfo) XXX_Merge 

func (m *PendingActivityInfo) XXX_Merge(src proto.Message)

func (*PendingActivityInfo) XXX_Size 

func (m *PendingActivityInfo) XXX_Size() int

func (*PendingActivityInfo) XXX_Unmarshal 

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

type PendingChildExecutionInfo 

type PendingChildExecutionInfo struct {
	WorkflowId       string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId            string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowTypeName string `protobuf:"bytes,3,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	InitiatedId      int64  `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	// Default: PARENT_CLOSE_POLICY_TERMINATE.
	ParentClosePolicy v11.ParentClosePolicy `` /* 160-byte string literal not displayed */
}

func (*PendingChildExecutionInfo) Descriptor 

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

func (*PendingChildExecutionInfo) Equal 

func (this *PendingChildExecutionInfo) Equal(that interface{}) bool

func (*PendingChildExecutionInfo) GetInitiatedId 

func (m *PendingChildExecutionInfo) GetInitiatedId() int64

func (*PendingChildExecutionInfo) GetParentClosePolicy 

func (m *PendingChildExecutionInfo) GetParentClosePolicy() v11.ParentClosePolicy

func (*PendingChildExecutionInfo) GetRunId 

func (m *PendingChildExecutionInfo) GetRunId() string

func (*PendingChildExecutionInfo) GetWorkflowId 

func (m *PendingChildExecutionInfo) GetWorkflowId() string

func (*PendingChildExecutionInfo) GetWorkflowTypeName 

func (m *PendingChildExecutionInfo) GetWorkflowTypeName() string

func (*PendingChildExecutionInfo) GoString 

func (this *PendingChildExecutionInfo) GoString() string

func (*PendingChildExecutionInfo) Marshal 

func (m *PendingChildExecutionInfo) Marshal() (dAtA []byte, err error)

func (*PendingChildExecutionInfo) MarshalTo 

func (m *PendingChildExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingChildExecutionInfo) MarshalToSizedBuffer 

func (m *PendingChildExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingChildExecutionInfo) ProtoMessage 

func (*PendingChildExecutionInfo) ProtoMessage()

func (*PendingChildExecutionInfo) Reset 

func (m *PendingChildExecutionInfo) Reset()

func (*PendingChildExecutionInfo) Size 

func (m *PendingChildExecutionInfo) Size() (n int)

func (*PendingChildExecutionInfo) String 

func (this *PendingChildExecutionInfo) String() string

func (*PendingChildExecutionInfo) Unmarshal 

func (m *PendingChildExecutionInfo) Unmarshal(dAtA []byte) error

func (*PendingChildExecutionInfo) XXX_DiscardUnknown 

func (m *PendingChildExecutionInfo) XXX_DiscardUnknown()

func (*PendingChildExecutionInfo) XXX_Marshal 

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

func (*PendingChildExecutionInfo) XXX_Merge 

func (m *PendingChildExecutionInfo) XXX_Merge(src proto.Message)

func (*PendingChildExecutionInfo) XXX_Size 

func (m *PendingChildExecutionInfo) XXX_Size() int

func (*PendingChildExecutionInfo) XXX_Unmarshal 

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

type PendingWorkflowTaskInfo added in v1.8.0 

type PendingWorkflowTaskInfo struct {
	State         v11.PendingWorkflowTaskState `protobuf:"varint,1,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingWorkflowTaskState" json:"state,omitempty"`
	ScheduledTime *time.Time                   `protobuf:"bytes,2,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	// original_scheduled_time is the scheduled time of the first workflow task during workflow task heartbeat.
	// Heartbeat workflow task is done by RespondWorkflowTaskComplete with ForceCreateNewWorkflowTask == true and no command
	// In this case, OriginalScheduledTime won't change. Then when current time - original_scheduled_time exceeds
	// some threshold, the workflow task will be forced timeout.
	OriginalScheduledTime *time.Time `` /* 134-byte string literal not displayed */
	StartedTime           *time.Time `protobuf:"bytes,4,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	Attempt               int32      `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
}

func (*PendingWorkflowTaskInfo) Descriptor added in v1.8.0 

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

func (*PendingWorkflowTaskInfo) Equal added in v1.8.0 

func (this *PendingWorkflowTaskInfo) Equal(that interface{}) bool

func (*PendingWorkflowTaskInfo) GetAttempt added in v1.8.0 

func (m *PendingWorkflowTaskInfo) GetAttempt() int32

func (*PendingWorkflowTaskInfo) GetOriginalScheduledTime added in v1.8.0 

func (m *PendingWorkflowTaskInfo) GetOriginalScheduledTime() *time.Time

func (*PendingWorkflowTaskInfo) GetScheduledTime added in v1.8.0 

func (m *PendingWorkflowTaskInfo) GetScheduledTime() *time.Time

func (*PendingWorkflowTaskInfo) GetStartedTime added in v1.8.0 

func (m *PendingWorkflowTaskInfo) GetStartedTime() *time.Time

func (*PendingWorkflowTaskInfo) GetState added in v1.8.0 

func (m *PendingWorkflowTaskInfo) GetState() v11.PendingWorkflowTaskState

func (*PendingWorkflowTaskInfo) GoString added in v1.8.0 

func (this *PendingWorkflowTaskInfo) GoString() string

func (*PendingWorkflowTaskInfo) Marshal added in v1.8.0 

func (m *PendingWorkflowTaskInfo) Marshal() (dAtA []byte, err error)

func (*PendingWorkflowTaskInfo) MarshalTo added in v1.8.0 

func (m *PendingWorkflowTaskInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingWorkflowTaskInfo) MarshalToSizedBuffer added in v1.8.0 

func (m *PendingWorkflowTaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingWorkflowTaskInfo) ProtoMessage added in v1.8.0 

func (*PendingWorkflowTaskInfo) ProtoMessage()

func (*PendingWorkflowTaskInfo) Reset added in v1.8.0 

func (m *PendingWorkflowTaskInfo) Reset()

func (*PendingWorkflowTaskInfo) Size added in v1.8.0 

func (m *PendingWorkflowTaskInfo) Size() (n int)

func (*PendingWorkflowTaskInfo) String added in v1.8.0 

func (this *PendingWorkflowTaskInfo) String() string

func (*PendingWorkflowTaskInfo) Unmarshal added in v1.8.0 

func (m *PendingWorkflowTaskInfo) Unmarshal(dAtA []byte) error

func (*PendingWorkflowTaskInfo) XXX_DiscardUnknown added in v1.8.0 

func (m *PendingWorkflowTaskInfo) XXX_DiscardUnknown()

func (*PendingWorkflowTaskInfo) XXX_Marshal added in v1.8.0 

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

func (*PendingWorkflowTaskInfo) XXX_Merge added in v1.8.0 

func (m *PendingWorkflowTaskInfo) XXX_Merge(src proto.Message)

func (*PendingWorkflowTaskInfo) XXX_Size added in v1.8.0 

func (m *PendingWorkflowTaskInfo) XXX_Size() int

func (*PendingWorkflowTaskInfo) XXX_Unmarshal added in v1.8.0 

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

type ResetPointInfo 

type ResetPointInfo struct {
	BinaryChecksum               string     `protobuf:"bytes,1,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	RunId                        string     `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	FirstWorkflowTaskCompletedId int64      `` /* 152-byte string literal not displayed */
	CreateTime                   *time.Time `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3,stdtime" json:"create_time,omitempty"`
	// (-- api-linter: core::0214::resource-expiry=disabled
	//     aip.dev/not-precedent: TTL is not defined for ResetPointInfo. --)
	// The time that the run is deleted due to retention.
	ExpireTime *time.Time `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3,stdtime" json:"expire_time,omitempty"`
	// false if the reset point has pending childWFs/reqCancels/signalExternals.
	Resettable bool `protobuf:"varint,6,opt,name=resettable,proto3" json:"resettable,omitempty"`
}

func (*ResetPointInfo) Descriptor 

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

func (*ResetPointInfo) Equal 

func (this *ResetPointInfo) Equal(that interface{}) bool

func (*ResetPointInfo) GetBinaryChecksum 

func (m *ResetPointInfo) GetBinaryChecksum() string

func (*ResetPointInfo) GetCreateTime added in v0.28.0 

func (m *ResetPointInfo) GetCreateTime() *time.Time

func (*ResetPointInfo) GetExpireTime added in v0.28.0 

func (m *ResetPointInfo) GetExpireTime() *time.Time

func (*ResetPointInfo) GetFirstWorkflowTaskCompletedId 

func (m *ResetPointInfo) GetFirstWorkflowTaskCompletedId() int64

func (*ResetPointInfo) GetResettable 

func (m *ResetPointInfo) GetResettable() bool

func (*ResetPointInfo) GetRunId 

func (m *ResetPointInfo) GetRunId() string

func (*ResetPointInfo) GoString 

func (this *ResetPointInfo) GoString() string

func (*ResetPointInfo) Marshal 

func (m *ResetPointInfo) Marshal() (dAtA []byte, err error)

func (*ResetPointInfo) MarshalTo 

func (m *ResetPointInfo) MarshalTo(dAtA []byte) (int, error)

func (*ResetPointInfo) MarshalToSizedBuffer 

func (m *ResetPointInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetPointInfo) ProtoMessage 

func (*ResetPointInfo) ProtoMessage()

func (*ResetPointInfo) Reset 

func (m *ResetPointInfo) Reset()

func (*ResetPointInfo) Size 

func (m *ResetPointInfo) Size() (n int)

func (*ResetPointInfo) String 

func (this *ResetPointInfo) String() string

func (*ResetPointInfo) Unmarshal 

func (m *ResetPointInfo) Unmarshal(dAtA []byte) error

func (*ResetPointInfo) XXX_DiscardUnknown 

func (m *ResetPointInfo) XXX_DiscardUnknown()

func (*ResetPointInfo) XXX_Marshal 

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

func (*ResetPointInfo) XXX_Merge 

func (m *ResetPointInfo) XXX_Merge(src proto.Message)

func (*ResetPointInfo) XXX_Size 

func (m *ResetPointInfo) XXX_Size() int

func (*ResetPointInfo) XXX_Unmarshal 

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

type ResetPoints 

type ResetPoints struct {
	Points []*ResetPointInfo `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
}

func (*ResetPoints) Descriptor 

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

func (*ResetPoints) Equal 

func (this *ResetPoints) Equal(that interface{}) bool

func (*ResetPoints) GetPoints 

func (m *ResetPoints) GetPoints() []*ResetPointInfo

func (*ResetPoints) GoString 

func (this *ResetPoints) GoString() string

func (*ResetPoints) Marshal 

func (m *ResetPoints) Marshal() (dAtA []byte, err error)

func (*ResetPoints) MarshalTo 

func (m *ResetPoints) MarshalTo(dAtA []byte) (int, error)

func (*ResetPoints) MarshalToSizedBuffer 

func (m *ResetPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetPoints) ProtoMessage 

func (*ResetPoints) ProtoMessage()

func (*ResetPoints) Reset 

func (m *ResetPoints) Reset()

func (*ResetPoints) Size 

func (m *ResetPoints) Size() (n int)

func (*ResetPoints) String 

func (this *ResetPoints) String() string

func (*ResetPoints) Unmarshal 

func (m *ResetPoints) Unmarshal(dAtA []byte) error

func (*ResetPoints) XXX_DiscardUnknown 

func (m *ResetPoints) XXX_DiscardUnknown()

func (*ResetPoints) XXX_Marshal 

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

func (*ResetPoints) XXX_Merge 

func (m *ResetPoints) XXX_Merge(src proto.Message)

func (*ResetPoints) XXX_Size 

func (m *ResetPoints) XXX_Size() int

func (*ResetPoints) XXX_Unmarshal 

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

type WorkflowExecutionConfig 

type WorkflowExecutionConfig struct {
	TaskQueue                  *v12.TaskQueue `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowExecutionTimeout   *time.Duration `` /* 147-byte string literal not displayed */
	WorkflowRunTimeout         *time.Duration `` /* 129-byte string literal not displayed */
	DefaultWorkflowTaskTimeout *time.Duration `` /* 155-byte string literal not displayed */
}

func (*WorkflowExecutionConfig) Descriptor 

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

func (*WorkflowExecutionConfig) Equal 

func (this *WorkflowExecutionConfig) Equal(that interface{}) bool

func (*WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout added in v0.28.0 

func (m *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *time.Duration

func (*WorkflowExecutionConfig) GetTaskQueue 

func (m *WorkflowExecutionConfig) GetTaskQueue() *v12.TaskQueue

func (*WorkflowExecutionConfig) GetWorkflowExecutionTimeout added in v0.28.0 

func (m *WorkflowExecutionConfig) GetWorkflowExecutionTimeout() *time.Duration

func (*WorkflowExecutionConfig) GetWorkflowRunTimeout added in v0.28.0 

func (m *WorkflowExecutionConfig) GetWorkflowRunTimeout() *time.Duration

func (*WorkflowExecutionConfig) GoString 

func (this *WorkflowExecutionConfig) GoString() string

func (*WorkflowExecutionConfig) Marshal 

func (m *WorkflowExecutionConfig) Marshal() (dAtA []byte, err error)

func (*WorkflowExecutionConfig) MarshalTo 

func (m *WorkflowExecutionConfig) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecutionConfig) MarshalToSizedBuffer 

func (m *WorkflowExecutionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecutionConfig) ProtoMessage 

func (*WorkflowExecutionConfig) ProtoMessage()

func (*WorkflowExecutionConfig) Reset 

func (m *WorkflowExecutionConfig) Reset()

func (*WorkflowExecutionConfig) Size 

func (m *WorkflowExecutionConfig) Size() (n int)

func (*WorkflowExecutionConfig) String 

func (this *WorkflowExecutionConfig) String() string

func (*WorkflowExecutionConfig) Unmarshal 

func (m *WorkflowExecutionConfig) Unmarshal(dAtA []byte) error

func (*WorkflowExecutionConfig) XXX_DiscardUnknown 

func (m *WorkflowExecutionConfig) XXX_DiscardUnknown()

func (*WorkflowExecutionConfig) XXX_Marshal 

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

func (*WorkflowExecutionConfig) XXX_Merge 

func (m *WorkflowExecutionConfig) XXX_Merge(src proto.Message)

func (*WorkflowExecutionConfig) XXX_Size 

func (m *WorkflowExecutionConfig) XXX_Size() int

func (*WorkflowExecutionConfig) XXX_Unmarshal 

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

type WorkflowExecutionInfo 

type WorkflowExecutionInfo struct {
	Execution            *v1.WorkflowExecution       `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Type                 *v1.WorkflowType            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StartTime            *time.Time                  `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	CloseTime            *time.Time                  `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
	Status               v11.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength        int64                       `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	ParentNamespaceId    string                      `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentExecution      *v1.WorkflowExecution       `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ExecutionTime        *time.Time                  `protobuf:"bytes,9,opt,name=execution_time,json=executionTime,proto3,stdtime" json:"execution_time,omitempty"`
	Memo                 *v1.Memo                    `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes     *v1.SearchAttributes        `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	AutoResetPoints      *ResetPoints                `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	TaskQueue            string                      `protobuf:"bytes,13,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StateTransitionCount int64                       `protobuf:"varint,14,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	HistorySizeBytes     int64                       `protobuf:"varint,15,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"`
}

func (*WorkflowExecutionInfo) Descriptor 

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

func (*WorkflowExecutionInfo) Equal 

func (this *WorkflowExecutionInfo) Equal(that interface{}) bool

func (*WorkflowExecutionInfo) GetAutoResetPoints 

func (m *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints

func (*WorkflowExecutionInfo) GetCloseTime 

func (m *WorkflowExecutionInfo) GetCloseTime() *time.Time

func (*WorkflowExecutionInfo) GetExecution 

func (m *WorkflowExecutionInfo) GetExecution() *v1.WorkflowExecution

func (*WorkflowExecutionInfo) GetExecutionTime 

func (m *WorkflowExecutionInfo) GetExecutionTime() *time.Time

func (*WorkflowExecutionInfo) GetHistoryLength 

func (m *WorkflowExecutionInfo) GetHistoryLength() int64

func (*WorkflowExecutionInfo) GetHistorySizeBytes added in v1.13.0 

func (m *WorkflowExecutionInfo) GetHistorySizeBytes() int64

func (*WorkflowExecutionInfo) GetMemo 

func (m *WorkflowExecutionInfo) GetMemo() *v1.Memo

func (*WorkflowExecutionInfo) GetParentExecution 

func (m *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution

func (*WorkflowExecutionInfo) GetParentNamespaceId 

func (m *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetSearchAttributes 

func (m *WorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes

func (*WorkflowExecutionInfo) GetStartTime 

func (m *WorkflowExecutionInfo) GetStartTime() *time.Time

func (*WorkflowExecutionInfo) GetStateTransitionCount added in v1.5.0 

func (m *WorkflowExecutionInfo) GetStateTransitionCount() int64

func (*WorkflowExecutionInfo) GetStatus 

func (m *WorkflowExecutionInfo) GetStatus() v11.WorkflowExecutionStatus

func (*WorkflowExecutionInfo) GetTaskQueue 

func (m *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetType 

func (m *WorkflowExecutionInfo) GetType() *v1.WorkflowType

func (*WorkflowExecutionInfo) GoString 

func (this *WorkflowExecutionInfo) GoString() string

func (*WorkflowExecutionInfo) Marshal 

func (m *WorkflowExecutionInfo) Marshal() (dAtA []byte, err error)

func (*WorkflowExecutionInfo) MarshalTo 

func (m *WorkflowExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) MarshalToSizedBuffer 

func (m *WorkflowExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) ProtoMessage 

func (*WorkflowExecutionInfo) ProtoMessage()

func (*WorkflowExecutionInfo) Reset 

func (m *WorkflowExecutionInfo) Reset()

func (*WorkflowExecutionInfo) Size 

func (m *WorkflowExecutionInfo) Size() (n int)

func (*WorkflowExecutionInfo) String 

func (this *WorkflowExecutionInfo) String() string

func (*WorkflowExecutionInfo) Unmarshal 

func (m *WorkflowExecutionInfo) Unmarshal(dAtA []byte) error

func (*WorkflowExecutionInfo) XXX_DiscardUnknown 

func (m *WorkflowExecutionInfo) XXX_DiscardUnknown()

func (*WorkflowExecutionInfo) XXX_Marshal 

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

func (*WorkflowExecutionInfo) XXX_Merge 

func (m *WorkflowExecutionInfo) XXX_Merge(src proto.Message)

func (*WorkflowExecutionInfo) XXX_Size 

func (m *WorkflowExecutionInfo) XXX_Size() int

func (*WorkflowExecutionInfo) XXX_Unmarshal 

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

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.