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 (x *ActivityOptions_StartOptions) ProtoReflect() protoreflect.Message

func (*ActivityOptions_StartOptions) Reset 

func (x *ActivityOptions_StartOptions) Reset()

func (*ActivityOptions_StartOptions) String 

func (x *ActivityOptions_StartOptions) String() 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 (x *WorkflowOptions_SignalStart) ProtoReflect() protoreflect.Message

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 (x *WorkflowOptions_StartOptions) ProtoReflect() protoreflect.Message

func (*WorkflowOptions_StartOptions) Reset 

func (x *WorkflowOptions_StartOptions) Reset()

func (*WorkflowOptions_StartOptions) String 

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