Documentation ¶
Index ¶
- Variables
- type Acceptance
- func (*Acceptance) Descriptor() ([]byte, []int)
- func (this *Acceptance) Equal(that interface{}) bool
- func (m *Acceptance) GetAcceptedRequest() *Request
- func (m *Acceptance) GetAcceptedRequestMessageId() string
- func (m *Acceptance) GetAcceptedRequestSequencingEventId() int64
- func (this *Acceptance) GoString() string
- func (m *Acceptance) Marshal() (dAtA []byte, err error)
- func (m *Acceptance) MarshalTo(dAtA []byte) (int, error)
- func (m *Acceptance) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Acceptance) ProtoMessage()
- func (m *Acceptance) Reset()
- func (m *Acceptance) Size() (n int)
- func (this *Acceptance) String() string
- func (m *Acceptance) Unmarshal(dAtA []byte) error
- func (m *Acceptance) XXX_DiscardUnknown()
- func (m *Acceptance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Acceptance) XXX_Merge(src proto.Message)
- func (m *Acceptance) XXX_Size() int
- func (m *Acceptance) XXX_Unmarshal(b []byte) error
- type Input
- func (*Input) Descriptor() ([]byte, []int)
- func (this *Input) Equal(that interface{}) bool
- func (m *Input) GetArgs() *v11.Payloads
- func (m *Input) GetHeader() *v11.Header
- func (m *Input) GetName() string
- func (this *Input) GoString() string
- func (m *Input) Marshal() (dAtA []byte, err error)
- func (m *Input) MarshalTo(dAtA []byte) (int, error)
- func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Input) ProtoMessage()
- func (m *Input) Reset()
- func (m *Input) Size() (n int)
- func (this *Input) String() string
- func (m *Input) Unmarshal(dAtA []byte) error
- func (m *Input) XXX_DiscardUnknown()
- func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Input) XXX_Merge(src proto.Message)
- func (m *Input) XXX_Size() int
- func (m *Input) XXX_Unmarshal(b []byte) error
- type Meta
- func (*Meta) Descriptor() ([]byte, []int)
- func (this *Meta) Equal(that interface{}) bool
- func (m *Meta) GetIdentity() string
- func (m *Meta) GetUpdateId() string
- func (this *Meta) GoString() string
- func (m *Meta) Marshal() (dAtA []byte, err error)
- func (m *Meta) MarshalTo(dAtA []byte) (int, error)
- func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Meta) ProtoMessage()
- func (m *Meta) Reset()
- func (m *Meta) Size() (n int)
- func (this *Meta) String() string
- func (m *Meta) Unmarshal(dAtA []byte) error
- func (m *Meta) XXX_DiscardUnknown()
- func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Meta) XXX_Merge(src proto.Message)
- func (m *Meta) XXX_Size() int
- func (m *Meta) XXX_Unmarshal(b []byte) error
- type Outcome
- func (*Outcome) Descriptor() ([]byte, []int)
- func (this *Outcome) Equal(that interface{}) bool
- func (m *Outcome) GetFailure() *v12.Failure
- func (m *Outcome) GetSuccess() *v11.Payloads
- func (m *Outcome) GetValue() isOutcome_Value
- func (this *Outcome) GoString() string
- func (m *Outcome) Marshal() (dAtA []byte, err error)
- func (m *Outcome) MarshalTo(dAtA []byte) (int, error)
- func (m *Outcome) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Outcome) ProtoMessage()
- func (m *Outcome) Reset()
- func (m *Outcome) Size() (n int)
- func (this *Outcome) String() string
- func (m *Outcome) Unmarshal(dAtA []byte) error
- func (m *Outcome) XXX_DiscardUnknown()
- func (m *Outcome) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Outcome) XXX_Merge(src proto.Message)
- func (*Outcome) XXX_OneofWrappers() []interface{}
- func (m *Outcome) XXX_Size() int
- func (m *Outcome) XXX_Unmarshal(b []byte) error
- type Outcome_Failure
- func (this *Outcome_Failure) Equal(that interface{}) bool
- func (this *Outcome_Failure) GoString() string
- func (m *Outcome_Failure) MarshalTo(dAtA []byte) (int, error)
- func (m *Outcome_Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Outcome_Failure) Size() (n int)
- func (this *Outcome_Failure) String() string
- type Outcome_Success
- func (this *Outcome_Success) Equal(that interface{}) bool
- func (this *Outcome_Success) GoString() string
- func (m *Outcome_Success) MarshalTo(dAtA []byte) (int, error)
- func (m *Outcome_Success) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Outcome_Success) Size() (n int)
- func (this *Outcome_Success) String() string
- type Rejection
- func (*Rejection) Descriptor() ([]byte, []int)
- func (this *Rejection) Equal(that interface{}) bool
- func (m *Rejection) GetFailure() *v12.Failure
- func (m *Rejection) GetRejectedRequest() *Request
- func (m *Rejection) GetRejectedRequestMessageId() string
- func (m *Rejection) GetRejectedRequestSequencingEventId() int64
- func (this *Rejection) GoString() string
- func (m *Rejection) Marshal() (dAtA []byte, err error)
- func (m *Rejection) MarshalTo(dAtA []byte) (int, error)
- func (m *Rejection) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Rejection) ProtoMessage()
- func (m *Rejection) Reset()
- func (m *Rejection) Size() (n int)
- func (this *Rejection) String() string
- func (m *Rejection) Unmarshal(dAtA []byte) error
- func (m *Rejection) XXX_DiscardUnknown()
- func (m *Rejection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Rejection) XXX_Merge(src proto.Message)
- func (m *Rejection) XXX_Size() int
- func (m *Rejection) XXX_Unmarshal(b []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (this *Request) Equal(that interface{}) bool
- func (m *Request) GetInput() *Input
- func (m *Request) GetMeta() *Meta
- func (this *Request) GoString() string
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (this *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (this *Response) Equal(that interface{}) bool
- func (m *Response) GetMeta() *Meta
- func (m *Response) GetOutcome() *Outcome
- func (this *Response) GoString() string
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (this *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type UpdateRef
- func (*UpdateRef) Descriptor() ([]byte, []int)
- func (this *UpdateRef) Equal(that interface{}) bool
- func (m *UpdateRef) GetUpdateId() string
- func (m *UpdateRef) GetWorkflowExecution() *v11.WorkflowExecution
- func (this *UpdateRef) GoString() string
- func (m *UpdateRef) Marshal() (dAtA []byte, err error)
- func (m *UpdateRef) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateRef) ProtoMessage()
- func (m *UpdateRef) Reset()
- func (m *UpdateRef) Size() (n int)
- func (this *UpdateRef) String() string
- func (m *UpdateRef) Unmarshal(dAtA []byte) error
- func (m *UpdateRef) XXX_DiscardUnknown()
- func (m *UpdateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRef) XXX_Merge(src proto.Message)
- func (m *UpdateRef) XXX_Size() int
- func (m *UpdateRef) XXX_Unmarshal(b []byte) error
- type WaitPolicy
- func (*WaitPolicy) Descriptor() ([]byte, []int)
- func (this *WaitPolicy) Equal(that interface{}) bool
- func (m *WaitPolicy) GetLifecycleStage() v1.UpdateWorkflowExecutionLifecycleStage
- func (this *WaitPolicy) GoString() string
- func (m *WaitPolicy) Marshal() (dAtA []byte, err error)
- func (m *WaitPolicy) MarshalTo(dAtA []byte) (int, error)
- func (m *WaitPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WaitPolicy) ProtoMessage()
- func (m *WaitPolicy) Reset()
- func (m *WaitPolicy) Size() (n int)
- func (this *WaitPolicy) String() string
- func (m *WaitPolicy) Unmarshal(dAtA []byte) error
- func (m *WaitPolicy) XXX_DiscardUnknown()
- func (m *WaitPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WaitPolicy) XXX_Merge(src proto.Message)
- func (m *WaitPolicy) XXX_Size() int
- func (m *WaitPolicy) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
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) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Input) ProtoMessage ¶ added in v1.16.0
func (*Input) ProtoMessage()
func (*Input) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Input) XXX_DiscardUnknown()
func (*Input) XXX_Marshal ¶ added in v1.16.0
func (*Input) XXX_Unmarshal ¶ added in v1.16.0
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) GetIdentity ¶ added in v1.16.0
func (*Meta) GetUpdateId ¶ added in v1.16.0
func (*Meta) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Meta) ProtoMessage ¶ added in v1.16.0
func (*Meta) ProtoMessage()
func (*Meta) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Meta) XXX_DiscardUnknown()
func (*Meta) XXX_Marshal ¶ added in v1.16.0
func (*Meta) XXX_Unmarshal ¶ added in v1.16.0
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) GetFailure ¶ added in v1.16.0
func (*Outcome) GetSuccess ¶ added in v1.16.0
func (*Outcome) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Outcome) ProtoMessage ¶ added in v1.16.0
func (*Outcome) ProtoMessage()
func (*Outcome) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Outcome) XXX_DiscardUnknown()
func (*Outcome) XXX_Marshal ¶ added in v1.16.0
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_Unmarshal ¶ added in v1.16.0
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) GetFailure ¶ added in v1.16.0
func (*Rejection) GetRejectedRequest ¶ added in v1.16.0
func (*Rejection) GetRejectedRequestMessageId ¶ added in v1.16.0
func (*Rejection) GetRejectedRequestSequencingEventId ¶ added in v1.16.0
func (*Rejection) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Rejection) ProtoMessage ¶ added in v1.16.0
func (*Rejection) ProtoMessage()
func (*Rejection) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Rejection) XXX_DiscardUnknown()
func (*Rejection) XXX_Marshal ¶ added in v1.16.0
func (*Rejection) XXX_Unmarshal ¶ added in v1.16.0
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) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Request) ProtoMessage ¶ added in v1.16.0
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶ added in v1.16.0
func (*Request) XXX_Unmarshal ¶ added in v1.16.0
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) GetOutcome ¶ added in v1.16.0
func (*Response) MarshalToSizedBuffer ¶ added in v1.16.0
func (*Response) ProtoMessage ¶ added in v1.16.0
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶ added in v1.16.0
func (*Response) XXX_Unmarshal ¶ added in v1.16.0
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) GetUpdateId ¶ added in v1.16.0
func (*UpdateRef) GetWorkflowExecution ¶ added in v1.16.0
func (m *UpdateRef) GetWorkflowExecution() *v11.WorkflowExecution
func (*UpdateRef) MarshalToSizedBuffer ¶ added in v1.16.0
func (*UpdateRef) ProtoMessage ¶ added in v1.16.0
func (*UpdateRef) ProtoMessage()
func (*UpdateRef) XXX_DiscardUnknown ¶ added in v1.16.0
func (m *UpdateRef) XXX_DiscardUnknown()
func (*UpdateRef) XXX_Marshal ¶ added in v1.16.0
func (*UpdateRef) XXX_Unmarshal ¶ added in v1.16.0
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