checksum

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: 10 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 MutableStateChecksumPayload 

type MutableStateChecksumPayload struct {
	CancelRequested                   bool                        `protobuf:"varint,1,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	State                             v1.WorkflowExecutionState   `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.server.api.enums.v1.WorkflowExecutionState" json:"state,omitempty"`
	Status                            v11.WorkflowExecutionStatus `protobuf:"varint,3,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	LastWriteVersion                  int64                       `protobuf:"varint,4,opt,name=last_write_version,json=lastWriteVersion,proto3" json:"last_write_version,omitempty"`
	LastWriteEventId                  int64                       `protobuf:"varint,5,opt,name=last_write_event_id,json=lastWriteEventId,proto3" json:"last_write_event_id,omitempty"`
	LastFirstEventId                  int64                       `protobuf:"varint,6,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	NextEventId                       int64                       `protobuf:"varint,7,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	LastProcessedEventId              int64                       `` /* 126-byte string literal not displayed */
	SignalCount                       int64                       `protobuf:"varint,9,opt,name=signal_count,json=signalCount,proto3" json:"signal_count,omitempty"`
	ActivityCount                     int64                       `protobuf:"varint,21,opt,name=activity_count,json=activityCount,proto3" json:"activity_count,omitempty"`
	ChildExecutionCount               int64                       `protobuf:"varint,22,opt,name=child_execution_count,json=childExecutionCount,proto3" json:"child_execution_count,omitempty"`
	UserTimerCount                    int64                       `protobuf:"varint,23,opt,name=user_timer_count,json=userTimerCount,proto3" json:"user_timer_count,omitempty"`
	RequestCancelExternalCount        int64                       `` /* 145-byte string literal not displayed */
	SignalExternalCount               int64                       `protobuf:"varint,25,opt,name=signal_external_count,json=signalExternalCount,proto3" json:"signal_external_count,omitempty"`
	WorkflowTaskAttempt               int32                       `protobuf:"varint,10,opt,name=workflow_task_attempt,json=workflowTaskAttempt,proto3" json:"workflow_task_attempt,omitempty"`
	WorkflowTaskVersion               int64                       `protobuf:"varint,11,opt,name=workflow_task_version,json=workflowTaskVersion,proto3" json:"workflow_task_version,omitempty"`
	WorkflowTaskScheduledEventId      int64                       `` /* 153-byte string literal not displayed */
	WorkflowTaskStartedEventId        int64                       `` /* 147-byte string literal not displayed */
	PendingTimerStartedEventIds       []int64                     `` /* 157-byte string literal not displayed */
	PendingActivityScheduledEventIds  []int64                     `` /* 172-byte string literal not displayed */
	PendingSignalInitiatedEventIds    []int64                     `` /* 166-byte string literal not displayed */
	PendingReqCancelInitiatedEventIds []int64                     `` /* 177-byte string literal not displayed */
	PendingChildInitiatedEventIds     []int64                     `` /* 163-byte string literal not displayed */
	StickyTaskQueueName               string                      `protobuf:"bytes,19,opt,name=sticky_task_queue_name,json=stickyTaskQueueName,proto3" json:"sticky_task_queue_name,omitempty"`
	VersionHistories                  *v12.VersionHistories       `protobuf:"bytes,20,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
}

func (*MutableStateChecksumPayload) Descriptor 

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

func (*MutableStateChecksumPayload) Equal 

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

func (*MutableStateChecksumPayload) GetActivityCount added in v1.20.1 

func (m *MutableStateChecksumPayload) GetActivityCount() int64

func (*MutableStateChecksumPayload) GetCancelRequested 

func (m *MutableStateChecksumPayload) GetCancelRequested() bool

func (*MutableStateChecksumPayload) GetChildExecutionCount added in v1.20.1 

func (m *MutableStateChecksumPayload) GetChildExecutionCount() int64

func (*MutableStateChecksumPayload) GetLastFirstEventId 

func (m *MutableStateChecksumPayload) GetLastFirstEventId() int64

func (*MutableStateChecksumPayload) GetLastProcessedEventId 

func (m *MutableStateChecksumPayload) GetLastProcessedEventId() int64

func (*MutableStateChecksumPayload) GetLastWriteEventId 

func (m *MutableStateChecksumPayload) GetLastWriteEventId() int64

func (*MutableStateChecksumPayload) GetLastWriteVersion 

func (m *MutableStateChecksumPayload) GetLastWriteVersion() int64

func (*MutableStateChecksumPayload) GetNextEventId 

func (m *MutableStateChecksumPayload) GetNextEventId() int64

func (*MutableStateChecksumPayload) GetPendingActivityScheduledEventIds added in v1.17.0 

func (m *MutableStateChecksumPayload) GetPendingActivityScheduledEventIds() []int64

func (*MutableStateChecksumPayload) GetPendingChildInitiatedEventIds added in v1.17.0 

func (m *MutableStateChecksumPayload) GetPendingChildInitiatedEventIds() []int64

func (*MutableStateChecksumPayload) GetPendingReqCancelInitiatedEventIds added in v1.17.0 

func (m *MutableStateChecksumPayload) GetPendingReqCancelInitiatedEventIds() []int64

func (*MutableStateChecksumPayload) GetPendingSignalInitiatedEventIds added in v1.17.0 

func (m *MutableStateChecksumPayload) GetPendingSignalInitiatedEventIds() []int64

func (*MutableStateChecksumPayload) GetPendingTimerStartedEventIds added in v1.17.0 

func (m *MutableStateChecksumPayload) GetPendingTimerStartedEventIds() []int64

func (*MutableStateChecksumPayload) GetRequestCancelExternalCount added in v1.20.1 

func (m *MutableStateChecksumPayload) GetRequestCancelExternalCount() int64

func (*MutableStateChecksumPayload) GetSignalCount 

func (m *MutableStateChecksumPayload) GetSignalCount() int64

func (*MutableStateChecksumPayload) GetSignalExternalCount added in v1.20.1 

func (m *MutableStateChecksumPayload) GetSignalExternalCount() int64

func (*MutableStateChecksumPayload) GetState 

func (m *MutableStateChecksumPayload) GetState() v1.WorkflowExecutionState

func (*MutableStateChecksumPayload) GetStatus 

func (m *MutableStateChecksumPayload) GetStatus() v11.WorkflowExecutionStatus

func (*MutableStateChecksumPayload) GetStickyTaskQueueName 

func (m *MutableStateChecksumPayload) GetStickyTaskQueueName() string

func (*MutableStateChecksumPayload) GetUserTimerCount added in v1.20.1 

func (m *MutableStateChecksumPayload) GetUserTimerCount() int64

func (*MutableStateChecksumPayload) GetVersionHistories 

func (m *MutableStateChecksumPayload) GetVersionHistories() *v12.VersionHistories

func (*MutableStateChecksumPayload) GetWorkflowTaskAttempt 

func (m *MutableStateChecksumPayload) GetWorkflowTaskAttempt() int32

func (*MutableStateChecksumPayload) GetWorkflowTaskScheduledEventId added in v1.17.0 

func (m *MutableStateChecksumPayload) GetWorkflowTaskScheduledEventId() int64

func (*MutableStateChecksumPayload) GetWorkflowTaskStartedEventId added in v1.17.0 

func (m *MutableStateChecksumPayload) GetWorkflowTaskStartedEventId() int64

func (*MutableStateChecksumPayload) GetWorkflowTaskVersion 

func (m *MutableStateChecksumPayload) GetWorkflowTaskVersion() int64

func (*MutableStateChecksumPayload) GoString 

func (this *MutableStateChecksumPayload) GoString() string

func (*MutableStateChecksumPayload) Marshal 

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

func (*MutableStateChecksumPayload) MarshalTo 

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

func (*MutableStateChecksumPayload) MarshalToSizedBuffer 

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

func (*MutableStateChecksumPayload) ProtoMessage 

func (*MutableStateChecksumPayload) ProtoMessage()

func (*MutableStateChecksumPayload) Reset 

func (m *MutableStateChecksumPayload) Reset()

func (*MutableStateChecksumPayload) Size 

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

func (*MutableStateChecksumPayload) String 

func (this *MutableStateChecksumPayload) String() string

func (*MutableStateChecksumPayload) Unmarshal 

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

func (*MutableStateChecksumPayload) XXX_DiscardUnknown 

func (m *MutableStateChecksumPayload) XXX_DiscardUnknown()

func (*MutableStateChecksumPayload) XXX_Marshal 

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

func (*MutableStateChecksumPayload) XXX_Merge 

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

func (*MutableStateChecksumPayload) XXX_Size 

func (m *MutableStateChecksumPayload) XXX_Size() int

func (*MutableStateChecksumPayload) XXX_Unmarshal 

func (m *MutableStateChecksumPayload) 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.