temporalpb

package
v0.0.0-...-cf623d3 Latest Latest
Warning

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

Go to latest
Published: Feb 8, 2023 License: MIT Imports: 6 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// optional temporal.sdk.WorkflowOptions workflow = 7233;
	E_Workflow = &file_temporalpb_sdk_proto_extTypes[0]
	// optional temporal.sdk.ActivityOptions activity = 7234;
	E_Activity = &file_temporalpb_sdk_proto_extTypes[1]
	// optional temporal.sdk.QueryOptions query = 7235;
	E_Query = &file_temporalpb_sdk_proto_extTypes[2]
	// optional temporal.sdk.SignalOptions signal = 7236;
	E_Signal = &file_temporalpb_sdk_proto_extTypes[3]
	// optional temporal.sdk.CallOptions call = 7237;
	E_Call = &file_temporalpb_sdk_proto_extTypes[4]
)

Extension fields to descriptorpb.MethodOptions.

View Source
var File_temporalpb_sdk_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActivityOptions

type ActivityOptions struct {
	DefaultOptions *ActivityOptions_StartOptions `protobuf:"bytes,1,opt,name=default_options,json=defaultOptions,proto3" json:"default_options,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityOptions) Descriptor deprecated

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

Deprecated: Use ActivityOptions.ProtoReflect.Descriptor instead.

func (*ActivityOptions) GetDefaultOptions

func (x *ActivityOptions) GetDefaultOptions() *ActivityOptions_StartOptions

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 ActivityOptions_StartOptions

type ActivityOptions_StartOptions struct {
	TaskQueue              string               `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	StartToCloseTimeout    *durationpb.Duration `protobuf:"bytes,4,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	HeartbeatTimeout       *durationpb.Duration `protobuf:"bytes,5,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"` // TODO(cretz): retry_policy and others
	// contains filtered or unexported fields
}

func (*ActivityOptions_StartOptions) Descriptor deprecated

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

Deprecated: Use ActivityOptions_StartOptions.ProtoReflect.Descriptor instead.

func (*ActivityOptions_StartOptions) GetHeartbeatTimeout

func (x *ActivityOptions_StartOptions) GetHeartbeatTimeout() *durationpb.Duration

func (*ActivityOptions_StartOptions) GetScheduleToCloseTimeout

func (x *ActivityOptions_StartOptions) GetScheduleToCloseTimeout() *durationpb.Duration

func (*ActivityOptions_StartOptions) GetScheduleToStartTimeout

func (x *ActivityOptions_StartOptions) GetScheduleToStartTimeout() *durationpb.Duration

func (*ActivityOptions_StartOptions) GetStartToCloseTimeout

func (x *ActivityOptions_StartOptions) GetStartToCloseTimeout() *durationpb.Duration

func (*ActivityOptions_StartOptions) GetTaskQueue

func (x *ActivityOptions_StartOptions) GetTaskQueue() string

func (*ActivityOptions_StartOptions) ProtoMessage

func (*ActivityOptions_StartOptions) ProtoMessage()

func (*ActivityOptions_StartOptions) ProtoReflect

func (*ActivityOptions_StartOptions) Reset

func (x *ActivityOptions_StartOptions) Reset()

func (*ActivityOptions_StartOptions) String

type CallOptions

type CallOptions struct {
	// contains filtered or unexported fields
}

Calls must have an "id" field and either or both of "response_task_queue" or "response_workflow_id". If "response_task_queue" is not present, the call cannot be made from a top-level client. If "response_workflow_id" is not present, the call cannot be made from another workflow.

func (*CallOptions) Descriptor deprecated

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

Deprecated: Use CallOptions.ProtoReflect.Descriptor instead.

func (*CallOptions) ProtoMessage

func (*CallOptions) ProtoMessage()

func (*CallOptions) ProtoReflect

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

func (*CallOptions) Reset

func (x *CallOptions) Reset()

func (*CallOptions) String

func (x *CallOptions) String() string

type QueryOptions

type QueryOptions struct {
	// contains filtered or unexported fields
}

func (*QueryOptions) Descriptor deprecated

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

Deprecated: Use QueryOptions.ProtoReflect.Descriptor instead.

func (*QueryOptions) ProtoMessage

func (*QueryOptions) ProtoMessage()

func (*QueryOptions) ProtoReflect

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

func (*QueryOptions) Reset

func (x *QueryOptions) Reset()

func (*QueryOptions) String

func (x *QueryOptions) String() string

type SignalOptions

type SignalOptions struct {
	// contains filtered or unexported fields
}

func (*SignalOptions) Descriptor deprecated

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

Deprecated: Use SignalOptions.ProtoReflect.Descriptor instead.

func (*SignalOptions) ProtoMessage

func (*SignalOptions) ProtoMessage()

func (*SignalOptions) ProtoReflect

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

func (*SignalOptions) Reset

func (x *SignalOptions) Reset()

func (*SignalOptions) String

func (x *SignalOptions) String() string

type WorkflowOptions

type WorkflowOptions struct {
	Query           []*WorkflowOptions_Query      `protobuf:"bytes,1,rep,name=query,proto3" json:"query,omitempty"`
	Signal          []*WorkflowOptions_Signal     `protobuf:"bytes,2,rep,name=signal,proto3" json:"signal,omitempty"`
	Call            []*WorkflowOptions_Call       `protobuf:"bytes,3,rep,name=call,proto3" json:"call,omitempty"`
	SignalStart     *WorkflowOptions_SignalStart  `protobuf:"bytes,4,opt,name=signal_start,json=signalStart,proto3" json:"signal_start,omitempty"`
	WorkflowIdField string                        `protobuf:"bytes,5,opt,name=workflow_id_field,json=workflowIdField,proto3" json:"workflow_id_field,omitempty"`
	DefaultOptions  *WorkflowOptions_StartOptions `protobuf:"bytes,6,opt,name=default_options,json=defaultOptions,proto3" json:"default_options,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions) Descriptor deprecated

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

Deprecated: Use WorkflowOptions.ProtoReflect.Descriptor instead.

func (*WorkflowOptions) GetCall

func (x *WorkflowOptions) GetCall() []*WorkflowOptions_Call

func (*WorkflowOptions) GetDefaultOptions

func (x *WorkflowOptions) GetDefaultOptions() *WorkflowOptions_StartOptions

func (*WorkflowOptions) GetQuery

func (x *WorkflowOptions) GetQuery() []*WorkflowOptions_Query

func (*WorkflowOptions) GetSignal

func (x *WorkflowOptions) GetSignal() []*WorkflowOptions_Signal

func (*WorkflowOptions) GetSignalStart

func (x *WorkflowOptions) GetSignalStart() *WorkflowOptions_SignalStart

func (*WorkflowOptions) GetWorkflowIdField

func (x *WorkflowOptions) GetWorkflowIdField() string

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

type WorkflowOptions_Call

type WorkflowOptions_Call struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions_Call) Descriptor deprecated

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

