update

package
v1.23.0-rc0 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 2023 License: MIT Imports: 7 Imported by: 0

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 AcceptanceInfo

type AcceptanceInfo struct {
	// the event ID of the WorkflowExecutionUpdateAcceptedEvent
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
}

AcceptanceInfo contains information about an accepted update

func (*AcceptanceInfo) Descriptor

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

func (*AcceptanceInfo) Equal

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

func (*AcceptanceInfo) GetEventId

func (m *AcceptanceInfo) GetEventId() int64

func (*AcceptanceInfo) GoString

func (this *AcceptanceInfo) GoString() string

func (*AcceptanceInfo) Marshal

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

func (*AcceptanceInfo) MarshalTo

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

func (*AcceptanceInfo) MarshalToSizedBuffer

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

func (*AcceptanceInfo) ProtoMessage

func (*AcceptanceInfo) ProtoMessage()

func (*AcceptanceInfo) Reset

func (m *AcceptanceInfo) Reset()

func (*AcceptanceInfo) Size

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

func (*AcceptanceInfo) String

func (this *AcceptanceInfo) String() string

func (*AcceptanceInfo) Unmarshal

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

func (*AcceptanceInfo) XXX_DiscardUnknown

func (m *AcceptanceInfo) XXX_DiscardUnknown()

func (*AcceptanceInfo) XXX_Marshal

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

func (*AcceptanceInfo) XXX_Merge

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

func (*AcceptanceInfo) XXX_Size

func (m *AcceptanceInfo) XXX_Size() int

func (*AcceptanceInfo) XXX_Unmarshal

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

type CompletionInfo

type CompletionInfo struct {
	// the event ID of the WorkflowExecutionUpdateCompletedEvent
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// the ID of the event batch containing the event_id above
	EventBatchId int64 `protobuf:"varint,2,opt,name=event_batch_id,json=eventBatchId,proto3" json:"event_batch_id,omitempty"`
}

CompletionInfo contains information about a completed update

func (*CompletionInfo) Descriptor

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

func (*CompletionInfo) Equal

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

func (*CompletionInfo) GetEventBatchId

func (m *CompletionInfo) GetEventBatchId() int64

func (*CompletionInfo) GetEventId

func (m *CompletionInfo) GetEventId() int64

func (*CompletionInfo) GoString

func (this *CompletionInfo) GoString() string

func (*CompletionInfo) Marshal

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

func (*CompletionInfo) MarshalTo

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

func (*CompletionInfo) MarshalToSizedBuffer

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

func (*CompletionInfo) ProtoMessage

func (*CompletionInfo) ProtoMessage()

func (*CompletionInfo) Reset

func (m *CompletionInfo) Reset()

func (*CompletionInfo) Size

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

func (*CompletionInfo) String

func (this *CompletionInfo) String() string

func (*CompletionInfo) Unmarshal

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

func (*CompletionInfo) XXX_DiscardUnknown

func (m *CompletionInfo) XXX_DiscardUnknown()

func (*CompletionInfo) XXX_Marshal

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

func (*CompletionInfo) XXX_Merge

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

func (*CompletionInfo) XXX_Size

func (m *CompletionInfo) XXX_Size() int

func (*CompletionInfo) XXX_Unmarshal

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

type UpdateInfo

type UpdateInfo struct {
	// Types that are valid to be assigned to Value:
	//
	//	*UpdateInfo_Acceptance
	//	*UpdateInfo_Completion
	Value isUpdateInfo_Value `protobuf_oneof:"value"`
}

UpdateInfo is the persistent state of a single update

func (*UpdateInfo) Descriptor

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

func (*UpdateInfo) Equal

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

func (*UpdateInfo) GetAcceptance

func (m *UpdateInfo) GetAcceptance() *AcceptanceInfo

func (*UpdateInfo) GetCompletion

func (m *UpdateInfo) GetCompletion() *CompletionInfo

func (*UpdateInfo) GetValue

func (m *UpdateInfo) GetValue() isUpdateInfo_Value

func (*UpdateInfo) GoString

func (this *UpdateInfo) GoString() string

func (*UpdateInfo) Marshal

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

func (*UpdateInfo) MarshalTo

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

func (*UpdateInfo) MarshalToSizedBuffer

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

func (*UpdateInfo) ProtoMessage

func (*UpdateInfo) ProtoMessage()

func (*UpdateInfo) Reset

func (m *UpdateInfo) Reset()

func (*UpdateInfo) Size

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

func (*UpdateInfo) String

func (this *UpdateInfo) String() string

func (*UpdateInfo) Unmarshal

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

func (*UpdateInfo) XXX_DiscardUnknown

func (m *UpdateInfo) XXX_DiscardUnknown()

func (*UpdateInfo) XXX_Marshal

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

func (*UpdateInfo) XXX_Merge

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

func (*UpdateInfo) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateInfo) XXX_Size

func (m *UpdateInfo) XXX_Size() int

func (*UpdateInfo) XXX_Unmarshal

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

type UpdateInfo_Acceptance

type UpdateInfo_Acceptance struct {
	Acceptance *AcceptanceInfo `protobuf:"bytes,1,opt,name=acceptance,proto3,oneof" json:"acceptance,omitempty"`
}

func (*UpdateInfo_Acceptance) Equal

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

func (*UpdateInfo_Acceptance) GoString

func (this *UpdateInfo_Acceptance) GoString() string

func (*UpdateInfo_Acceptance) MarshalTo

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

func (*UpdateInfo_Acceptance) MarshalToSizedBuffer

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

func (*UpdateInfo_Acceptance) Size

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

func (*UpdateInfo_Acceptance) String

func (this *UpdateInfo_Acceptance) String() string

type UpdateInfo_Completion

type UpdateInfo_Completion struct {
	Completion *CompletionInfo `protobuf:"bytes,2,opt,name=completion,proto3,oneof" json:"completion,omitempty"`
}

func (*UpdateInfo_Completion) Equal

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

func (*UpdateInfo_Completion) GoString

func (this *UpdateInfo_Completion) GoString() string

func (*UpdateInfo_Completion) MarshalTo

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

func (*UpdateInfo_Completion) MarshalToSizedBuffer

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

func (*UpdateInfo_Completion) Size

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

func (*UpdateInfo_Completion) String

func (this *UpdateInfo_Completion) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL