temporalv1

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// optional temporal.v1.ActivityOptions activity = 50000;
	E_Activity = &file_v1_temporal_proto_extTypes[0]
	// optional temporal.v1.WorkflowOptions workflow = 50001;
	E_Workflow = &file_v1_temporal_proto_extTypes[1]
)

Extension fields to descriptorpb.MethodOptions.

View Source 
var (
	// optional temporal.v1.ServiceOptions service = 50002;
	E_Service = &file_v1_temporal_proto_extTypes[2]
)

Extension fields to descriptorpb.ServiceOptions.

View Source 
var File_v1_temporal_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActivityOptions 

type ActivityOptions struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Timeout from schedule to close - in seconds
	ScheduleToCloseTimeout *wrapperspb.Int32Value `` /* 131-byte string literal not displayed */
	// Timeout from start to close - in seconds
	StartToCloseTimeout *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	// Timeout from schedule to  - in seconds
	ScheduleToStartTimeout *wrapperspb.Int32Value `` /* 131-byte string literal not displayed */
	// Default retry policy
	RetryPolicy *RetryPolicy `protobuf:"bytes,5,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityOptions) Descriptor deprecated 

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

Deprecated: Use ActivityOptions.ProtoReflect.Descriptor instead.

func (*ActivityOptions) GetName 

func (x *ActivityOptions) GetName() string

func (*ActivityOptions) GetRetryPolicy 

func (x *ActivityOptions) GetRetryPolicy() *RetryPolicy

func (*ActivityOptions) GetScheduleToCloseTimeout 

func (x *ActivityOptions) GetScheduleToCloseTimeout() *wrapperspb.Int32Value

func (*ActivityOptions) GetScheduleToStartTimeout 

func (x *ActivityOptions) GetScheduleToStartTimeout() *wrapperspb.Int32Value

func (*ActivityOptions) GetStartToCloseTimeout 

func (x *ActivityOptions) GetStartToCloseTimeout() *wrapperspb.Int32Value

func (*ActivityOptions) ProtoMessage 

func (*ActivityOptions) ProtoMessage()

func (*ActivityOptions) ProtoReflect 

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

func (*ActivityOptions) Reset 

func (x *ActivityOptions) Reset()

func (*ActivityOptions) String 

func (x *ActivityOptions) String() string

type RetryPolicy 

type RetryPolicy struct {

	// Initial interval in seconds for the first retry
	InitialInterval *wrapperspb.Int32Value `protobuf:"bytes,1,opt,name=initial_interval,json=initialInterval,proto3" json:"initial_interval,omitempty"`
	// Backoff coefficient for exponential backoff
	BackoffCoefficient *wrapperspb.FloatValue `protobuf:"bytes,2,opt,name=backoff_coefficient,json=backoffCoefficient,proto3" json:"backoff_coefficient,omitempty"`
	// Max inteval between two retries
	MaximumInterval *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=maximum_interval,json=maximumInterval,proto3" json:"maximum_interval,omitempty"`
	// Maximum of attempts
	MaximumAttempts *wrapperspb.Int32Value `protobuf:"bytes,4,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	// Non retryable error types
	NonRetryableErrorTypes []*wrapperspb.StringValue `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RetryPolicy) Descriptor deprecated 

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

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) GetBackoffCoefficient 

func (x *RetryPolicy) GetBackoffCoefficient() *wrapperspb.FloatValue

func (*RetryPolicy) GetInitialInterval 

func (x *RetryPolicy) GetInitialInterval() *wrapperspb.Int32Value

func (*RetryPolicy) GetMaximumAttempts 

func (x *RetryPolicy) GetMaximumAttempts() *wrapperspb.Int32Value

func (*RetryPolicy) GetMaximumInterval 

func (x *RetryPolicy) GetMaximumInterval() *wrapperspb.Int32Value

func (*RetryPolicy) GetNonRetryableErrorTypes 

func (x *RetryPolicy) GetNonRetryableErrorTypes() []*wrapperspb.StringValue

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) ProtoReflect 

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

func (*RetryPolicy) Reset 

func (x *RetryPolicy) Reset()

func (*RetryPolicy) String 

func (x *RetryPolicy) String() string

type ServiceOptions 

type ServiceOptions struct {
	TaskQueue string `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// These will apply to all workflows unless defined otherwise
	// appart from the `name` one that is ignored here
	DefaultWorkflowOptions *WorkflowOptions `` /* 129-byte string literal not displayed */
	// These settings will apply to all activities unless defined otherwise
	// appart from the `name` one that is ignored here
	DefaultActivityOptions *ActivityOptions `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServiceOptions) Descriptor deprecated 

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

Deprecated: Use ServiceOptions.ProtoReflect.Descriptor instead.

func (*ServiceOptions) GetDefaultActivityOptions 

func (x *ServiceOptions) GetDefaultActivityOptions() *ActivityOptions

func (*ServiceOptions) GetDefaultWorkflowOptions 

func (x *ServiceOptions) GetDefaultWorkflowOptions() *WorkflowOptions

func (*ServiceOptions) GetTaskQueue 

func (x *ServiceOptions) GetTaskQueue() string

func (*ServiceOptions) ProtoMessage 

func (*ServiceOptions) ProtoMessage()

func (*ServiceOptions) ProtoReflect 

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

func (*ServiceOptions) Reset 

func (x *ServiceOptions) Reset()

func (*ServiceOptions) String 

func (x *ServiceOptions) String() string

type WorkflowOptions 

type WorkflowOptions struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Execution timeout for the workflow - in seconds
	WorkflowExecutionTimeout *wrapperspb.Int32Value `` /* 135-byte string literal not displayed */
	// The timeout for duration of a single workflow run - in seconds
	WorkflowRunTimeout *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// The timeout for processing workflow task from the time the worker
	// pulled this task
	WorkflowTaskTimeout *wrapperspb.Int32Value `protobuf:"bytes,4,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// Default retry policy
	RetryPolicy *RetryPolicy `protobuf:"bytes,5,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions) Descriptor deprecated 

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

Deprecated: Use WorkflowOptions.ProtoReflect.Descriptor instead.

func (*WorkflowOptions) GetName 

func (x *WorkflowOptions) GetName() string

func (*WorkflowOptions) GetRetryPolicy 

func (x *WorkflowOptions) GetRetryPolicy() *RetryPolicy

func (*WorkflowOptions) GetWorkflowExecutionTimeout 

func (x *WorkflowOptions) GetWorkflowExecutionTimeout() *wrapperspb.Int32Value

func (*WorkflowOptions) GetWorkflowRunTimeout 

func (x *WorkflowOptions) GetWorkflowRunTimeout() *wrapperspb.Int32Value

func (*WorkflowOptions) GetWorkflowTaskTimeout 

func (x *WorkflowOptions) GetWorkflowTaskTimeout() *wrapperspb.Int32Value

func (*WorkflowOptions) ProtoMessage 

func (*WorkflowOptions) ProtoMessage()

func (*WorkflowOptions) ProtoReflect 

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

func (*WorkflowOptions) Reset 

func (x *WorkflowOptions) Reset()

func (*WorkflowOptions) String 

func (x *WorkflowOptions) 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.