xnsv1

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IDReusePolicy_name = map[int32]string{
		0: "WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED",
		1: "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE",
		2: "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY",
		3: "WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE",
		4: "WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING",
	}
	IDReusePolicy_value = map[string]int32{
		"WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED":                 0,
		"WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE":             1,
		"WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY": 2,
		"WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE":            3,
		"WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING":        4,
	}
)

Enum value maps for IDReusePolicy.

View Source 
var (
	ParentClosePolicy_name = map[int32]string{
		0: "PARENT_CLOSE_POLICY_UNSPECIFIED",
		1: "PARENT_CLOSE_POLICY_TERMINATE",
		2: "PARENT_CLOSE_POLICY_ABANDON",
		3: "PARENT_CLOSE_POLICY_REQUEST_CANCEL",
	}
	ParentClosePolicy_value = map[string]int32{
		"PARENT_CLOSE_POLICY_UNSPECIFIED":    0,
		"PARENT_CLOSE_POLICY_TERMINATE":      1,
		"PARENT_CLOSE_POLICY_ABANDON":        2,
		"PARENT_CLOSE_POLICY_REQUEST_CANCEL": 3,
	}
)

Enum value maps for ParentClosePolicy.

View Source 
var (
	WaitPolicy_name = map[int32]string{
		0: "WAIT_POLICY_UNSPECIFIED",
		1: "WAIT_POLICY_ADMITTED",
		2: "WAIT_POLICY_ACCEPTED",
		3: "WAIT_POLICY_COMPLETED",
	}
	WaitPolicy_value = map[string]int32{
		"WAIT_POLICY_UNSPECIFIED": 0,
		"WAIT_POLICY_ADMITTED":    1,
		"WAIT_POLICY_ACCEPTED":    2,
		"WAIT_POLICY_COMPLETED":   3,
	}
)

Enum value maps for WaitPolicy.

View Source 
var File_temporal_xns_v1_xns_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type IDReusePolicy 

type IDReusePolicy int32
const (
	IDReusePolicy_WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED IDReusePolicy = 0
	// Allow starting a workflow execution using the same workflow id.
	IDReusePolicy_WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE IDReusePolicy = 1
	// Allow starting a workflow execution using the same workflow id, only when the last
	// execution's final state is one of [terminated, cancelled, timed out, failed].
	IDReusePolicy_WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY IDReusePolicy = 2
	// Do not permit re-use of the workflow id for this workflow. Future start workflow requests
	// could potentially change the policy, allowing re-use of the workflow id.
	IDReusePolicy_WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE IDReusePolicy = 3
	// If a workflow is running using the same workflow ID, terminate it and start a new one.
	// If no running workflow, then the behavior is the same as ALLOW_DUPLICATE
	IDReusePolicy_WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING IDReusePolicy = 4
)

func (IDReusePolicy) Descriptor 

func (IDReusePolicy) Descriptor() protoreflect.EnumDescriptor

func (IDReusePolicy) Enum 

func (x IDReusePolicy) Enum() *IDReusePolicy

func (IDReusePolicy) EnumDescriptor deprecated 

