update

package
v1.24.0 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2023 License: MIT Imports: 10 Imported by: 17

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type Acceptance added in v1.16.0 

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"`
}

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

func (*Acceptance) Descriptor added in v1.16.0 

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

func (*Acceptance) Equal added in v1.16.0 

func (this *Acceptance) Equal(that interface{}) bool

func (*Acceptance) GetAcceptedRequest added in v1.16.0 

func (m *Acceptance) GetAcceptedRequest() *Request

func (*Acceptance) GetAcceptedRequestMessageId added in v1.16.0 

func (m *Acceptance) GetAcceptedRequestMessageId() string

func (*Acceptance) GetAcceptedRequestSequencingEventId added in v1.16.0 

func (m *Acceptance) GetAcceptedRequestSequencingEventId() int64

func (*Acceptance) GoString added in v1.16.0 

func (this *Acceptance) GoString() string

func (*Acceptance) Marshal added in v1.16.0 

func (m *Acceptance) Marshal() (dAtA []byte, err error)

func (*Acceptance) MarshalTo added in v1.16.0 

func (m *Acceptance) MarshalTo(dAtA []byte) (int, error)

func (*Acceptance) MarshalToSizedBuffer added in v1.16.0 

func (m *Acceptance) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Acceptance) ProtoMessage added in v1.16.0 

func (*Acceptance) ProtoMessage()

func (*Acceptance) Reset added in v1.16.0 

func (m *Acceptance) Reset()

func (*Acceptance) Size added in v1.16.0 

func (m *Acceptance) Size() (n int)

func (*Acceptance) String added in v1.16.0 

func (this *Acceptance) String() string

func (*Acceptance) Unmarshal added in v1.16.0 

func (m *Acceptance) Unmarshal(dAtA []byte) error

func (*Acceptance) XXX_DiscardUnknown added in v1.16.0 

func (m *Acceptance) XXX_DiscardUnknown()

func (*Acceptance) XXX_Marshal added in v1.16.0 

func (m *Acceptance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Acceptance) XXX_Merge added in v1.16.0 

func (m *Acceptance) XXX_Merge(src proto.Message)

func (*Acceptance) XXX_Size added in v1.16.0 

func (m *Acceptance) XXX_Size() int

func (*Acceptance) XXX_Unmarshal added in v1.16.0 

func (m *Acceptance) XXX_Unmarshal(b []byte) error

type Input added in v1.16.0 

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"`
}

func (*Input) Descriptor added in v1.16.0 

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

func (*Input) Equal added in v1.16.0 

func (this *Input) Equal(that interface{}) bool

func (*Input) GetArgs added in v1.16.0 

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

func (*Input) GetHeader added in v1.16.0 

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

func (*Input) GetName added in v1.16.0 

func (m *Input) GetName() string

func (*Input) GoString added in v1.16.0 

func (this *Input) GoString() string

func (*Input) Marshal added in v1.16.0 

func (m *Input) Marshal() (dAtA []byte, err error)

func (*Input) MarshalTo added in v1.16.0 

func (m *Input) MarshalTo(dAtA []byte) (int, error)

func (*Input) MarshalToSizedBuffer added in v1.16.0 

func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input) ProtoMessage added in v1.16.0 

func (*Input) ProtoMessage()

func (*Input) Reset added in v1.16.0 

func (m *Input) Reset()

func (*Input) Size added in v1.16.0 

func (m *Input) Size() (n int)

func (*Input) String added in v1.16.0 

func (this *Input) String() string

func (*Input) Unmarshal added in v1.16.0 

func (m *Input) Unmarshal(dAtA []byte) error

func (*Input) XXX_DiscardUnknown added in v1.16.0 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal added in v1.16.0 

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge added in v1.16.0 

func (m *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_Size added in v1.16.0 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal added in v1.16.0 

func (m *Input) XXX_Unmarshal(b []byte) error

type Meta added in v1.16.0 

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"`
}

Metadata about a workflow execution update.

func (*Meta) Descriptor added in v1.16.0 

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

func (*Meta) Equal added in v1.16.0 

func (this *Meta) Equal(that interface{}) bool

func (*Meta) GetIdentity added in v1.16.0 

func (m *Meta) GetIdentity() string

func (*Meta) GetUpdateId added in v1.16.0 

func (m *Meta) GetUpdateId() string

func (*Meta) GoString added in v1.16.0 

func (this *Meta) GoString() string

func (*Meta) Marshal added in v1.16.0 

func (m *Meta) Marshal() (dAtA []byte, err error)

