Documentation
¶
Index ¶
- Variables
- type BatchOperationCancellation
- func (*BatchOperationCancellation) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationCancellation) GetIdentity() string
- func (*BatchOperationCancellation) ProtoMessage()
- func (x *BatchOperationCancellation) ProtoReflect() protoreflect.Message
- func (x *BatchOperationCancellation) Reset()
- func (x *BatchOperationCancellation) String() string
- type BatchOperationDeletion
- func (*BatchOperationDeletion) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationDeletion) GetIdentity() string
- func (*BatchOperationDeletion) ProtoMessage()
- func (x *BatchOperationDeletion) ProtoReflect() protoreflect.Message
- func (x *BatchOperationDeletion) Reset()
- func (x *BatchOperationDeletion) String() string
- type BatchOperationInfo
- func (*BatchOperationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationInfo) GetCloseTime() *timestamppb.Timestamp
- func (x *BatchOperationInfo) GetJobId() string
- func (x *BatchOperationInfo) GetStartTime() *timestamppb.Timestamp
- func (x *BatchOperationInfo) GetState() v1.BatchOperationState
- func (*BatchOperationInfo) ProtoMessage()
- func (x *BatchOperationInfo) ProtoReflect() protoreflect.Message
- func (x *BatchOperationInfo) Reset()
- func (x *BatchOperationInfo) String() string
- type BatchOperationReset
- func (*BatchOperationReset) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationReset) GetIdentity() string
- func (x *BatchOperationReset) GetOptions() *v11.ResetOptions
- func (x *BatchOperationReset) GetResetReapplyType() v1.ResetReapplyType
- func (x *BatchOperationReset) GetResetType() v1.ResetType
- func (*BatchOperationReset) ProtoMessage()
- func (x *BatchOperationReset) ProtoReflect() protoreflect.Message
- func (x *BatchOperationReset) Reset()
- func (x *BatchOperationReset) String() string
- type BatchOperationSignal
- func (*BatchOperationSignal) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationSignal) GetHeader() *v11.Header
- func (x *BatchOperationSignal) GetIdentity() string
- func (x *BatchOperationSignal) GetInput() *v11.Payloads
- func (x *BatchOperationSignal) GetSignal() string
- func (*BatchOperationSignal) ProtoMessage()
- func (x *BatchOperationSignal) ProtoReflect() protoreflect.Message
- func (x *BatchOperationSignal) Reset()
- func (x *BatchOperationSignal) String() string
- type BatchOperationTermination
- func (*BatchOperationTermination) Descriptor() ([]byte, []int)deprecated
- func (x *BatchOperationTermination) GetDetails() *v11.Payloads
- func (x *BatchOperationTermination) GetIdentity() string
- func (*BatchOperationTermination) ProtoMessage()
- func (x *BatchOperationTermination) ProtoReflect() protoreflect.Message
- func (x *BatchOperationTermination) Reset()
- func (x *BatchOperationTermination) String() string
Constants ¶
This section is empty.
Variables ¶
var File_temporal_api_batch_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BatchOperationCancellation ¶
type BatchOperationCancellation struct {
// The identity of the worker/client
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// contains filtered or unexported fields
}
BatchOperationCancellation sends cancel requests to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest. Ignore first_execution_run_id because this is used for single workflow operation.
func (*BatchOperationCancellation) Descriptor
deprecated
func (*BatchOperationCancellation) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationCancellation.ProtoReflect.Descriptor instead.
func (*BatchOperationCancellation) GetIdentity ¶
func (x *BatchOperationCancellation) GetIdentity() string
func (*BatchOperationCancellation) ProtoMessage ¶
func (*BatchOperationCancellation) ProtoMessage()
func (*BatchOperationCancellation) ProtoReflect ¶
func (x *BatchOperationCancellation) ProtoReflect() protoreflect.Message
func (*BatchOperationCancellation) Reset ¶
func (x *BatchOperationCancellation) Reset()
func (*BatchOperationCancellation) String ¶
func (x *BatchOperationCancellation) String() string
type BatchOperationDeletion ¶
type BatchOperationDeletion struct {
// The identity of the worker/client
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// contains filtered or unexported fields
}
BatchOperationDeletion sends deletion requests to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.DeleteWorkflowExecutionRequest.
func (*BatchOperationDeletion) Descriptor
deprecated
func (*BatchOperationDeletion) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationDeletion.ProtoReflect.Descriptor instead.
func (*BatchOperationDeletion) GetIdentity ¶
func (x *BatchOperationDeletion) GetIdentity() string
func (*BatchOperationDeletion) ProtoMessage ¶
func (*BatchOperationDeletion) ProtoMessage()
func (*BatchOperationDeletion) ProtoReflect ¶
func (x *BatchOperationDeletion) ProtoReflect() protoreflect.Message
func (*BatchOperationDeletion) Reset ¶
func (x *BatchOperationDeletion) Reset()
func (*BatchOperationDeletion) String ¶
func (x *BatchOperationDeletion) String() string
type BatchOperationInfo ¶
type BatchOperationInfo struct {
// Batch job ID
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// Batch operation state
State v1.BatchOperationState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.BatchOperationState" json:"state,omitempty"`
// Batch operation start time
StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// Batch operation close time
CloseTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
// contains filtered or unexported fields
}
func (*BatchOperationInfo) Descriptor
deprecated
func (*BatchOperationInfo) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationInfo.ProtoReflect.Descriptor instead.
func (*BatchOperationInfo) GetCloseTime ¶
func (x *BatchOperationInfo) GetCloseTime() *timestamppb.Timestamp
func (*BatchOperationInfo) GetJobId ¶
func (x *BatchOperationInfo) GetJobId() string
func (*BatchOperationInfo) GetStartTime ¶
func (x *BatchOperationInfo) GetStartTime() *timestamppb.Timestamp
func (*BatchOperationInfo) GetState ¶
func (x *BatchOperationInfo) GetState() v1.BatchOperationState
func (*BatchOperationInfo) ProtoMessage ¶
func (*BatchOperationInfo) ProtoMessage()
func (*BatchOperationInfo) ProtoReflect ¶
func (x *BatchOperationInfo) ProtoReflect() protoreflect.Message
func (*BatchOperationInfo) Reset ¶
func (x *BatchOperationInfo) Reset()
func (*BatchOperationInfo) String ¶
func (x *BatchOperationInfo) String() string
type BatchOperationReset ¶
type BatchOperationReset struct {
// The identity of the worker/client.
Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
// Describes what to reset to and how. If set, `reset_type` and `reset_reapply_type` are ignored.
Options *v11.ResetOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
// Reset type (deprecated, use `options`).
ResetType v1.ResetType `` /* 126-byte string literal not displayed */
// History event reapply options (deprecated, use `options`).
ResetReapplyType v1.ResetReapplyType `` /* 156-byte string literal not displayed */
// contains filtered or unexported fields
}
BatchOperationReset sends reset requests to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.ResetWorkflowExecutionRequest.
func (*BatchOperationReset) Descriptor
deprecated
func (*BatchOperationReset) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationReset.ProtoReflect.Descriptor instead.
func (*BatchOperationReset) GetIdentity ¶
func (x *BatchOperationReset) GetIdentity() string
func (*BatchOperationReset) GetOptions ¶ added in v4.11.0
func (x *BatchOperationReset) GetOptions() *v11.ResetOptions
func (*BatchOperationReset) GetResetReapplyType ¶
func (x *BatchOperationReset) GetResetReapplyType() v1.ResetReapplyType
func (*BatchOperationReset) GetResetType ¶
func (x *BatchOperationReset) GetResetType() v1.ResetType
func (*BatchOperationReset) ProtoMessage ¶
func (*BatchOperationReset) ProtoMessage()
func (*BatchOperationReset) ProtoReflect ¶
func (x *BatchOperationReset) ProtoReflect() protoreflect.Message
func (*BatchOperationReset) Reset ¶
func (x *BatchOperationReset) Reset()
func (*BatchOperationReset) String ¶
func (x *BatchOperationReset) String() string
type BatchOperationSignal ¶
type BatchOperationSignal struct {
// The workflow author-defined name of the signal to send to the workflow
Signal string `protobuf:"bytes,1,opt,name=signal,proto3" json:"signal,omitempty"`
// Serialized value(s) to provide with the signal
Input *v11.Payloads `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
// Headers that are passed with the signal to the processing workflow.
// These can include things like auth or tracing tokens.
Header *v11.Header `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
// The identity of the worker/client
Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
// contains filtered or unexported fields
}
BatchOperationSignal sends signals to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.
func (*BatchOperationSignal) Descriptor
deprecated
func (*BatchOperationSignal) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationSignal.ProtoReflect.Descriptor instead.
func (*BatchOperationSignal) GetHeader ¶
func (x *BatchOperationSignal) GetHeader() *v11.Header
func (*BatchOperationSignal) GetIdentity ¶
func (x *BatchOperationSignal) GetIdentity() string
func (*BatchOperationSignal) GetInput ¶
func (x *BatchOperationSignal) GetInput() *v11.Payloads
func (*BatchOperationSignal) GetSignal ¶
func (x *BatchOperationSignal) GetSignal() string
func (*BatchOperationSignal) ProtoMessage ¶
func (*BatchOperationSignal) ProtoMessage()
func (*BatchOperationSignal) ProtoReflect ¶
func (x *BatchOperationSignal) ProtoReflect() protoreflect.Message
func (*BatchOperationSignal) Reset ¶
func (x *BatchOperationSignal) Reset()
func (*BatchOperationSignal) String ¶
func (x *BatchOperationSignal) String() string
type BatchOperationTermination ¶
type BatchOperationTermination struct {
// Serialized value(s) to provide to the termination event
Details *v11.Payloads `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
// The identity of the worker/client
Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
// contains filtered or unexported fields
}
BatchOperationTermination sends terminate requests to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest. Ignore first_execution_run_id because this is used for single workflow operation.
func (*BatchOperationTermination) Descriptor
deprecated
func (*BatchOperationTermination) Descriptor() ([]byte, []int)
Deprecated: Use BatchOperationTermination.ProtoReflect.Descriptor instead.
func (*BatchOperationTermination) GetDetails ¶
func (x *BatchOperationTermination) GetDetails() *v11.Payloads
func (*BatchOperationTermination) GetIdentity ¶
func (x *BatchOperationTermination) GetIdentity() string
func (*BatchOperationTermination) ProtoMessage ¶
func (*BatchOperationTermination) ProtoMessage()
func (*BatchOperationTermination) ProtoReflect ¶
func (x *BatchOperationTermination) ProtoReflect() protoreflect.Message
func (*BatchOperationTermination) Reset ¶
func (x *BatchOperationTermination) Reset()
func (*BatchOperationTermination) String ¶
func (x *BatchOperationTermination) String() string