Documentation ¶
Index ¶
- Variables
- type AddSearchAttributesResponse
- func (*AddSearchAttributesResponse) Descriptor() ([]byte, []int)
- func (this *AddSearchAttributesResponse) Equal(that interface{}) bool
- func (m *AddSearchAttributesResponse) GetAddWorkflowExecutionInfo() *WorkflowExecutionInfo
- func (m *AddSearchAttributesResponse) GetCustomSearchAttributes() map[string]string
- func (m *AddSearchAttributesResponse) GetIndexName() string
- func (m *AddSearchAttributesResponse) GetMapping() map[string]string
- func (m *AddSearchAttributesResponse) GetSystemSearchAttributes() map[string]string
- func (this *AddSearchAttributesResponse) GoString() string
- func (m *AddSearchAttributesResponse) Marshal() (dAtA []byte, err error)
- func (m *AddSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AddSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AddSearchAttributesResponse) ProtoMessage()
- func (m *AddSearchAttributesResponse) Reset()
- func (m *AddSearchAttributesResponse) Size() (n int)
- func (this *AddSearchAttributesResponse) String() string
- func (m *AddSearchAttributesResponse) Unmarshal(dAtA []byte) error
- func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()
- func (m *AddSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddSearchAttributesResponse) XXX_Merge(src proto.Message)
- func (m *AddSearchAttributesResponse) XXX_Size() int
- func (m *AddSearchAttributesResponse) XXX_Unmarshal(b []byte) error
- type DescribeWorkflowExecutionResponse
- func (*DescribeWorkflowExecutionResponse) Descriptor() ([]byte, []int)
- func (this *DescribeWorkflowExecutionResponse) Equal(that interface{}) bool
- func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v1.WorkflowExecutionConfig
- func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*PendingActivityInfo
- func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v1.PendingChildExecutionInfo
- func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v1.PendingWorkflowTaskInfo
- func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *WorkflowExecutionInfo
- func (this *DescribeWorkflowExecutionResponse) GoString() string
- func (m *DescribeWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)
- func (m *DescribeWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DescribeWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DescribeWorkflowExecutionResponse) ProtoMessage()
- func (m *DescribeWorkflowExecutionResponse) Reset()
- func (m *DescribeWorkflowExecutionResponse) Size() (n int)
- func (this *DescribeWorkflowExecutionResponse) String() string
- func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error
- func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()
- func (m *DescribeWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)
- func (m *DescribeWorkflowExecutionResponse) XXX_Size() int
- func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error
- type Failure
- func (*Failure) Descriptor() ([]byte, []int)
- func (this *Failure) Equal(that interface{}) bool
- func (m *Failure) GetCause() *Failure
- func (m *Failure) GetFailureType() string
- func (m *Failure) GetMessage() string
- func (m *Failure) GetSource() string
- func (m *Failure) GetStackTrace() string
- func (this *Failure) GoString() string
- func (m *Failure) Marshal() (dAtA []byte, err error)
- func (m *Failure) MarshalTo(dAtA []byte) (int, error)
- func (m *Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Failure) ProtoMessage()
- func (m *Failure) Reset()
- func (m *Failure) Size() (n int)
- func (this *Failure) String() string
- func (m *Failure) Unmarshal(dAtA []byte) error
- func (m *Failure) XXX_DiscardUnknown()
- func (m *Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Failure) XXX_Merge(src proto.Message)
- func (m *Failure) XXX_Size() int
- func (m *Failure) XXX_Unmarshal(b []byte) error
- type PendingActivityInfo
- func (*PendingActivityInfo) Descriptor() ([]byte, []int)
- func (this *PendingActivityInfo) Equal(that interface{}) bool
- func (m *PendingActivityInfo) GetActivityId() string
- func (m *PendingActivityInfo) GetActivityType() *v11.ActivityType
- func (m *PendingActivityInfo) GetAttempt() int32
- func (m *PendingActivityInfo) GetExpirationTime() *time.Time
- func (m *PendingActivityInfo) GetHeartbeatDetails() string
- func (m *PendingActivityInfo) GetLastFailure() *Failure
- func (m *PendingActivityInfo) GetLastHeartbeatTime() *time.Time
- func (m *PendingActivityInfo) GetLastStartedTime() *time.Time
- func (m *PendingActivityInfo) GetLastWorkerIdentity() string
- func (m *PendingActivityInfo) GetMaximumAttempts() int32
- func (m *PendingActivityInfo) GetScheduledTime() *time.Time
- func (m *PendingActivityInfo) GetState() v12.PendingActivityState
- func (this *PendingActivityInfo) GoString() string
- func (m *PendingActivityInfo) Marshal() (dAtA []byte, err error)
- func (m *PendingActivityInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *PendingActivityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PendingActivityInfo) ProtoMessage()
- func (m *PendingActivityInfo) Reset()
- func (m *PendingActivityInfo) Size() (n int)
- func (this *PendingActivityInfo) String() string
- func (m *PendingActivityInfo) Unmarshal(dAtA []byte) error
- func (m *PendingActivityInfo) XXX_DiscardUnknown()
- func (m *PendingActivityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PendingActivityInfo) XXX_Merge(src proto.Message)
- func (m *PendingActivityInfo) XXX_Size() int
- func (m *PendingActivityInfo) XXX_Unmarshal(b []byte) error
- type SearchAttributes
- func (*SearchAttributes) Descriptor() ([]byte, []int)
- func (this *SearchAttributes) Equal(that interface{}) bool
- func (m *SearchAttributes) GetIndexedFields() map[string]string
- func (this *SearchAttributes) GoString() string
- func (m *SearchAttributes) Marshal() (dAtA []byte, err error)
- func (m *SearchAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *SearchAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SearchAttributes) ProtoMessage()
- func (m *SearchAttributes) Reset()
- func (m *SearchAttributes) Size() (n int)
- func (this *SearchAttributes) String() string
- func (m *SearchAttributes) Unmarshal(dAtA []byte) error
- func (m *SearchAttributes) XXX_DiscardUnknown()
- func (m *SearchAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchAttributes) XXX_Merge(src proto.Message)
- func (m *SearchAttributes) XXX_Size() int
- func (m *SearchAttributes) XXX_Unmarshal(b []byte) error
- type WorkflowExecutionInfo
- func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)
- func (this *WorkflowExecutionInfo) Equal(that interface{}) bool
- func (m *WorkflowExecutionInfo) GetAutoResetPoints() *v1.ResetPoints
- func (m *WorkflowExecutionInfo) GetCloseTime() *time.Time
- func (m *WorkflowExecutionInfo) GetExecution() *v11.WorkflowExecution
- func (m *WorkflowExecutionInfo) GetExecutionTime() *time.Time
- func (m *WorkflowExecutionInfo) GetHistoryLength() int64
- func (m *WorkflowExecutionInfo) GetHistorySizeBytes() int64
- func (m *WorkflowExecutionInfo) GetMemo() *v11.Memo
- func (m *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v11.WorkerVersionStamp
- func (m *WorkflowExecutionInfo) GetParentExecution() *v11.WorkflowExecution
- func (m *WorkflowExecutionInfo) GetParentNamespaceId() string
- func (m *WorkflowExecutionInfo) GetSearchAttributes() *SearchAttributes
- func (m *WorkflowExecutionInfo) GetStartTime() *time.Time
- func (m *WorkflowExecutionInfo) GetStateTransitionCount() int64
- func (m *WorkflowExecutionInfo) GetStatus() v12.WorkflowExecutionStatus
- func (m *WorkflowExecutionInfo) GetType() *v11.WorkflowType
- func (this *WorkflowExecutionInfo) GoString() string
- func (m *WorkflowExecutionInfo) Marshal() (dAtA []byte, err error)
- func (m *WorkflowExecutionInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowExecutionInfo) ProtoMessage()
- func (m *WorkflowExecutionInfo) Reset()
- func (m *WorkflowExecutionInfo) Size() (n int)
- func (this *WorkflowExecutionInfo) String() string
- func (m *WorkflowExecutionInfo) Unmarshal(dAtA []byte) error
- func (m *WorkflowExecutionInfo) XXX_DiscardUnknown()
- func (m *WorkflowExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowExecutionInfo) XXX_Merge(src proto.Message)
- func (m *WorkflowExecutionInfo) XXX_Size() int
- func (m *WorkflowExecutionInfo) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type AddSearchAttributesResponse ¶ added in v1.12.0
type AddSearchAttributesResponse struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` CustomSearchAttributes map[string]string `` /* 217-byte string literal not displayed */ SystemSearchAttributes map[string]string `` /* 217-byte string literal not displayed */ Mapping map[string]string `` /* 155-byte string literal not displayed */ AddWorkflowExecutionInfo *WorkflowExecutionInfo `` /* 137-byte string literal not displayed */ }
func (*AddSearchAttributesResponse) Descriptor ¶ added in v1.12.0
func (*AddSearchAttributesResponse) Descriptor() ([]byte, []int)
func (*AddSearchAttributesResponse) Equal ¶ added in v1.12.0
func (this *AddSearchAttributesResponse) Equal(that interface{}) bool
func (*AddSearchAttributesResponse) GetAddWorkflowExecutionInfo ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) GetAddWorkflowExecutionInfo() *WorkflowExecutionInfo
func (*AddSearchAttributesResponse) GetCustomSearchAttributes ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) GetCustomSearchAttributes() map[string]string
func (*AddSearchAttributesResponse) GetIndexName ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) GetIndexName() string
func (*AddSearchAttributesResponse) GetMapping ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) GetMapping() map[string]string
func (*AddSearchAttributesResponse) GetSystemSearchAttributes ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) GetSystemSearchAttributes() map[string]string
func (*AddSearchAttributesResponse) GoString ¶ added in v1.12.0
func (this *AddSearchAttributesResponse) GoString() string
func (*AddSearchAttributesResponse) Marshal ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) Marshal() (dAtA []byte, err error)
func (*AddSearchAttributesResponse) MarshalTo ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)
func (*AddSearchAttributesResponse) MarshalToSizedBuffer ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AddSearchAttributesResponse) ProtoMessage ¶ added in v1.12.0
func (*AddSearchAttributesResponse) ProtoMessage()
func (*AddSearchAttributesResponse) Reset ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) Reset()
func (*AddSearchAttributesResponse) Size ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) Size() (n int)
func (*AddSearchAttributesResponse) String ¶ added in v1.12.0
func (this *AddSearchAttributesResponse) String() string
func (*AddSearchAttributesResponse) Unmarshal ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) Unmarshal(dAtA []byte) error
func (*AddSearchAttributesResponse) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()
func (*AddSearchAttributesResponse) XXX_Marshal ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddSearchAttributesResponse) XXX_Merge ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) XXX_Merge(src proto.Message)
func (*AddSearchAttributesResponse) XXX_Size ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) XXX_Size() int
func (*AddSearchAttributesResponse) XXX_Unmarshal ¶ added in v1.12.0
func (m *AddSearchAttributesResponse) XXX_Unmarshal(b []byte) error
type DescribeWorkflowExecutionResponse ¶
type DescribeWorkflowExecutionResponse struct { ExecutionConfig *v1.WorkflowExecutionConfig `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"` WorkflowExecutionInfo *WorkflowExecutionInfo `` /* 126-byte string literal not displayed */ PendingActivities []*PendingActivityInfo `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"` PendingChildren []*v1.PendingChildExecutionInfo `protobuf:"bytes,4,rep,name=pending_children,json=pendingChildren,proto3" json:"pending_children,omitempty"` PendingWorkflowTask *v1.PendingWorkflowTaskInfo `protobuf:"bytes,5,opt,name=pending_workflow_task,json=pendingWorkflowTask,proto3" json:"pending_workflow_task,omitempty"` }
func (*DescribeWorkflowExecutionResponse) Descriptor ¶
func (*DescribeWorkflowExecutionResponse) Descriptor() ([]byte, []int)
func (*DescribeWorkflowExecutionResponse) Equal ¶
func (this *DescribeWorkflowExecutionResponse) Equal(that interface{}) bool
func (*DescribeWorkflowExecutionResponse) GetExecutionConfig ¶
func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v1.WorkflowExecutionConfig
func (*DescribeWorkflowExecutionResponse) GetPendingActivities ¶
func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*PendingActivityInfo
func (*DescribeWorkflowExecutionResponse) GetPendingChildren ¶
func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v1.PendingChildExecutionInfo
func (*DescribeWorkflowExecutionResponse) GetPendingWorkflowTask ¶ added in v1.15.0
func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v1.PendingWorkflowTaskInfo
func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo ¶
func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *WorkflowExecutionInfo
func (*DescribeWorkflowExecutionResponse) GoString ¶
func (this *DescribeWorkflowExecutionResponse) GoString() string
func (*DescribeWorkflowExecutionResponse) Marshal ¶
func (m *DescribeWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)
func (*DescribeWorkflowExecutionResponse) MarshalTo ¶
func (m *DescribeWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)
func (*DescribeWorkflowExecutionResponse) MarshalToSizedBuffer ¶
func (m *DescribeWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DescribeWorkflowExecutionResponse) ProtoMessage ¶
func (*DescribeWorkflowExecutionResponse) ProtoMessage()
func (*DescribeWorkflowExecutionResponse) Reset ¶
func (m *DescribeWorkflowExecutionResponse) Reset()
func (*DescribeWorkflowExecutionResponse) Size ¶
func (m *DescribeWorkflowExecutionResponse) Size() (n int)
func (*DescribeWorkflowExecutionResponse) String ¶
func (this *DescribeWorkflowExecutionResponse) String() string
func (*DescribeWorkflowExecutionResponse) Unmarshal ¶
func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error
func (*DescribeWorkflowExecutionResponse) XXX_DiscardUnknown ¶
func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()
func (*DescribeWorkflowExecutionResponse) XXX_Marshal ¶
func (m *DescribeWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DescribeWorkflowExecutionResponse) XXX_Merge ¶
func (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)
func (*DescribeWorkflowExecutionResponse) XXX_Size ¶
func (m *DescribeWorkflowExecutionResponse) XXX_Size() int
func (*DescribeWorkflowExecutionResponse) XXX_Unmarshal ¶
func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error
type Failure ¶ added in v0.28.0
type Failure struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` StackTrace string `protobuf:"bytes,3,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"` Cause *Failure `protobuf:"bytes,4,opt,name=cause,proto3" json:"cause,omitempty"` FailureType string `protobuf:"bytes,5,opt,name=failure_type,json=failureType,proto3" json:"failure_type,omitempty"` }
func (*Failure) Descriptor ¶ added in v0.28.0
func (*Failure) GetFailureType ¶ added in v0.28.0
func (*Failure) GetMessage ¶ added in v0.28.0
func (*Failure) GetStackTrace ¶ added in v0.28.0
func (*Failure) MarshalToSizedBuffer ¶ added in v0.28.0
func (*Failure) ProtoMessage ¶ added in v0.28.0
func (*Failure) ProtoMessage()
func (*Failure) XXX_DiscardUnknown ¶ added in v0.28.0
func (m *Failure) XXX_DiscardUnknown()
func (*Failure) XXX_Marshal ¶ added in v0.28.0
func (*Failure) XXX_Unmarshal ¶ added in v0.28.0
type PendingActivityInfo ¶
type PendingActivityInfo struct { ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"` ActivityType *v11.ActivityType `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"` State v12.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"state,omitempty"` HeartbeatDetails string `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 *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() *v11.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() string
func (*PendingActivityInfo) GetLastFailure ¶
func (m *PendingActivityInfo) GetLastFailure() *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() v12.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 SearchAttributes ¶
type SearchAttributes struct {
IndexedFields map[string]string `` /* 188-byte string literal not displayed */
}
func (*SearchAttributes) Descriptor ¶
func (*SearchAttributes) Descriptor() ([]byte, []int)
func (*SearchAttributes) Equal ¶
func (this *SearchAttributes) Equal(that interface{}) bool
func (*SearchAttributes) GetIndexedFields ¶
func (m *SearchAttributes) GetIndexedFields() map[string]string
func (*SearchAttributes) GoString ¶
func (this *SearchAttributes) GoString() string
func (*SearchAttributes) Marshal ¶
func (m *SearchAttributes) Marshal() (dAtA []byte, err error)
func (*SearchAttributes) MarshalToSizedBuffer ¶
func (m *SearchAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SearchAttributes) ProtoMessage ¶
func (*SearchAttributes) ProtoMessage()
func (*SearchAttributes) Reset ¶
func (m *SearchAttributes) Reset()
func (*SearchAttributes) Size ¶
func (m *SearchAttributes) Size() (n int)
func (*SearchAttributes) String ¶
func (this *SearchAttributes) String() string
func (*SearchAttributes) Unmarshal ¶
func (m *SearchAttributes) Unmarshal(dAtA []byte) error
func (*SearchAttributes) XXX_DiscardUnknown ¶
func (m *SearchAttributes) XXX_DiscardUnknown()
func (*SearchAttributes) XXX_Marshal ¶
func (m *SearchAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchAttributes) XXX_Merge ¶
func (m *SearchAttributes) XXX_Merge(src proto.Message)
func (*SearchAttributes) XXX_Size ¶
func (m *SearchAttributes) XXX_Size() int
func (*SearchAttributes) XXX_Unmarshal ¶
func (m *SearchAttributes) XXX_Unmarshal(b []byte) error
type WorkflowExecutionInfo ¶
type WorkflowExecutionInfo struct { Execution *v11.WorkflowExecution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"` Type *v11.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 v12.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 *v11.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 *v11.Memo `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *SearchAttributes `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` AutoResetPoints *v1.ResetPoints `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"` StateTransitionCount int64 `protobuf:"varint,13,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"` HistorySizeBytes int64 `protobuf:"varint,14,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"` MostRecentWorkerVersionStamp *v11.WorkerVersionStamp `` /* 152-byte string literal not displayed */ }
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() *v1.ResetPoints
func (*WorkflowExecutionInfo) GetCloseTime ¶
func (m *WorkflowExecutionInfo) GetCloseTime() *time.Time
func (*WorkflowExecutionInfo) GetExecution ¶
func (m *WorkflowExecutionInfo) GetExecution() *v11.WorkflowExecution
func (*WorkflowExecutionInfo) GetExecutionTime ¶
func (m *WorkflowExecutionInfo) GetExecutionTime() *time.Time
func (*WorkflowExecutionInfo) GetHistoryLength ¶
func (m *WorkflowExecutionInfo) GetHistoryLength() int64
func (*WorkflowExecutionInfo) GetHistorySizeBytes ¶ added in v1.20.0
func (m *WorkflowExecutionInfo) GetHistorySizeBytes() int64
func (*WorkflowExecutionInfo) GetMemo ¶
func (m *WorkflowExecutionInfo) GetMemo() *v11.Memo
func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp ¶ added in v1.21.0
func (m *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v11.WorkerVersionStamp
func (*WorkflowExecutionInfo) GetParentExecution ¶
func (m *WorkflowExecutionInfo) GetParentExecution() *v11.WorkflowExecution
func (*WorkflowExecutionInfo) GetParentNamespaceId ¶
func (m *WorkflowExecutionInfo) GetParentNamespaceId() string
func (*WorkflowExecutionInfo) GetSearchAttributes ¶
func (m *WorkflowExecutionInfo) GetSearchAttributes() *SearchAttributes
func (*WorkflowExecutionInfo) GetStartTime ¶
func (m *WorkflowExecutionInfo) GetStartTime() *time.Time
func (*WorkflowExecutionInfo) GetStateTransitionCount ¶ added in v1.10.0
func (m *WorkflowExecutionInfo) GetStateTransitionCount() int64
func (*WorkflowExecutionInfo) GetStatus ¶
func (m *WorkflowExecutionInfo) GetStatus() v12.WorkflowExecutionStatus
func (*WorkflowExecutionInfo) GetType ¶
func (m *WorkflowExecutionInfo) GetType() *v11.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
Click to show internal directories.
Click to hide internal directories.