batch

package
v1.43.0 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: MIT Imports: 10 Imported by: 9

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

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) Equal 

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

Equal returns whether two BatchOperationCancellation values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BatchOperationCancellation) GetIdentity 

func (x *BatchOperationCancellation) GetIdentity() string

func (*BatchOperationCancellation) Marshal 

func (val *BatchOperationCancellation) Marshal() ([]byte, error)

Marshal an object of type BatchOperationCancellation to the protobuf v3 wire format

func (*BatchOperationCancellation) ProtoMessage 

func (*BatchOperationCancellation) ProtoMessage()

func (*BatchOperationCancellation) ProtoReflect added in v1.26.1 

func (x *BatchOperationCancellation) ProtoReflect() protoreflect.Message

func (*BatchOperationCancellation) Reset 

func (x *BatchOperationCancellation) Reset()

func (*BatchOperationCancellation) Size 

func (val *BatchOperationCancellation) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationCancellation) String 

func (x *BatchOperationCancellation) String() string

func (*BatchOperationCancellation) Unmarshal 

func (val *BatchOperationCancellation) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationCancellation from the protobuf v3 wire format

type BatchOperationDeletion added in v1.13.0 

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 added in v1.13.0 

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

Deprecated: Use BatchOperationDeletion.ProtoReflect.Descriptor instead.

func (*BatchOperationDeletion) Equal added in v1.13.0 

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

Equal returns whether two BatchOperationDeletion values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BatchOperationDeletion) GetIdentity added in v1.13.0 

func (x *BatchOperationDeletion) GetIdentity() string

func (*BatchOperationDeletion) Marshal added in v1.13.0 

func (val *BatchOperationDeletion) Marshal() ([]byte, error)

Marshal an object of type BatchOperationDeletion to the protobuf v3 wire format

func (*BatchOperationDeletion) ProtoMessage added in v1.13.0 

func (*BatchOperationDeletion) ProtoMessage()

func (*BatchOperationDeletion) ProtoReflect added in v1.26.1 

func (x *BatchOperationDeletion) ProtoReflect() protoreflect.Message

func (*BatchOperationDeletion) Reset added in v1.13.0 

func (x *BatchOperationDeletion) Reset()

func (*BatchOperationDeletion) Size added in v1.13.0 

func (val *BatchOperationDeletion) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationDeletion) String added in v1.13.0 

func (x *BatchOperationDeletion) String() string

func (*BatchOperationDeletion) Unmarshal added in v1.13.0 

func (val *BatchOperationDeletion) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationDeletion from the protobuf v3 wire format

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) Equal 

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

Equal returns whether two BatchOperationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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) Marshal 

func (val *BatchOperationInfo) Marshal() ([]byte, error)

Marshal an object of type BatchOperationInfo to the protobuf v3 wire format

func (*BatchOperationInfo) ProtoMessage 

func (*BatchOperationInfo) ProtoMessage()

func (*BatchOperationInfo) ProtoReflect added in v1.26.1 

func (x *BatchOperationInfo) ProtoReflect() protoreflect.Message

func (*BatchOperationInfo) Reset 

func (x *BatchOperationInfo) Reset()

func (*BatchOperationInfo) Size 

func (val *BatchOperationInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationInfo) String 

func (x *BatchOperationInfo) String() string

func (*BatchOperationInfo) Unmarshal 

func (val *BatchOperationInfo) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationInfo from the protobuf v3 wire format

type BatchOperationReset added in v1.21.0 

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 added in v1.21.0 

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

Deprecated: Use BatchOperationReset.ProtoReflect.Descriptor instead.

func (*BatchOperationReset) Equal added in v1.21.0 

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

Equal returns whether two BatchOperationReset values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BatchOperationReset) GetIdentity added in v1.21.0 

func (x *BatchOperationReset) GetIdentity() string

func (*BatchOperationReset) GetOptions added in v1.26.2 

func (x *BatchOperationReset) GetOptions() *v11.ResetOptions

func (*BatchOperationReset) GetResetReapplyType added in v1.21.0 

func (x *BatchOperationReset) GetResetReapplyType() v1.ResetReapplyType

func (*BatchOperationReset) GetResetType added in v1.21.0 

func (x *BatchOperationReset) GetResetType() v1.ResetType

func (*BatchOperationReset) Marshal added in v1.21.0 

func (val *BatchOperationReset) Marshal() ([]byte, error)

Marshal an object of type BatchOperationReset to the protobuf v3 wire format

func (*BatchOperationReset) ProtoMessage added in v1.21.0 

func (*BatchOperationReset) ProtoMessage()

func (*BatchOperationReset) ProtoReflect added in v1.26.1 

func (x *BatchOperationReset) ProtoReflect() protoreflect.Message

func (*BatchOperationReset) Reset added in v1.21.0 

func (x *BatchOperationReset) Reset()

func (*BatchOperationReset) Size added in v1.21.0 

func (val *BatchOperationReset) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationReset) String added in v1.21.0 

func (x *BatchOperationReset) String() string

func (*BatchOperationReset) Unmarshal added in v1.21.0 

