batch

package
v1.17.0 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2023 License: MIT Imports: 12 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

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"`
}

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 

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

func (*BatchOperationCancellation) Equal 

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

func (*BatchOperationCancellation) GetIdentity 

func (m *BatchOperationCancellation) GetIdentity() string

func (*BatchOperationCancellation) GoString 

func (this *BatchOperationCancellation) GoString() string

func (*BatchOperationCancellation) Marshal 

func (m *BatchOperationCancellation) Marshal() (dAtA []byte, err error)

func (*BatchOperationCancellation) MarshalTo 

func (m *BatchOperationCancellation) MarshalTo(dAtA []byte) (int, error)

func (*BatchOperationCancellation) MarshalToSizedBuffer 

func (m *BatchOperationCancellation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchOperationCancellation) ProtoMessage 

func (*BatchOperationCancellation) ProtoMessage()

func (*BatchOperationCancellation) Reset 

func (m *BatchOperationCancellation) Reset()

func (*BatchOperationCancellation) Size 

func (m *BatchOperationCancellation) Size() (n int)

func (*BatchOperationCancellation) String 

func (this *BatchOperationCancellation) String() string

func (*BatchOperationCancellation) Unmarshal 

func (m *BatchOperationCancellation) Unmarshal(dAtA []byte) error

func (*BatchOperationCancellation) XXX_DiscardUnknown 

func (m *BatchOperationCancellation) XXX_DiscardUnknown()

func (*BatchOperationCancellation) XXX_Marshal 

func (m *BatchOperationCancellation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchOperationCancellation) XXX_Merge 

func (m *BatchOperationCancellation) XXX_Merge(src proto.Message)

func (*BatchOperationCancellation) XXX_Size 

func (m *BatchOperationCancellation) XXX_Size() int

func (*BatchOperationCancellation) XXX_Unmarshal 

func (m *BatchOperationCancellation) XXX_Unmarshal(b []byte) error

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"`
}

BatchOperationDeletion sends deletion requests to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.DeleteWorkflowExecutionRequest.

func (*BatchOperationDeletion) Descriptor added in v1.13.0 

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

func (*BatchOperationDeletion) Equal added in v1.13.0 

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

func (*BatchOperationDeletion) GetIdentity added in v1.13.0 

func (m *BatchOperationDeletion) GetIdentity() string

func (*BatchOperationDeletion) GoString added in v1.13.0 

func (this *BatchOperationDeletion) GoString() string

func (*BatchOperationDeletion) Marshal added in v1.13.0 

func (m *BatchOperationDeletion) Marshal() (dAtA []byte, err error)

func (*BatchOperationDeletion) MarshalTo added in v1.13.0 

func (m *BatchOperationDeletion) MarshalTo(dAtA []byte) (int, error)

func (*BatchOperationDeletion) MarshalToSizedBuffer added in v1.13.0 

func (m *BatchOperationDeletion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchOperationDeletion) ProtoMessage added in v1.13.0 

func (*BatchOperationDeletion) ProtoMessage()

func (*BatchOperationDeletion) Reset added in v1.13.0 

func (m *BatchOperationDeletion) Reset()

func (*BatchOperationDeletion) Size added in v1.13.0 

func (m *BatchOperationDeletion) Size() (n int)

func (*BatchOperationDeletion) String added in v1.13.0 

func (this *BatchOperationDeletion) String() string

func (*BatchOperationDeletion) Unmarshal added in v1.13.0 

func (m *BatchOperationDeletion) Unmarshal(dAtA []byte) error

func (*BatchOperationDeletion) XXX_DiscardUnknown added in v1.13.0 

func (m *BatchOperationDeletion) XXX_DiscardUnknown()

func (*BatchOperationDeletion) XXX_Marshal added in v1.13.0 

func (m *BatchOperationDeletion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchOperationDeletion) XXX_Merge added in v1.13.0 

func (m *BatchOperationDeletion) XXX_Merge(src proto.Message)

func (*BatchOperationDeletion) XXX_Size added in v1.13.0 

func (m *BatchOperationDeletion) XXX_Size() int

func (*BatchOperationDeletion) XXX_Unmarshal added in v1.13.0 

func (m *BatchOperationDeletion) XXX_Unmarshal(b []byte) error

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 *time.Time `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	// Batch operation close time
	CloseTime *time.Time `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
}

func (*BatchOperationInfo) Descriptor 

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

func (*BatchOperationInfo) Equal 

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

func (*BatchOperationInfo) GetCloseTime 

func (m *BatchOperationInfo) GetCloseTime() *time.Time

func (*BatchOperationInfo) GetJobId 

func (m *BatchOperationInfo) GetJobId() string

func (*BatchOperationInfo) GetStartTime 

func (m *BatchOperationInfo) GetStartTime() *time.Time

func (*BatchOperationInfo) GetState 

func (m *BatchOperationInfo) GetState() v1.BatchOperationState

func (*BatchOperationInfo) GoString 

func (this *BatchOperationInfo) GoString() string

func (*BatchOperationInfo) Marshal 

func (m *BatchOperationInfo) Marshal() (dAtA []byte, err error)

func (*BatchOperationInfo) MarshalTo 

func (m *BatchOperationInfo) MarshalTo(dAtA []byte) (int, error)

func (*BatchOperationInfo) MarshalToSizedBuffer 

func (m *BatchOperationInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchOperationInfo) ProtoMessage 

func (*BatchOperationInfo) ProtoMessage()

func (*BatchOperationInfo) Reset 

func (m *BatchOperationInfo) Reset()

func (*BatchOperationInfo) Size 

func (m *BatchOperationInfo) Size() (n int)

func (*BatchOperationInfo) String 

func (this *BatchOperationInfo) String() string

func (*BatchOperationInfo) Unmarshal 

func (m *BatchOperationInfo) Unmarshal(dAtA []byte) error

func (*BatchOperationInfo) XXX_DiscardUnknown 

func (m *BatchOperationInfo) XXX_DiscardUnknown()

func (*BatchOperationInfo) XXX_Marshal 

func (m *BatchOperationInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchOperationInfo) XXX_Merge 

func (m *BatchOperationInfo) XXX_Merge(src proto.Message)

func (*BatchOperationInfo) XXX_Size 

func (m *BatchOperationInfo) XXX_Size() int

func (*BatchOperationInfo) XXX_Unmarshal 

func (m *BatchOperationInfo) XXX_Unmarshal(b []byte) error

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"`
}

BatchOperationSignal sends signals to batch workflows. Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.

func (*BatchOperationSignal) Descriptor 

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

func (*BatchOperationSignal) Equal 

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

func (*BatchOperationSignal) GetHeader 

func (m *BatchOperationSignal) GetHeader() *v11.Header

func (*BatchOperationSignal) GetIdentity 

func (m *BatchOperationSignal) GetIdentity() string

func (*BatchOperationSignal) GetInput 

func (m *BatchOperationSignal) GetInput() *v11.Payloads

func (*BatchOperationSignal) GetSignal 

func (m *BatchOperationSignal) GetSignal() string

func (*BatchOperationSignal) GoString 

func (this *BatchOperationSignal) GoString() string

func (*BatchOperationSignal) Marshal 

func (m *BatchOperationSignal) Marshal() (dAtA []byte, err error)

func (*BatchOperationSignal) MarshalTo 

func (m *BatchOperationSignal) MarshalTo(dAtA []byte) (int, error)

func (*BatchOperationSignal) MarshalToSizedBuffer 

func (m *BatchOperationSignal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchOperationSignal) ProtoMessage 

func (*BatchOperationSignal) ProtoMessage()

func (*BatchOperationSignal) Reset 

func (m *BatchOperationSignal) Reset()

func (*BatchOperationSignal) Size 

func (m *BatchOperationSignal) Size() (n int)

func (*BatchOperationSignal) String 

func (this *BatchOperationSignal) String() string

func (*BatchOperationSignal) Unmarshal 

func (m *BatchOperationSignal) Unmarshal(dAtA []byte) error

func (*BatchOperationSignal) XXX_DiscardUnknown 

func (m *BatchOperationSignal) XXX_DiscardUnknown()

func (*BatchOperationSignal) XXX_Marshal 

func (m *BatchOperationSignal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchOperationSignal) XXX_Merge 

func (m *BatchOperationSignal) XXX_Merge(src proto.Message)

func (*BatchOperationSignal) XXX_Size 

func (m *BatchOperationSignal) XXX_Size() int

func (*BatchOperationSignal) XXX_Unmarshal 

func (m *BatchOperationSignal) XXX_Unmarshal(b []byte) error

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"`
}

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 

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

func (*BatchOperationTermination) Equal 

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

func (*BatchOperationTermination) GetDetails 

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

func (*BatchOperationTermination) GetIdentity 

func (m *BatchOperationTermination) GetIdentity() string

func (*BatchOperationTermination) GoString 

func (this *BatchOperationTermination) GoString() string

func (*BatchOperationTermination) Marshal 

func (m *BatchOperationTermination) Marshal() (dAtA []byte, err error)

func (*BatchOperationTermination) MarshalTo 

func (m *BatchOperationTermination) MarshalTo(dAtA []byte) (int, error)

func (*BatchOperationTermination) MarshalToSizedBuffer 

func (m *BatchOperationTermination) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchOperationTermination) ProtoMessage 

func (*BatchOperationTermination) ProtoMessage()

func (*BatchOperationTermination) Reset 

func (m *BatchOperationTermination) Reset()

func (*BatchOperationTermination) Size 

func (m *BatchOperationTermination) Size() (n int)

func (*BatchOperationTermination) String 

func (this *BatchOperationTermination) String() string

func (*BatchOperationTermination) Unmarshal 

func (m *BatchOperationTermination) Unmarshal(dAtA []byte) error

func (*BatchOperationTermination) XXX_DiscardUnknown 

func (m *BatchOperationTermination) XXX_DiscardUnknown()

func (*BatchOperationTermination) XXX_Marshal 

func (m *BatchOperationTermination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchOperationTermination) XXX_Merge 

func (m *BatchOperationTermination) XXX_Merge(src proto.Message)

func (*BatchOperationTermination) XXX_Size 

func (m *BatchOperationTermination) XXX_Size() int

func (*BatchOperationTermination) XXX_Unmarshal 

func (m *BatchOperationTermination) XXX_Unmarshal(b []byte) error

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.