func (*Meta) MarshalTo added in v1.16.0 

func (m *Meta) MarshalTo(dAtA []byte) (int, error)

func (*Meta) MarshalToSizedBuffer added in v1.16.0 

func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Meta) ProtoMessage added in v1.16.0 

func (*Meta) ProtoMessage()

func (*Meta) Reset added in v1.16.0 

func (m *Meta) Reset()

func (*Meta) Size added in v1.16.0 

func (m *Meta) Size() (n int)

func (*Meta) String added in v1.16.0 

func (this *Meta) String() string

func (*Meta) Unmarshal added in v1.16.0 

func (m *Meta) Unmarshal(dAtA []byte) error

func (*Meta) XXX_DiscardUnknown added in v1.16.0 

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal added in v1.16.0 

func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Meta) XXX_Merge added in v1.16.0 

func (m *Meta) XXX_Merge(src proto.Message)

func (*Meta) XXX_Size added in v1.16.0 

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal added in v1.16.0 

func (m *Meta) XXX_Unmarshal(b []byte) error

type Outcome added in v1.16.0 

type Outcome struct {
	// Types that are valid to be assigned to Value:
	//	*Outcome_Success
	//	*Outcome_Failure
	Value isOutcome_Value `protobuf_oneof:"value"`
}

The outcome of a workflow update - success or failure.

func (*Outcome) Descriptor added in v1.16.0 

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

func (*Outcome) Equal added in v1.16.0 

func (this *Outcome) Equal(that interface{}) bool

func (*Outcome) GetFailure added in v1.16.0 

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

func (*Outcome) GetSuccess added in v1.16.0 

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

func (*Outcome) GetValue added in v1.16.0 

func (m *Outcome) GetValue() isOutcome_Value

func (*Outcome) GoString added in v1.16.0 

func (this *Outcome) GoString() string

func (*Outcome) Marshal added in v1.16.0 

func (m *Outcome) Marshal() (dAtA []byte, err error)

func (*Outcome) MarshalTo added in v1.16.0 

func (m *Outcome) MarshalTo(dAtA []byte) (int, error)

func (*Outcome) MarshalToSizedBuffer added in v1.16.0 

func (m *Outcome) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Outcome) ProtoMessage added in v1.16.0 

func (*Outcome) ProtoMessage()

func (*Outcome) Reset added in v1.16.0 

func (m *Outcome) Reset()

func (*Outcome) Size added in v1.16.0 

func (m *Outcome) Size() (n int)

func (*Outcome) String added in v1.16.0 

func (this *Outcome) String() string

func (*Outcome) Unmarshal added in v1.16.0 

func (m *Outcome) Unmarshal(dAtA []byte) error

func (*Outcome) XXX_DiscardUnknown added in v1.16.0 

func (m *Outcome) XXX_DiscardUnknown()

func (*Outcome) XXX_Marshal added in v1.16.0 

func (m *Outcome) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Outcome) XXX_Merge added in v1.16.0 

func (m *Outcome) XXX_Merge(src proto.Message)

func (*Outcome) XXX_OneofWrappers added in v1.16.0 

func (*Outcome) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Outcome) XXX_Size added in v1.16.0 

func (m *Outcome) XXX_Size() int

func (*Outcome) XXX_Unmarshal added in v1.16.0 

func (m *Outcome) XXX_Unmarshal(b []byte) error

type Outcome_Failure added in v1.16.0 

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

func (*Outcome_Failure) Equal added in v1.16.0 

func (this *Outcome_Failure) Equal(that interface{}) bool

func (*Outcome_Failure) GoString added in v1.16.0 

func (this *Outcome_Failure) GoString() string

func (*Outcome_Failure) MarshalTo added in v1.16.0 

func (m *Outcome_Failure) MarshalTo(dAtA []byte) (int, error)

func (*Outcome_Failure) MarshalToSizedBuffer added in v1.16.0 

func (m *Outcome_Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Outcome_Failure) Size added in v1.16.0 

func (m *Outcome_Failure) Size() (n int)

func (*Outcome_Failure) String added in v1.16.0 

func (this *Outcome_Failure) String() string

type Outcome_Success added in v1.16.0 

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

func (*Outcome_Success) Equal added in v1.16.0 

func (this *Outcome_Success) Equal(that interface{}) bool

func (*Outcome_Success) GoString added in v1.16.0 

func (this *Outcome_Success) GoString() string

func (*Outcome_Success) MarshalTo added in v1.16.0 

func (m *Outcome_Success) MarshalTo(dAtA []byte) (int, error)

func (*Outcome_Success) MarshalToSizedBuffer added in v1.16.0 

func (m *Outcome_Success) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Outcome_Success) Size added in v1.16.0 

func (m *Outcome_Success) Size() (n int)

func (*Outcome_Success) String added in v1.16.0 

func (this *Outcome_Success) String() string

type Rejection added in v1.16.0 

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"`
}

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

func (*Rejection) Descriptor added in v1.16.0 

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

func (*Rejection) Equal added in v1.16.0 

func (this *Rejection) Equal(that interface{}) bool

func (*Rejection) GetFailure added in v1.16.0 

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

func (*Rejection) GetRejectedRequest added in v1.16.0 

func (m *Rejection) GetRejectedRequest() *Request

func (*Rejection) GetRejectedRequestMessageId added in v1.16.0 

func (m *Rejection) GetRejectedRequestMessageId() string

func (*Rejection) GetRejectedRequestSequencingEventId added in v1.16.0 

func (m *Rejection) GetRejectedRequestSequencingEventId() int64

func (*Rejection) GoString added in v1.16.0 

func (this *Rejection) GoString() string

func (*Rejection) Marshal added in v1.16.0 

func (m *Rejection) Marshal() (dAtA []byte, err error)

func (*Rejection) MarshalTo added in v1.16.0 

func (m *Rejection) MarshalTo(dAtA []byte) (int, error)

func (*Rejection) MarshalToSizedBuffer added in v1.16.0 

func (m *Rejection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Rejection) ProtoMessage added in v1.16.0 

func (*Rejection) ProtoMessage()

func (*Rejection) Reset added in v1.16.0 

func (m *Rejection) Reset()

func (*Rejection) Size added in v1.16.0 

func (m *Rejection) Size() (n int)

func (*Rejection) String added in v1.16.0 

func (this *Rejection) String() string

func (*Rejection) Unmarshal added in v1.16.0 

func (m *Rejection) Unmarshal(dAtA []byte) error

func (*Rejection) XXX_DiscardUnknown added in v1.16.0 

func (m *Rejection) XXX_DiscardUnknown()

func (*Rejection) XXX_Marshal added in v1.16.0 

func (m *Rejection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rejection) XXX_Merge added in v1.16.0 

func (m *Rejection) XXX_Merge(src proto.Message)

func (*Rejection) XXX_Size added in v1.16.0 

func (m *Rejection) XXX_Size() int

func (*Rejection) XXX_Unmarshal added in v1.16.0 

func (m *Rejection) XXX_Unmarshal(b []byte) error

type Request added in v1.16.0 

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"`
}

The client request that triggers a workflow execution update

func (*Request) Descriptor added in v1.16.0 

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

func (*Request) Equal added in v1.16.0 

func (this *Request) Equal(that interface{}) bool

func (*Request) GetInput added in v1.16.0 

func (m *Request) GetInput() *Input

func (*Request) GetMeta added in v1.16.0 

func (m *Request) GetMeta() *Meta

func (*Request) GoString added in v1.16.0 

func (this *Request) GoString() string

func (*Request) Marshal added in v1.16.0 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo added in v1.16.0 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer added in v1.16.0 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage added in v1.16.0 

func (*Request) ProtoMessage()

func (*Request) Reset added in v1.16.0 

func (m *Request) Reset()

func (*Request) Size added in v1.16.0 

func (m *Request) Size() (n int)

func (*Request) String added in v1.16.0 

func (this *Request) String() string

func (*Request) Unmarshal added in v1.16.0 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown added in v1.16.0 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal added in v1.16.0 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge added in v1.16.0 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size added in v1.16.0 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal added in v1.16.0 

func (m *Request) XXX_Unmarshal(b []byte) error

type Response added in v1.16.0 

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"`
}

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

func (*Response) Descriptor added in v1.16.0 

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

func (*Response) Equal added in v1.16.0 

func (this *Response) Equal(that interface{}) bool

func (*Response) GetMeta added in v1.16.0 

func (m *Response) GetMeta() *Meta

func (*Response) GetOutcome added in v1.16.0 

func (m *Response) GetOutcome() *Outcome

func (*Response) GoString added in v1.16.0 

func (this *Response) GoString() string

func (*Response) Marshal added in v1.16.0 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo added in v1.16.0 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer added in v1.16.0 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage added in v1.16.0 

func (*Response) ProtoMessage()

func (*Response) Reset added in v1.16.0 

func (m *Response) Reset()

func (*Response) Size added in v1.16.0 

func (m *Response) Size() (n int)

func (*Response) String added in v1.16.0 

func (this *Response) String() string

func (*Response) Unmarshal added in v1.16.0 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown added in v1.16.0 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal added in v1.16.0 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge added in v1.16.0 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size added in v1.16.0 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal added in v1.16.0 

func (m *Response) XXX_Unmarshal(b []byte) error

type UpdateRef added in v1.16.0 

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"`
}

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

func (*UpdateRef) Descriptor added in v1.16.0 

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

func (*UpdateRef) Equal added in v1.16.0 

func (this *UpdateRef) Equal(that interface{}) bool

func (*UpdateRef) GetUpdateId added in v1.16.0 

func (m *UpdateRef) GetUpdateId() string

func (*UpdateRef) GetWorkflowExecution added in v1.16.0 

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

func (*UpdateRef) GoString added in v1.16.0 

func (this *UpdateRef) GoString() string

func (*UpdateRef) Marshal added in v1.16.0 

func (m *UpdateRef) Marshal() (dAtA []byte, err error)

func (*UpdateRef) MarshalTo added in v1.16.0 

func (m *UpdateRef) MarshalTo(dAtA []byte) (int, error)

func (*UpdateRef) MarshalToSizedBuffer added in v1.16.0 

func (m *UpdateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateRef) ProtoMessage added in v1.16.0 

func (*UpdateRef) ProtoMessage()

func (*UpdateRef) Reset added in v1.16.0 

func (m *UpdateRef) Reset()

func (*UpdateRef) Size added in v1.16.0 

func (m *UpdateRef) Size() (n int)

func (*UpdateRef) String added in v1.16.0 

func (this *UpdateRef) String() string

func (*UpdateRef) Unmarshal added in v1.16.0 

func (m *UpdateRef) Unmarshal(dAtA []byte) error

func (*UpdateRef) XXX_DiscardUnknown added in v1.16.0 

func (m *UpdateRef) XXX_DiscardUnknown()

func (*UpdateRef) XXX_Marshal added in v1.16.0 

func (m *UpdateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateRef) XXX_Merge added in v1.16.0 

func (m *UpdateRef) XXX_Merge(src proto.Message)

func (*UpdateRef) XXX_Size added in v1.16.0 

func (m *UpdateRef) XXX_Size() int

func (*UpdateRef) XXX_Unmarshal added in v1.16.0 

func (m *UpdateRef) XXX_Unmarshal(b []byte) error

type WaitPolicy added in v1.16.0 

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 */
}

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 added in v1.16.0 

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

func (*WaitPolicy) Equal added in v1.16.0 

func (this *WaitPolicy) Equal(that interface{}) bool

func (*WaitPolicy) GetLifecycleStage added in v1.16.0 

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

func (*WaitPolicy) GoString added in v1.16.0 

func (this *WaitPolicy) GoString() string

func (*WaitPolicy) Marshal added in v1.16.0 

func (m *WaitPolicy) Marshal() (dAtA []byte, err error)

func (*WaitPolicy) MarshalTo added in v1.16.0 

func (m *WaitPolicy) MarshalTo(dAtA []byte) (int, error)

func (*WaitPolicy) MarshalToSizedBuffer added in v1.16.0 

func (m *WaitPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitPolicy) ProtoMessage added in v1.16.0 

func (*WaitPolicy) ProtoMessage()

func (*WaitPolicy) Reset added in v1.16.0 

func (m *WaitPolicy) Reset()

func (*WaitPolicy) Size added in v1.16.0 

func (m *WaitPolicy) Size() (n int)

func (*WaitPolicy) String added in v1.16.0 

func (this *WaitPolicy) String() string

func (*WaitPolicy) Unmarshal added in v1.16.0 

func (m *WaitPolicy) Unmarshal(dAtA []byte) error

func (*WaitPolicy) XXX_DiscardUnknown added in v1.16.0 

func (m *WaitPolicy) XXX_DiscardUnknown()

func (*WaitPolicy) XXX_Marshal added in v1.16.0 

func (m *WaitPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitPolicy) XXX_Merge added in v1.16.0 

func (m *WaitPolicy) XXX_Merge(src proto.Message)

func (*WaitPolicy) XXX_Size added in v1.16.0 

func (m *WaitPolicy) XXX_Size() int

func (*WaitPolicy) XXX_Unmarshal added in v1.16.0 

func (m *WaitPolicy) XXX_Unmarshal(b []byte) error

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.