Deprecated: Use WorkflowOptions_Call.ProtoReflect.Descriptor instead.

func (*WorkflowOptions_Call) GetRef

func (x *WorkflowOptions_Call) GetRef() string

func (*WorkflowOptions_Call) ProtoMessage

func (*WorkflowOptions_Call) ProtoMessage()

func (*WorkflowOptions_Call) ProtoReflect

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

func (*WorkflowOptions_Call) Reset

func (x *WorkflowOptions_Call) Reset()

func (*WorkflowOptions_Call) String

func (x *WorkflowOptions_Call) String() string

type WorkflowOptions_Query

type WorkflowOptions_Query struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions_Query) Descriptor deprecated

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

Deprecated: Use WorkflowOptions_Query.ProtoReflect.Descriptor instead.

func (*WorkflowOptions_Query) GetRef

func (x *WorkflowOptions_Query) GetRef() string

func (*WorkflowOptions_Query) ProtoMessage

func (*WorkflowOptions_Query) ProtoMessage()

func (*WorkflowOptions_Query) ProtoReflect

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

func (*WorkflowOptions_Query) Reset

func (x *WorkflowOptions_Query) Reset()

func (*WorkflowOptions_Query) String

func (x *WorkflowOptions_Query) String() string

type WorkflowOptions_Signal

type WorkflowOptions_Signal struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions_Signal) Descriptor deprecated

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

Deprecated: Use WorkflowOptions_Signal.ProtoReflect.Descriptor instead.

func (*WorkflowOptions_Signal) GetRef

func (x *WorkflowOptions_Signal) GetRef() string

func (*WorkflowOptions_Signal) ProtoMessage

func (*WorkflowOptions_Signal) ProtoMessage()

func (*WorkflowOptions_Signal) ProtoReflect

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

func (*WorkflowOptions_Signal) Reset

func (x *WorkflowOptions_Signal) Reset()

func (*WorkflowOptions_Signal) String

func (x *WorkflowOptions_Signal) String() string

type WorkflowOptions_SignalStart

type WorkflowOptions_SignalStart struct {
	Ref string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowOptions_SignalStart) Descriptor deprecated

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

Deprecated: Use WorkflowOptions_SignalStart.ProtoReflect.Descriptor instead.

func (*WorkflowOptions_SignalStart) GetRef

func (x *WorkflowOptions_SignalStart) GetRef() string

func (*WorkflowOptions_SignalStart) ProtoMessage

func (*WorkflowOptions_SignalStart) ProtoMessage()

func (*WorkflowOptions_SignalStart) ProtoReflect

func (*WorkflowOptions_SignalStart) Reset

func (x *WorkflowOptions_SignalStart) Reset()

func (*WorkflowOptions_SignalStart) String

func (x *WorkflowOptions_SignalStart) String() string

type WorkflowOptions_StartOptions

type WorkflowOptions_StartOptions struct {
	TaskQueue string `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` // TODO(cretz): retry_policy and others
	// contains filtered or unexported fields
}

func (*WorkflowOptions_StartOptions) Descriptor deprecated

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

Deprecated: Use WorkflowOptions_StartOptions.ProtoReflect.Descriptor instead.

func (*WorkflowOptions_StartOptions) GetTaskQueue

func (x *WorkflowOptions_StartOptions) GetTaskQueue() string

func (*WorkflowOptions_StartOptions) ProtoMessage

func (*WorkflowOptions_StartOptions) ProtoMessage()

func (*WorkflowOptions_StartOptions) ProtoReflect

func (*WorkflowOptions_StartOptions) Reset

func (x *WorkflowOptions_StartOptions) Reset()

func (*WorkflowOptions_StartOptions) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL