batch

package
v4.10.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 {

	// Reset type.
	ResetType v1.ResetType `` /* 126-byte string literal not displayed */
	// History event reapply options.
	ResetReapplyType v1.ResetReapplyType `` /* 156-byte string literal not displayed */
	// The identity of the worker/client.
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// 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) 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

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.