update

package
v1.21.0 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 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

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.