checksum

Documentation

Index

• Variables
• type MutableStateChecksumPayload
  • func (*MutableStateChecksumPayload) Descriptor() ([]byte, []int)
  • func (this *MutableStateChecksumPayload) Equal(that interface{}) bool
  • func (m *MutableStateChecksumPayload) GetCancelRequested() bool
  • func (m *MutableStateChecksumPayload) GetLastFirstEventId() int64
  • func (m *MutableStateChecksumPayload) GetLastProcessedEventId() int64
  • func (m *MutableStateChecksumPayload) GetLastWriteEventId() int64
  • func (m *MutableStateChecksumPayload) GetLastWriteVersion() int64
  • func (m *MutableStateChecksumPayload) GetNextEventId() int64
  • func (m *MutableStateChecksumPayload) GetPendingActivityScheduledIds() []int64
  • func (m *MutableStateChecksumPayload) GetPendingChildInitiatedIds() []int64
  • func (m *MutableStateChecksumPayload) GetPendingReqCancelInitiatedIds() []int64
  • func (m *MutableStateChecksumPayload) GetPendingSignalInitiatedIds() []int64
  • func (m *MutableStateChecksumPayload) GetPendingTimerStartedIds() []int64
  • func (m *MutableStateChecksumPayload) GetSignalCount() int64
  • func (m *MutableStateChecksumPayload) GetState() v1.WorkflowExecutionState
  • func (m *MutableStateChecksumPayload) GetStatus() v11.WorkflowExecutionStatus
  • func (m *MutableStateChecksumPayload) GetStickyTaskQueueName() string
  • func (m *MutableStateChecksumPayload) GetVersionHistories() *v12.VersionHistories
  • func (m *MutableStateChecksumPayload) GetWorkflowTaskAttempt() int32
  • func (m *MutableStateChecksumPayload) GetWorkflowTaskScheduledId() int64
  • func (m *MutableStateChecksumPayload) GetWorkflowTaskStartedId() int64
  • func (m *MutableStateChecksumPayload) GetWorkflowTaskVersion() int64
  • func (this *MutableStateChecksumPayload) GoString() string
  • func (m *MutableStateChecksumPayload) Marshal() (dAtA []byte, err error)
  • func (m *MutableStateChecksumPayload) MarshalTo(dAtA []byte) (int, error)
  • func (m *MutableStateChecksumPayload) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MutableStateChecksumPayload) ProtoMessage()
  • func (m *MutableStateChecksumPayload) Reset()
  • func (m *MutableStateChecksumPayload) Size() (n int)
  • func (this *MutableStateChecksumPayload) String() string
  • func (m *MutableStateChecksumPayload) Unmarshal(dAtA []byte) error
  • func (m *MutableStateChecksumPayload) XXX_DiscardUnknown()
  • func (m *MutableStateChecksumPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MutableStateChecksumPayload) XXX_Merge(src proto.Message)
  • func (m *MutableStateChecksumPayload) XXX_Size() int
  • func (m *MutableStateChecksumPayload) XXX_Unmarshal(b []byte) error

Variables

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

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"`
	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"`
	WorkflowTaskScheduledId      int64                       `` /* 136-byte string literal not displayed */
	WorkflowTaskStartedId        int64                       `` /* 130-byte string literal not displayed */
	PendingTimerStartedIds       []int64                     `` /* 140-byte string literal not displayed */
	PendingActivityScheduledIds  []int64                     `` /* 155-byte string literal not displayed */
	PendingSignalInitiatedIds    []int64                     `` /* 149-byte string literal not displayed */
	PendingReqCancelInitiatedIds []int64                     `` /* 160-byte string literal not displayed */
	PendingChildInitiatedIds     []int64                     `` /* 146-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) GetCancelRequested

func (m *MutableStateChecksumPayload) GetCancelRequested() bool

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) GetPendingActivityScheduledIds

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

func (*MutableStateChecksumPayload) GetPendingChildInitiatedIds

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

func (*MutableStateChecksumPayload) GetPendingReqCancelInitiatedIds

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

func (*MutableStateChecksumPayload) GetPendingSignalInitiatedIds

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

func (*MutableStateChecksumPayload) GetPendingTimerStartedIds

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

func (*MutableStateChecksumPayload) GetSignalCount

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

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

func (*MutableStateChecksumPayload) GetWorkflowTaskAttempt

func (m *MutableStateChecksumPayload) GetWorkflowTaskAttempt() int32

func (*MutableStateChecksumPayload) GetWorkflowTaskScheduledId

func (m *MutableStateChecksumPayload) GetWorkflowTaskScheduledId() int64

func (*MutableStateChecksumPayload) GetWorkflowTaskStartedId

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