func (IDReusePolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use IDReusePolicy.Descriptor instead.

func (IDReusePolicy) Number 

func (x IDReusePolicy) Number() protoreflect.EnumNumber

func (IDReusePolicy) String 

func (x IDReusePolicy) String() string

func (IDReusePolicy) Type 

func (IDReusePolicy) Type() protoreflect.EnumType

type ParentClosePolicy 

type ParentClosePolicy int32

Defines how child workflows will react to their parent completing 

const (
	ParentClosePolicy_PARENT_CLOSE_POLICY_UNSPECIFIED ParentClosePolicy = 0
	// The child workflow will also terminate
	ParentClosePolicy_PARENT_CLOSE_POLICY_TERMINATE ParentClosePolicy = 1
	// The child workflow will do nothing
	ParentClosePolicy_PARENT_CLOSE_POLICY_ABANDON ParentClosePolicy = 2
	// Cancellation will be requested of the child workflow
	ParentClosePolicy_PARENT_CLOSE_POLICY_REQUEST_CANCEL ParentClosePolicy = 3
)

func (ParentClosePolicy) Descriptor 

func (ParentClosePolicy) Descriptor() protoreflect.EnumDescriptor

func (ParentClosePolicy) Enum 

func (x ParentClosePolicy) Enum() *ParentClosePolicy

func (ParentClosePolicy) EnumDescriptor deprecated 

func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use ParentClosePolicy.Descriptor instead.

func (ParentClosePolicy) Number 

func (x ParentClosePolicy) Number() protoreflect.EnumNumber

func (ParentClosePolicy) String 

func (x ParentClosePolicy) String() string

func (ParentClosePolicy) Type 

func (ParentClosePolicy) Type() protoreflect.EnumType

type QueryRequest 

type QueryRequest struct {
	RunId             string               `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowId        string               `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Request           *anypb.Any           `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// contains filtered or unexported fields
}

QueryRequest can be used to configure xns query activities

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetHeartbeatInterval 

func (x *QueryRequest) GetHeartbeatInterval() *durationpb.Duration

func (*QueryRequest) GetRequest 

func (x *QueryRequest) GetRequest() *anypb.Any

func (*QueryRequest) GetRunId 

func (x *QueryRequest) GetRunId() string

func (*QueryRequest) GetWorkflowId 

func (x *QueryRequest) GetWorkflowId() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type RetryPolicy 

type RetryPolicy struct {
	InitialInterval        *durationpb.Duration `protobuf:"bytes,1,opt,name=initial_interval,json=initialInterval,proto3" json:"initial_interval,omitempty"`
	BackoffCoefficient     float64              `protobuf:"fixed64,2,opt,name=backoff_coefficient,json=backoffCoefficient,proto3" json:"backoff_coefficient,omitempty"`
	MaxInterval            *durationpb.Duration `protobuf:"bytes,3,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`
	MaxAttempts            int32                `protobuf:"varint,4,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	NonRetryableErrorTypes []string             `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

RetryPolicy describes configuration for activity or child workflow retries

func (*RetryPolicy) Descriptor deprecated 

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

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) GetBackoffCoefficient 

func (x *RetryPolicy) GetBackoffCoefficient() float64

func (*RetryPolicy) GetInitialInterval 

func (x *RetryPolicy) GetInitialInterval() *durationpb.Duration

func (*RetryPolicy) GetMaxAttempts 

func (x *RetryPolicy) GetMaxAttempts() int32

func (*RetryPolicy) GetMaxInterval 

func (x *RetryPolicy) GetMaxInterval() *durationpb.Duration

func (*RetryPolicy) GetNonRetryableErrorTypes 

func (x *RetryPolicy) GetNonRetryableErrorTypes() []string

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 SignalRequest 

type SignalRequest struct {
	RunId             string               `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowId        string               `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Request           *anypb.Any           `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// contains filtered or unexported fields
}

SignalRequest can be used to configure xns signal activities

func (*SignalRequest) Descriptor deprecated 

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

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetHeartbeatInterval 

func (x *SignalRequest) GetHeartbeatInterval() *durationpb.Duration

func (*SignalRequest) GetRequest 

func (x *SignalRequest) GetRequest() *anypb.Any

func (*SignalRequest) GetRunId 

func (x *SignalRequest) GetRunId() string

func (*SignalRequest) GetWorkflowId 

func (x *SignalRequest) GetWorkflowId() string

func (*SignalRequest) ProtoMessage 

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) ProtoReflect 

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

func (*SignalRequest) Reset 

func (x *SignalRequest) Reset()

func (*SignalRequest) String 

func (x *SignalRequest) String() string

type StartWorkflowOptions 

type StartWorkflowOptions struct {
	Id                      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskQueue               string               `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	ExecutionTimeout        *durationpb.Duration `protobuf:"bytes,3,opt,name=execution_timeout,json=executionTimeout,proto3" json:"execution_timeout,omitempty"`
	RunTimeout              *durationpb.Duration `protobuf:"bytes,4,opt,name=run_timeout,json=runTimeout,proto3" json:"run_timeout,omitempty"`
	TaskTimeout             *durationpb.Duration `protobuf:"bytes,5,opt,name=task_timeout,json=taskTimeout,proto3" json:"task_timeout,omitempty"`
	IdReusePolicy           IDReusePolicy        `` /* 138-byte string literal not displayed */
	ErrorWhenAlreadyStarted bool                 `` /* 135-byte string literal not displayed */
	RetryPolicy             *RetryPolicy         `protobuf:"bytes,8,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	Memo                    *structpb.Struct     `protobuf:"bytes,9,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttirbutes        *structpb.Struct     `protobuf:"bytes,10,opt,name=search_attirbutes,json=searchAttirbutes,proto3" json:"search_attirbutes,omitempty"`
	EnableEagerStart        bool                 `protobuf:"varint,11,opt,name=enable_eager_start,json=enableEagerStart,proto3" json:"enable_eager_start,omitempty"`
	StartDelay              *durationpb.Duration `protobuf:"bytes,12,opt,name=start_delay,json=startDelay,proto3" json:"start_delay,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowOptions) Descriptor deprecated 

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

Deprecated: Use StartWorkflowOptions.ProtoReflect.Descriptor instead.

func (*StartWorkflowOptions) GetEnableEagerStart 

func (x *StartWorkflowOptions) GetEnableEagerStart() bool

func (*StartWorkflowOptions) GetErrorWhenAlreadyStarted 

func (x *StartWorkflowOptions) GetErrorWhenAlreadyStarted() bool

func (*StartWorkflowOptions) GetExecutionTimeout 

func (x *StartWorkflowOptions) GetExecutionTimeout() *durationpb.Duration

func (*StartWorkflowOptions) GetId 

func (x *StartWorkflowOptions) GetId() string

func (*StartWorkflowOptions) GetIdReusePolicy 

func (x *StartWorkflowOptions) GetIdReusePolicy() IDReusePolicy

func (*StartWorkflowOptions) GetMemo 

func (x *StartWorkflowOptions) GetMemo() *structpb.Struct

func (*StartWorkflowOptions) GetRetryPolicy 

func (x *StartWorkflowOptions) GetRetryPolicy() *RetryPolicy

func (*StartWorkflowOptions) GetRunTimeout 

func (x *StartWorkflowOptions) GetRunTimeout() *durationpb.Duration

func (*StartWorkflowOptions) GetSearchAttirbutes 

func (x *StartWorkflowOptions) GetSearchAttirbutes() *structpb.Struct

func (*StartWorkflowOptions) GetStartDelay 

func (x *StartWorkflowOptions) GetStartDelay() *durationpb.Duration

func (*StartWorkflowOptions) GetTaskQueue 

func (x *StartWorkflowOptions) GetTaskQueue() string

func (*StartWorkflowOptions) GetTaskTimeout 

func (x *StartWorkflowOptions) GetTaskTimeout() *durationpb.Duration

func (*StartWorkflowOptions) ProtoMessage 

func (*StartWorkflowOptions) ProtoMessage()

func (*StartWorkflowOptions) ProtoReflect 

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

func (*StartWorkflowOptions) Reset 

func (x *StartWorkflowOptions) Reset()

func (*StartWorkflowOptions) String 

func (x *StartWorkflowOptions) String() string

type UpdateRequest 

type UpdateRequest struct {
	HeartbeatInterval     *durationpb.Duration              `protobuf:"bytes,1,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	UpdateWorkflowOptions *UpdateWorkflowWithOptionsRequest `` /* 126-byte string literal not displayed */
	Request               *anypb.Any                        `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

UpdateRequest can be used to configure xns update activities

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetHeartbeatInterval 

func (x *UpdateRequest) GetHeartbeatInterval() *durationpb.Duration

func (*UpdateRequest) GetRequest 

func (x *UpdateRequest) GetRequest() *anypb.Any

func (*UpdateRequest) GetUpdateWorkflowOptions 

func (x *UpdateRequest) GetUpdateWorkflowOptions() *UpdateWorkflowWithOptionsRequest

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateWorkflowWithOptionsRequest 

type UpdateWorkflowWithOptionsRequest struct {
	UpdateId            string     `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
	WorkflowId          string     `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId               string     `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	FirstExecutionRunId string     `protobuf:"bytes,4,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	WaitPolicy          WaitPolicy `protobuf:"varint,5,opt,name=wait_policy,json=waitPolicy,proto3,enum=temporal.xns.v1.WaitPolicy" json:"wait_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkflowWithOptionsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowWithOptionsRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowWithOptionsRequest) GetFirstExecutionRunId 

func (x *UpdateWorkflowWithOptionsRequest) GetFirstExecutionRunId() string

func (*UpdateWorkflowWithOptionsRequest) GetRunId 

func (x *UpdateWorkflowWithOptionsRequest) GetRunId() string

func (*UpdateWorkflowWithOptionsRequest) GetUpdateId 

func (x *UpdateWorkflowWithOptionsRequest) GetUpdateId() string

func (*UpdateWorkflowWithOptionsRequest) GetWaitPolicy 

func (x *UpdateWorkflowWithOptionsRequest) GetWaitPolicy() WaitPolicy

func (*UpdateWorkflowWithOptionsRequest) GetWorkflowId 

func (x *UpdateWorkflowWithOptionsRequest) GetWorkflowId() string

func (*UpdateWorkflowWithOptionsRequest) ProtoMessage 

func (*UpdateWorkflowWithOptionsRequest) ProtoMessage()

func (*UpdateWorkflowWithOptionsRequest) ProtoReflect 

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

func (*UpdateWorkflowWithOptionsRequest) Reset 

func (x *UpdateWorkflowWithOptionsRequest) Reset()

func (*UpdateWorkflowWithOptionsRequest) String 

func (x *UpdateWorkflowWithOptionsRequest) String() string

type WaitPolicy 

type WaitPolicy int32

WaitPolicy used to indicate to the server how long the client wishes to wait for a return value from an UpdateWorkflow RPC 

const (
	WaitPolicy_WAIT_POLICY_UNSPECIFIED WaitPolicy = 0
	WaitPolicy_WAIT_POLICY_ADMITTED    WaitPolicy = 1
	WaitPolicy_WAIT_POLICY_ACCEPTED    WaitPolicy = 2
	WaitPolicy_WAIT_POLICY_COMPLETED   WaitPolicy = 3
)

func (WaitPolicy) Descriptor 

func (WaitPolicy) Descriptor() protoreflect.EnumDescriptor

func (WaitPolicy) Enum 

func (x WaitPolicy) Enum() *WaitPolicy

func (WaitPolicy) EnumDescriptor deprecated 

func (WaitPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use WaitPolicy.Descriptor instead.

func (WaitPolicy) Number 

func (x WaitPolicy) Number() protoreflect.EnumNumber

func (WaitPolicy) String 

func (x WaitPolicy) String() string

func (WaitPolicy) Type 

func (WaitPolicy) Type() protoreflect.EnumType

type WorkflowRequest 

type WorkflowRequest struct {
	HeartbeatInterval    *durationpb.Duration  `protobuf:"bytes,1,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	StartWorkflowOptions *StartWorkflowOptions `protobuf:"bytes,2,opt,name=start_workflow_options,json=startWorkflowOptions,proto3" json:"start_workflow_options,omitempty"`
	Request              *anypb.Any            `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	Detached             bool                  `protobuf:"varint,4,opt,name=detached,proto3" json:"detached,omitempty"`
	Signal               *anypb.Any            `protobuf:"bytes,5,opt,name=signal,proto3" json:"signal,omitempty"`
	// contains filtered or unexported fields
}

WorkflowRequest can be used to configure xns workflow activities

func (*WorkflowRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.

func (*WorkflowRequest) GetDetached 

func (x *WorkflowRequest) GetDetached() bool

func (*WorkflowRequest) GetHeartbeatInterval 

func (x *WorkflowRequest) GetHeartbeatInterval() *durationpb.Duration

func (*WorkflowRequest) GetRequest 

func (x *WorkflowRequest) GetRequest() *anypb.Any

func (*WorkflowRequest) GetSignal 

func (x *WorkflowRequest) GetSignal() *anypb.Any

func (*WorkflowRequest) GetStartWorkflowOptions 

func (x *WorkflowRequest) GetStartWorkflowOptions() *StartWorkflowOptions

func (*WorkflowRequest) ProtoMessage 

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) ProtoReflect 

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

func (*WorkflowRequest) Reset 

func (x *WorkflowRequest) Reset()

func (*WorkflowRequest) String 

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