func (val *BatchOperationReset) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationReset from the protobuf v3 wire format

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) Equal 

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

Equal returns whether two BatchOperationSignal values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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) Marshal 

func (val *BatchOperationSignal) Marshal() ([]byte, error)

Marshal an object of type BatchOperationSignal to the protobuf v3 wire format

func (*BatchOperationSignal) ProtoMessage 

func (*BatchOperationSignal) ProtoMessage()

func (*BatchOperationSignal) ProtoReflect added in v1.26.1 

func (x *BatchOperationSignal) ProtoReflect() protoreflect.Message

func (*BatchOperationSignal) Reset 

func (x *BatchOperationSignal) Reset()

func (*BatchOperationSignal) Size 

func (val *BatchOperationSignal) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationSignal) String 

func (x *BatchOperationSignal) String() string

func (*BatchOperationSignal) Unmarshal 

func (val *BatchOperationSignal) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationSignal from the protobuf v3 wire format

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) Equal 

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

Equal returns whether two BatchOperationTermination values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BatchOperationTermination) GetDetails 

func (x *BatchOperationTermination) GetDetails() *v11.Payloads

func (*BatchOperationTermination) GetIdentity 

func (x *BatchOperationTermination) GetIdentity() string

func (*BatchOperationTermination) Marshal 

func (val *BatchOperationTermination) Marshal() ([]byte, error)

Marshal an object of type BatchOperationTermination to the protobuf v3 wire format

func (*BatchOperationTermination) ProtoMessage 

func (*BatchOperationTermination) ProtoMessage()

func (*BatchOperationTermination) ProtoReflect added in v1.26.1 

func (x *BatchOperationTermination) ProtoReflect() protoreflect.Message

func (*BatchOperationTermination) Reset 

func (x *BatchOperationTermination) Reset()

func (*BatchOperationTermination) Size 

func (val *BatchOperationTermination) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationTermination) String 

func (x *BatchOperationTermination) String() string

func (*BatchOperationTermination) Unmarshal 

func (val *BatchOperationTermination) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationTermination from the protobuf v3 wire format

type BatchOperationUpdateWorkflowExecutionOptions added in v1.43.0 

type BatchOperationUpdateWorkflowExecutionOptions struct {

	// The identity of the worker/client.
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// Workflow Execution options. Partial updates are accepted and controlled by update_mask.
	WorkflowExecutionOptions *v12.WorkflowExecutionOptions `` /* 135-byte string literal not displayed */
	// Controls which fields from `workflow_execution_options` will be applied.
	// To unset a field, set it to null and use the update mask to indicate that it should be mutated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

BatchOperationUpdateWorkflowExecutionOptions sends UpdateWorkflowExecutionOptions requests to batch workflows. Keep the parameters in sync with temporal.api.workflowservice.v1.UpdateWorkflowExecutionOptionsRequest.

func (*BatchOperationUpdateWorkflowExecutionOptions) Descriptor deprecated added in v1.43.0 

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

Deprecated: Use BatchOperationUpdateWorkflowExecutionOptions.ProtoReflect.Descriptor instead.

func (*BatchOperationUpdateWorkflowExecutionOptions) Equal added in v1.43.0 

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

Equal returns whether two BatchOperationUpdateWorkflowExecutionOptions values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BatchOperationUpdateWorkflowExecutionOptions) GetIdentity added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) GetIdentity() string

func (*BatchOperationUpdateWorkflowExecutionOptions) GetUpdateMask added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) GetUpdateMask() *fieldmaskpb.FieldMask

func (*BatchOperationUpdateWorkflowExecutionOptions) GetWorkflowExecutionOptions added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) GetWorkflowExecutionOptions() *v12.WorkflowExecutionOptions

func (*BatchOperationUpdateWorkflowExecutionOptions) Marshal added in v1.43.0 

func (val *BatchOperationUpdateWorkflowExecutionOptions) Marshal() ([]byte, error)

Marshal an object of type BatchOperationUpdateWorkflowExecutionOptions to the protobuf v3 wire format

func (*BatchOperationUpdateWorkflowExecutionOptions) ProtoMessage added in v1.43.0 

func (*BatchOperationUpdateWorkflowExecutionOptions) ProtoMessage()

func (*BatchOperationUpdateWorkflowExecutionOptions) ProtoReflect added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) ProtoReflect() protoreflect.Message

func (*BatchOperationUpdateWorkflowExecutionOptions) Reset added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) Reset()

func (*BatchOperationUpdateWorkflowExecutionOptions) Size added in v1.43.0 

func (val *BatchOperationUpdateWorkflowExecutionOptions) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BatchOperationUpdateWorkflowExecutionOptions) String added in v1.43.0 

func (x *BatchOperationUpdateWorkflowExecutionOptions) String() string

func (*BatchOperationUpdateWorkflowExecutionOptions) Unmarshal added in v1.43.0 

func (val *BatchOperationUpdateWorkflowExecutionOptions) Unmarshal(buf []byte) error

Unmarshal an object of type BatchOperationUpdateWorkflowExecutionOptions from the protobuf v3 wire format

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.