temporalV1

package
v4.17.0 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: MIT Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_v1_temporal_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Frame 

type Frame struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetMessages 

func (x *Frame) GetMessages() []*Message

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect 

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

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type History added in v4.7.0 

type History struct {
	History      *v13.History      `protobuf:"bytes,1,opt,name=history,proto3" json:"history,omitempty"`
	WorkflowType *v11.WorkflowType `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	// contains filtered or unexported fields
}

func (*History) Descriptor deprecated added in v4.7.0 

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

Deprecated: Use History.ProtoReflect.Descriptor instead.

func (*History) GetHistory added in v4.7.0 

func (x *History) GetHistory() *v13.History

func (*History) GetWorkflowType added in v4.7.0 

func (x *History) GetWorkflowType() *v11.WorkflowType

func (*History) ProtoMessage added in v4.7.0 

func (*History) ProtoMessage()

func (*History) ProtoReflect added in v4.7.0 

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

func (*History) Reset added in v4.7.0 

func (x *History) Reset()

func (*History) String added in v4.7.0 

func (x *History) String() string

type Message 

type Message struct {

	// unique ID of the message (counter)
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// command name (if any)
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// command options in json format.
	Options []byte `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// error response.
	Failure *v1.Failure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	// invocation or result payloads.
	Payloads *v11.Payloads `protobuf:"bytes,5,opt,name=payloads,proto3" json:"payloads,omitempty"`
	// invocation or result payloads.
	Header *v11.Header `protobuf:"bytes,6,opt,name=header,proto3" json:"header,omitempty"`
	// workflow history length
	HistoryLength int64 `protobuf:"varint,7,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	// rr_run id
	RunId string `protobuf:"bytes,8,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// task queue name
	TaskQueue string `protobuf:"bytes,9,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// tick time
	TickTime string `protobuf:"bytes,10,opt,name=tick_time,json=tickTime,proto3" json:"tick_time,omitempty"`
	// replay flag
	Replay bool `protobuf:"varint,11,opt,name=replay,proto3" json:"replay,omitempty"`
	// continue as new flag
	ContinueAsNewSuggested bool `` /* 133-byte string literal not displayed */
	// returns the current length of history when called.
	// This value may change throughout the life of the workflow.
	HistorySize int64 `protobuf:"varint,13,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"`
	// contains filtered or unexported fields
}

Single communication message.

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetCommand 

func (x *Message) GetCommand() string

func (*Message) GetContinueAsNewSuggested added in v4.16.0 

func (x *Message) GetContinueAsNewSuggested() bool

func (*Message) GetFailure 

func (x *Message) GetFailure() *v1.Failure

func (*Message) GetHeader 

func (x *Message) GetHeader() *v11.Header

func (*Message) GetHistoryLength 

func (x *Message) GetHistoryLength() int64

func (*Message) GetHistorySize added in v4.16.0 

func (x *Message) GetHistorySize() int64

func (*Message) GetId 

func (x *Message) GetId() uint64

func (*Message) GetOptions 

func (x *Message) GetOptions() []byte

func (*Message) GetPayloads 

func (x *Message) GetPayloads() *v11.Payloads

func (*Message) GetReplay added in v4.16.0 

func (x *Message) GetReplay() bool

func (*Message) GetRunId 

func (x *Message) GetRunId() string

func (*Message) GetTaskQueue added in v4.16.0 

func (x *Message) GetTaskQueue() string

func (*Message) GetTickTime added in v4.16.0 

func (x *Message) GetTickTime() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type ReplayRequest 

type ReplayRequest struct {
	WorkflowExecution *v11.WorkflowExecution `protobuf:"bytes,1,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	WorkflowType      *v11.WorkflowType      `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	SavePath          string                 `protobuf:"bytes,3,opt,name=save_path,json=savePath,proto3" json:"save_path,omitempty"`
	LastEventId       int64                  `protobuf:"varint,4,opt,name=last_event_id,json=lastEventId,proto3" json:"last_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRequest) Descriptor deprecated 

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

Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.

func (*ReplayRequest) GetLastEventId added in v4.6.1 

func (x *ReplayRequest) GetLastEventId() int64

func (*ReplayRequest) GetSavePath 

func (x *ReplayRequest) GetSavePath() string

func (*ReplayRequest) GetWorkflowExecution 

func (x *ReplayRequest) GetWorkflowExecution() *v11.WorkflowExecution

func (*ReplayRequest) GetWorkflowType 

func (x *ReplayRequest) GetWorkflowType() *v11.WorkflowType

func (*ReplayRequest) ProtoMessage 

func (*ReplayRequest) ProtoMessage()

func (*ReplayRequest) ProtoReflect 

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

func (*ReplayRequest) Reset 

func (x *ReplayRequest) Reset()

func (*ReplayRequest) String 

func (x *ReplayRequest) String() string

type ReplayResponse 

type ReplayResponse struct {
	Status *v12.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

https://cloud.google.com/apis/design/errors

func (*ReplayResponse) Descriptor deprecated 

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

Deprecated: Use ReplayResponse.ProtoReflect.Descriptor instead.

func (*ReplayResponse) GetStatus 

func (x *ReplayResponse) GetStatus() *v12.Status

func (*ReplayResponse) ProtoMessage 

func (*ReplayResponse) ProtoMessage()

func (*ReplayResponse) ProtoReflect 

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

func (*ReplayResponse) Reset 

func (x *ReplayResponse) Reset()

func (*ReplayResponse) String 

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