Documentation ¶
Index ¶
- Variables
- type HistoryContinuation
- func (*HistoryContinuation) Descriptor() ([]byte, []int)
- func (this *HistoryContinuation) Equal(that interface{}) bool
- func (m *HistoryContinuation) GetBranchToken() []byte
- func (m *HistoryContinuation) GetFirstEventId() int64
- func (m *HistoryContinuation) GetIsWorkflowRunning() bool
- func (m *HistoryContinuation) GetNextEventId() int64
- func (m *HistoryContinuation) GetPersistenceToken() []byte
- func (m *HistoryContinuation) GetRunId() string
- func (m *HistoryContinuation) GetTransientWorkflowTask() *v1.TransientWorkflowTaskInfo
- func (m *HistoryContinuation) GetVersionHistoryItem() *v1.VersionHistoryItem
- func (this *HistoryContinuation) GoString() string
- func (m *HistoryContinuation) Marshal() (dAtA []byte, err error)
- func (m *HistoryContinuation) MarshalTo(dAtA []byte) (int, error)
- func (m *HistoryContinuation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HistoryContinuation) ProtoMessage()
- func (m *HistoryContinuation) Reset()
- func (m *HistoryContinuation) Size() (n int)
- func (this *HistoryContinuation) String() string
- func (m *HistoryContinuation) Unmarshal(dAtA []byte) error
- func (m *HistoryContinuation) XXX_DiscardUnknown()
- func (m *HistoryContinuation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HistoryContinuation) XXX_Merge(src proto.Message)
- func (m *HistoryContinuation) XXX_Size() int
- func (m *HistoryContinuation) XXX_Unmarshal(b []byte) error
- type QueryTask
- func (*QueryTask) Descriptor() ([]byte, []int)
- func (this *QueryTask) Equal(that interface{}) bool
- func (m *QueryTask) GetNamespaceId() string
- func (m *QueryTask) GetTaskId() string
- func (m *QueryTask) GetTaskQueue() string
- func (this *QueryTask) GoString() string
- func (m *QueryTask) Marshal() (dAtA []byte, err error)
- func (m *QueryTask) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryTask) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryTask) ProtoMessage()
- func (m *QueryTask) Reset()
- func (m *QueryTask) Size() (n int)
- func (this *QueryTask) String() string
- func (m *QueryTask) Unmarshal(dAtA []byte) error
- func (m *QueryTask) XXX_DiscardUnknown()
- func (m *QueryTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryTask) XXX_Merge(src proto.Message)
- func (m *QueryTask) XXX_Size() int
- func (m *QueryTask) XXX_Unmarshal(b []byte) error
- type RawHistoryContinuation
- func (*RawHistoryContinuation) Descriptor() ([]byte, []int)
- func (this *RawHistoryContinuation) Equal(that interface{}) bool
- func (m *RawHistoryContinuation) GetEndEventId() int64
- func (m *RawHistoryContinuation) GetEndEventVersion() int64
- func (m *RawHistoryContinuation) GetNamespaceId() string
- func (m *RawHistoryContinuation) GetPersistenceToken() []byte
- func (m *RawHistoryContinuation) GetRunId() string
- func (m *RawHistoryContinuation) GetStartEventId() int64
- func (m *RawHistoryContinuation) GetStartEventVersion() int64
- func (m *RawHistoryContinuation) GetVersionHistories() *v1.VersionHistories
- func (m *RawHistoryContinuation) GetWorkflowId() string
- func (this *RawHistoryContinuation) GoString() string
- func (m *RawHistoryContinuation) Marshal() (dAtA []byte, err error)
- func (m *RawHistoryContinuation) MarshalTo(dAtA []byte) (int, error)
- func (m *RawHistoryContinuation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RawHistoryContinuation) ProtoMessage()
- func (m *RawHistoryContinuation) Reset()
- func (m *RawHistoryContinuation) Size() (n int)
- func (this *RawHistoryContinuation) String() string
- func (m *RawHistoryContinuation) Unmarshal(dAtA []byte) error
- func (m *RawHistoryContinuation) XXX_DiscardUnknown()
- func (m *RawHistoryContinuation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RawHistoryContinuation) XXX_Merge(src proto.Message)
- func (m *RawHistoryContinuation) XXX_Size() int
- func (m *RawHistoryContinuation) XXX_Unmarshal(b []byte) error
- type Task
- func (*Task) Descriptor() ([]byte, []int)
- func (this *Task) Equal(that interface{}) bool
- func (m *Task) GetActivityId() string
- func (m *Task) GetActivityType() string
- func (m *Task) GetAttempt() int32
- func (m *Task) GetClock() *v11.VectorClock
- func (m *Task) GetNamespaceId() string
- func (m *Task) GetRunId() string
- func (m *Task) GetScheduledEventId() int64
- func (m *Task) GetStartedEventId() int64
- func (m *Task) GetStartedTime() *time.Time
- func (m *Task) GetVersion() int64
- func (m *Task) GetWorkflowId() string
- func (m *Task) GetWorkflowType() string
- func (this *Task) GoString() string
- func (m *Task) Marshal() (dAtA []byte, err error)
- func (m *Task) MarshalTo(dAtA []byte) (int, error)
- func (m *Task) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Task) ProtoMessage()
- func (m *Task) Reset()
- func (m *Task) Size() (n int)
- func (this *Task) String() string
- func (m *Task) Unmarshal(dAtA []byte) error
- func (m *Task) XXX_DiscardUnknown()
- func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Task) XXX_Merge(src proto.Message)
- func (m *Task) XXX_Size() int
- func (m *Task) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type HistoryContinuation ¶
type HistoryContinuation struct { RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` FirstEventId int64 `protobuf:"varint,2,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"` NextEventId int64 `protobuf:"varint,3,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"` IsWorkflowRunning bool `protobuf:"varint,5,opt,name=is_workflow_running,json=isWorkflowRunning,proto3" json:"is_workflow_running,omitempty"` PersistenceToken []byte `protobuf:"bytes,6,opt,name=persistence_token,json=persistenceToken,proto3" json:"persistence_token,omitempty"` TransientWorkflowTask *v1.TransientWorkflowTaskInfo `` /* 126-byte string literal not displayed */ BranchToken []byte `protobuf:"bytes,8,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"` VersionHistoryItem *v1.VersionHistoryItem `protobuf:"bytes,10,opt,name=version_history_item,json=versionHistoryItem,proto3" json:"version_history_item,omitempty"` }
func (*HistoryContinuation) Descriptor ¶
func (*HistoryContinuation) Descriptor() ([]byte, []int)
func (*HistoryContinuation) Equal ¶
func (this *HistoryContinuation) Equal(that interface{}) bool
func (*HistoryContinuation) GetBranchToken ¶
func (m *HistoryContinuation) GetBranchToken() []byte
func (*HistoryContinuation) GetFirstEventId ¶
func (m *HistoryContinuation) GetFirstEventId() int64
func (*HistoryContinuation) GetIsWorkflowRunning ¶
func (m *HistoryContinuation) GetIsWorkflowRunning() bool
func (*HistoryContinuation) GetNextEventId ¶
func (m *HistoryContinuation) GetNextEventId() int64
func (*HistoryContinuation) GetPersistenceToken ¶
func (m *HistoryContinuation) GetPersistenceToken() []byte
func (*HistoryContinuation) GetRunId ¶
func (m *HistoryContinuation) GetRunId() string
func (*HistoryContinuation) GetTransientWorkflowTask ¶
func (m *HistoryContinuation) GetTransientWorkflowTask() *v1.TransientWorkflowTaskInfo
func (*HistoryContinuation) GetVersionHistoryItem ¶ added in v1.22.3
func (m *HistoryContinuation) GetVersionHistoryItem() *v1.VersionHistoryItem
func (*HistoryContinuation) GoString ¶
func (this *HistoryContinuation) GoString() string
func (*HistoryContinuation) Marshal ¶
func (m *HistoryContinuation) Marshal() (dAtA []byte, err error)
func (*HistoryContinuation) MarshalTo ¶
func (m *HistoryContinuation) MarshalTo(dAtA []byte) (int, error)
func (*HistoryContinuation) MarshalToSizedBuffer ¶
func (m *HistoryContinuation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HistoryContinuation) ProtoMessage ¶
func (*HistoryContinuation) ProtoMessage()
func (*HistoryContinuation) Reset ¶
func (m *HistoryContinuation) Reset()
func (*HistoryContinuation) Size ¶
func (m *HistoryContinuation) Size() (n int)
func (*HistoryContinuation) String ¶
func (this *HistoryContinuation) String() string
func (*HistoryContinuation) Unmarshal ¶
func (m *HistoryContinuation) Unmarshal(dAtA []byte) error
func (*HistoryContinuation) XXX_DiscardUnknown ¶
func (m *HistoryContinuation) XXX_DiscardUnknown()
func (*HistoryContinuation) XXX_Marshal ¶
func (m *HistoryContinuation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HistoryContinuation) XXX_Merge ¶
func (m *HistoryContinuation) XXX_Merge(src proto.Message)
func (*HistoryContinuation) XXX_Size ¶
func (m *HistoryContinuation) XXX_Size() int
func (*HistoryContinuation) XXX_Unmarshal ¶
func (m *HistoryContinuation) XXX_Unmarshal(b []byte) error
type QueryTask ¶
type QueryTask struct { NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` }
func (*QueryTask) Descriptor ¶
func (*QueryTask) GetNamespaceId ¶
func (*QueryTask) GetTaskQueue ¶
func (*QueryTask) MarshalToSizedBuffer ¶
func (*QueryTask) ProtoMessage ¶
func (*QueryTask) ProtoMessage()
func (*QueryTask) XXX_DiscardUnknown ¶
func (m *QueryTask) XXX_DiscardUnknown()
func (*QueryTask) XXX_Marshal ¶
func (*QueryTask) XXX_Unmarshal ¶
type RawHistoryContinuation ¶
type RawHistoryContinuation struct { NamespaceId string `protobuf:"bytes,10,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` StartEventId int64 `protobuf:"varint,4,opt,name=start_event_id,json=startEventId,proto3" json:"start_event_id,omitempty"` StartEventVersion int64 `protobuf:"varint,5,opt,name=start_event_version,json=startEventVersion,proto3" json:"start_event_version,omitempty"` EndEventId int64 `protobuf:"varint,6,opt,name=end_event_id,json=endEventId,proto3" json:"end_event_id,omitempty"` EndEventVersion int64 `protobuf:"varint,7,opt,name=end_event_version,json=endEventVersion,proto3" json:"end_event_version,omitempty"` PersistenceToken []byte `protobuf:"bytes,8,opt,name=persistence_token,json=persistenceToken,proto3" json:"persistence_token,omitempty"` VersionHistories *v1.VersionHistories `protobuf:"bytes,9,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"` }
func (*RawHistoryContinuation) Descriptor ¶
func (*RawHistoryContinuation) Descriptor() ([]byte, []int)
func (*RawHistoryContinuation) Equal ¶
func (this *RawHistoryContinuation) Equal(that interface{}) bool
func (*RawHistoryContinuation) GetEndEventId ¶
func (m *RawHistoryContinuation) GetEndEventId() int64
func (*RawHistoryContinuation) GetEndEventVersion ¶
func (m *RawHistoryContinuation) GetEndEventVersion() int64
func (*RawHistoryContinuation) GetNamespaceId ¶ added in v1.17.0
func (m *RawHistoryContinuation) GetNamespaceId() string
func (*RawHistoryContinuation) GetPersistenceToken ¶
func (m *RawHistoryContinuation) GetPersistenceToken() []byte
func (*RawHistoryContinuation) GetRunId ¶
func (m *RawHistoryContinuation) GetRunId() string
func (*RawHistoryContinuation) GetStartEventId ¶
func (m *RawHistoryContinuation) GetStartEventId() int64
func (*RawHistoryContinuation) GetStartEventVersion ¶
func (m *RawHistoryContinuation) GetStartEventVersion() int64
func (*RawHistoryContinuation) GetVersionHistories ¶
func (m *RawHistoryContinuation) GetVersionHistories() *v1.VersionHistories
func (*RawHistoryContinuation) GetWorkflowId ¶
func (m *RawHistoryContinuation) GetWorkflowId() string
func (*RawHistoryContinuation) GoString ¶
func (this *RawHistoryContinuation) GoString() string
func (*RawHistoryContinuation) Marshal ¶
func (m *RawHistoryContinuation) Marshal() (dAtA []byte, err error)
func (*RawHistoryContinuation) MarshalTo ¶
func (m *RawHistoryContinuation) MarshalTo(dAtA []byte) (int, error)
func (*RawHistoryContinuation) MarshalToSizedBuffer ¶
func (m *RawHistoryContinuation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RawHistoryContinuation) ProtoMessage ¶
func (*RawHistoryContinuation) ProtoMessage()
func (*RawHistoryContinuation) Reset ¶
func (m *RawHistoryContinuation) Reset()
func (*RawHistoryContinuation) Size ¶
func (m *RawHistoryContinuation) Size() (n int)
func (*RawHistoryContinuation) String ¶
func (this *RawHistoryContinuation) String() string
func (*RawHistoryContinuation) Unmarshal ¶
func (m *RawHistoryContinuation) Unmarshal(dAtA []byte) error
func (*RawHistoryContinuation) XXX_DiscardUnknown ¶
func (m *RawHistoryContinuation) XXX_DiscardUnknown()
func (*RawHistoryContinuation) XXX_Marshal ¶
func (m *RawHistoryContinuation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RawHistoryContinuation) XXX_Merge ¶
func (m *RawHistoryContinuation) XXX_Merge(src proto.Message)
func (*RawHistoryContinuation) XXX_Size ¶
func (m *RawHistoryContinuation) XXX_Size() int
func (*RawHistoryContinuation) XXX_Unmarshal ¶
func (m *RawHistoryContinuation) XXX_Unmarshal(b []byte) error
type Task ¶
type Task struct { NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` ScheduledEventId int64 `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"` ActivityId string `protobuf:"bytes,6,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"` WorkflowType string `protobuf:"bytes,7,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` ActivityType string `protobuf:"bytes,8,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"` Clock *v11.VectorClock `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"` StartedEventId int64 `protobuf:"varint,10,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` Version int64 `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"` StartedTime *time.Time `protobuf:"bytes,12,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"` }
func (*Task) Descriptor ¶
func (*Task) GetActivityId ¶
func (*Task) GetActivityType ¶
func (*Task) GetAttempt ¶ added in v1.17.0
func (*Task) GetClock ¶ added in v1.17.0
func (m *Task) GetClock() *v11.VectorClock
func (*Task) GetNamespaceId ¶
func (*Task) GetScheduledEventId ¶ added in v1.17.0
func (*Task) GetStartedEventId ¶ added in v1.21.0
func (*Task) GetStartedTime ¶ added in v1.21.3
func (*Task) GetVersion ¶ added in v1.21.3
func (*Task) GetWorkflowId ¶
func (*Task) GetWorkflowType ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) XXX_DiscardUnknown ¶
func (m *Task) XXX_DiscardUnknown()
func (*Task) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.