updatev1

package
v1.33.0-20230419173345... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_api_update_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Acceptance 

type Acceptance struct {
	AcceptedRequestMessageId         string   `` /* 137-byte string literal not displayed */
	AcceptedRequestSequencingEventId int64    `` /* 164-byte string literal not displayed */
	AcceptedRequest                  *Request `protobuf:"bytes,3,opt,name=accepted_request,json=acceptedRequest,proto3" json:"accepted_request,omitempty"`
	// contains filtered or unexported fields
}

An update protocol message indicating that a workflow execution update has been accepted (i.e. passed the worker-side validation phase).

func (*Acceptance) Descriptor deprecated 

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

Deprecated: Use Acceptance.ProtoReflect.Descriptor instead.

func (*Acceptance) GetAcceptedRequest 

func (x *Acceptance) GetAcceptedRequest() *Request

func (*Acceptance) GetAcceptedRequestMessageId 

func (x *Acceptance) GetAcceptedRequestMessageId() string

func (*Acceptance) GetAcceptedRequestSequencingEventId 

func (x *Acceptance) GetAcceptedRequestSequencingEventId() int64

func (*Acceptance) ProtoMessage 

func (*Acceptance) ProtoMessage()

func (*Acceptance) ProtoReflect 

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

func (*Acceptance) Reset 

func (x *Acceptance) Reset()

func (*Acceptance) String 

func (x *Acceptance) String() string

type Input 

type Input struct {

	// Headers that are passed with the update from the requesting entity.
	// These can include things like auth or tracing tokens.
	Header *v11.Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// The name of the input handler to invoke on the target workflow
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The arguments to pass to the named handler.
	Args *v11.Payloads `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*Input) Descriptor deprecated 

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

Deprecated: Use Input.ProtoReflect.Descriptor instead.

func (*Input) GetArgs 

func (x *Input) GetArgs() *v11.Payloads

func (*Input) GetHeader 

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

func (*Input) GetName 

func (x *Input) GetName() string

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) ProtoReflect 

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

func (*Input) Reset 

func (x *Input) Reset()

func (*Input) String 

func (x *Input) String() string

type Meta 

type Meta struct {

	// An ID with workflow-scoped uniqueness for this update
	UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
	// A string identifying the agent that requested this update.
	Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

Metadata about a workflow execution update.

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetIdentity 

func (x *Meta) GetIdentity() string

func (*Meta) GetUpdateId 

func (x *Meta) GetUpdateId() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

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

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type Outcome 

type Outcome struct {

	// Types that are assignable to Value:
	//
	//	*Outcome_Success
	//	*Outcome_Failure
	Value isOutcome_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

The outcome of a workflow update - success or failure.

func (*Outcome) Descriptor deprecated 

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

Deprecated: Use Outcome.ProtoReflect.Descriptor instead.

func (*Outcome) GetFailure 

func (x *Outcome) GetFailure() *v12.Failure

func (*Outcome) GetSuccess 

func (x *Outcome) GetSuccess() *v11.Payloads

func (*Outcome) GetValue 

func (m *Outcome) GetValue() isOutcome_Value

func (*Outcome) ProtoMessage 

func (*Outcome) ProtoMessage()

func (*Outcome) ProtoReflect 

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

func (*Outcome) Reset 

func (x *Outcome) Reset()

func (*Outcome) String 

func (x *Outcome) String() string

type Outcome_Failure 

type Outcome_Failure struct {
	Failure *v12.Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type Outcome_Success 

type Outcome_Success struct {
	Success *v11.Payloads `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type Rejection 

type Rejection struct {
	RejectedRequestMessageId         string       `` /* 137-byte string literal not displayed */
	RejectedRequestSequencingEventId int64        `` /* 164-byte string literal not displayed */
	RejectedRequest                  *Request     `protobuf:"bytes,3,opt,name=rejected_request,json=rejectedRequest,proto3" json:"rejected_request,omitempty"`
	Failure                          *v12.Failure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

An update protocol message indicating that a workflow execution update has been rejected.

func (*Rejection) Descriptor deprecated 

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

Deprecated: Use Rejection.ProtoReflect.Descriptor instead.

func (*Rejection) GetFailure 

func (x *Rejection) GetFailure() *v12.Failure

func (*Rejection) GetRejectedRequest 

func (x *Rejection) GetRejectedRequest() *Request

func (*Rejection) GetRejectedRequestMessageId 

func (x *Rejection) GetRejectedRequestMessageId() string

func (*Rejection) GetRejectedRequestSequencingEventId 

func (x *Rejection) GetRejectedRequestSequencingEventId() int64

func (*Rejection) ProtoMessage 

func (*Rejection) ProtoMessage()

func (*Rejection) ProtoReflect 

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

func (*Rejection) Reset 

func (x *Rejection) Reset()

func (*Rejection) String 

func (x *Rejection) String() string

type Request 

type Request struct {
	Meta  *Meta  `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Input *Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

The client request that triggers a workflow execution update

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetInput 

func (x *Request) GetInput() *Input

func (*Request) GetMeta 

func (x *Request) GetMeta() *Meta

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Meta    *Meta    `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Outcome *Outcome `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

An update protocol message indicating that a workflow execution update has completed with the contained outcome.

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMeta 

func (x *Response) GetMeta() *Meta

func (*Response) GetOutcome 

func (x *Response) GetOutcome() *Outcome

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type UpdateRef 

type UpdateRef struct {
	WorkflowExecution *v11.WorkflowExecution `protobuf:"bytes,1,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	UpdateId          string                 `protobuf:"bytes,2,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
	// contains filtered or unexported fields
}

The data needed by a client to refer to an previously invoked workflow execution update process.

func (*UpdateRef) Descriptor deprecated 

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

Deprecated: Use UpdateRef.ProtoReflect.Descriptor instead.

func (*UpdateRef) GetUpdateId 

func (x *UpdateRef) GetUpdateId() string

func (*UpdateRef) GetWorkflowExecution 

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

func (*UpdateRef) ProtoMessage 

func (*UpdateRef) ProtoMessage()

func (*UpdateRef) ProtoReflect 

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

func (*UpdateRef) Reset 

func (x *UpdateRef) Reset()

func (*UpdateRef) String 

func (x *UpdateRef) String() string

type WaitPolicy 

type WaitPolicy struct {

	// Indicates the update lifecycle stage that the gRPC call should wait for
	// before returning.
	LifecycleStage v1.UpdateWorkflowExecutionLifecycleStage `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

Specifies to the gRPC server how long the client wants the an update-related RPC call to wait before returning control to the caller.

func (*WaitPolicy) Descriptor deprecated 

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

Deprecated: Use WaitPolicy.ProtoReflect.Descriptor instead.

func (*WaitPolicy) GetLifecycleStage 

func (x *WaitPolicy) GetLifecycleStage() v1.UpdateWorkflowExecutionLifecycleStage

func (*WaitPolicy) ProtoMessage 

func (*WaitPolicy) ProtoMessage()

func (*WaitPolicy) ProtoReflect 

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

func (*WaitPolicy) Reset 

func (x *WaitPolicy) Reset()

func (*WaitPolicy) String 

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