history

package
v1.18.4 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2022 License: MIT Imports: 12 Imported by: 2

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 TaskKey added in v1.16.0 

type TaskKey struct {
	TaskId   int64      `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FireTime *time.Time `protobuf:"bytes,2,opt,name=fire_time,json=fireTime,proto3,stdtime" json:"fire_time,omitempty"`
}

func (*TaskKey) Descriptor added in v1.16.0 

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

func (*TaskKey) Equal added in v1.16.0 

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

func (*TaskKey) GetFireTime added in v1.16.0 

func (m *TaskKey) GetFireTime() *time.Time

func (*TaskKey) GetTaskId added in v1.16.0 

func (m *TaskKey) GetTaskId() int64

func (*TaskKey) GoString added in v1.16.0 

func (this *TaskKey) GoString() string

func (*TaskKey) Marshal added in v1.16.0 

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

func (*TaskKey) MarshalTo added in v1.16.0 

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

func (*TaskKey) MarshalToSizedBuffer added in v1.16.0 

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

func (*TaskKey) ProtoMessage added in v1.16.0 

func (*TaskKey) ProtoMessage()

func (*TaskKey) Reset added in v1.16.0 

func (m *TaskKey) Reset()

func (*TaskKey) Size added in v1.16.0 

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

func (*TaskKey) String added in v1.16.0 

func (this *TaskKey) String() string

func (*TaskKey) Unmarshal added in v1.16.0 

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

func (*TaskKey) XXX_DiscardUnknown added in v1.16.0 

func (m *TaskKey) XXX_DiscardUnknown()

func (*TaskKey) XXX_Marshal added in v1.16.0 

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

func (*TaskKey) XXX_Merge added in v1.16.0 

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

func (*TaskKey) XXX_Size added in v1.16.0 

func (m *TaskKey) XXX_Size() int

func (*TaskKey) XXX_Unmarshal added in v1.16.0 

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

type TaskRange added in v1.16.0 

type TaskRange struct {
	InclusiveMinTaskKey *TaskKey `protobuf:"bytes,1,opt,name=inclusive_min_task_key,json=inclusiveMinTaskKey,proto3" json:"inclusive_min_task_key,omitempty"`
	ExclusiveMaxTaskKey *TaskKey `protobuf:"bytes,2,opt,name=exclusive_max_task_key,json=exclusiveMaxTaskKey,proto3" json:"exclusive_max_task_key,omitempty"`
}

func (*TaskRange) Descriptor added in v1.16.0 

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

func (*TaskRange) Equal added in v1.16.0 

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

func (*TaskRange) GetExclusiveMaxTaskKey added in v1.16.0 

func (m *TaskRange) GetExclusiveMaxTaskKey() *TaskKey

func (*TaskRange) GetInclusiveMinTaskKey added in v1.16.0 

func (m *TaskRange) GetInclusiveMinTaskKey() *TaskKey

func (*TaskRange) GoString added in v1.16.0 

func (this *TaskRange) GoString() string

func (*TaskRange) Marshal added in v1.16.0 

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

func (*TaskRange) MarshalTo added in v1.16.0 

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

func (*TaskRange) MarshalToSizedBuffer added in v1.16.0 

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

func (*TaskRange) ProtoMessage added in v1.16.0 

func (*TaskRange) ProtoMessage()

func (*TaskRange) Reset added in v1.16.0 

func (m *TaskRange) Reset()

func (*TaskRange) Size added in v1.16.0 

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

func (*TaskRange) String added in v1.16.0 

func (this *TaskRange) String() string

func (*TaskRange) Unmarshal added in v1.16.0 

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

func (*TaskRange) XXX_DiscardUnknown added in v1.16.0 

func (m *TaskRange) XXX_DiscardUnknown()

func (*TaskRange) XXX_Marshal added in v1.16.0 

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

func (*TaskRange) XXX_Merge added in v1.16.0 

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

func (*TaskRange) XXX_Size added in v1.16.0 

func (m *TaskRange) XXX_Size() int

func (*TaskRange) XXX_Unmarshal added in v1.16.0 

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

type TransientWorkflowTaskInfo 

type TransientWorkflowTaskInfo struct {
	// Rather than use this field, instead add the event to the history_suffix list.
	ScheduledEvent *v1.HistoryEvent `protobuf:"bytes,1,opt,name=scheduled_event,json=scheduledEvent,proto3" json:"scheduled_event,omitempty"` // Deprecated: Do not use.
	// Rather than use this field, instead add the event to the history_suffix list.
	StartedEvent *v1.HistoryEvent `protobuf:"bytes,2,opt,name=started_event,json=startedEvent,proto3" json:"started_event,omitempty"` // Deprecated: Do not use.
	// A list of history events that are to be appended to the "real" workflow
	// history.
	HistorySuffix []*v1.HistoryEvent `protobuf:"bytes,3,rep,name=history_suffix,json=historySuffix,proto3" json:"history_suffix,omitempty"`
}

func (*TransientWorkflowTaskInfo) Descriptor 

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

func (*TransientWorkflowTaskInfo) Equal 

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

func (*TransientWorkflowTaskInfo) GetHistorySuffix added in v1.17.3 

func (m *TransientWorkflowTaskInfo) GetHistorySuffix() []*v1.HistoryEvent

func (*TransientWorkflowTaskInfo) GetScheduledEvent deprecated 

func (m *TransientWorkflowTaskInfo) GetScheduledEvent() *v1.HistoryEvent

Deprecated: Do not use.

func (*TransientWorkflowTaskInfo) GetStartedEvent deprecated 

func (m *TransientWorkflowTaskInfo) GetStartedEvent() *v1.HistoryEvent

Deprecated: Do not use.

func (*TransientWorkflowTaskInfo) GoString 

func (this *TransientWorkflowTaskInfo) GoString() string

func (*TransientWorkflowTaskInfo) Marshal 

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

func (*TransientWorkflowTaskInfo) MarshalTo 

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

func (*TransientWorkflowTaskInfo) MarshalToSizedBuffer 

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

func (*TransientWorkflowTaskInfo) ProtoMessage 

func (*TransientWorkflowTaskInfo) ProtoMessage()

func (*TransientWorkflowTaskInfo) Reset 

func (m *TransientWorkflowTaskInfo) Reset()

func (*TransientWorkflowTaskInfo) Size 

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

func (*TransientWorkflowTaskInfo) String 

func (this *TransientWorkflowTaskInfo) String() string

func (*TransientWorkflowTaskInfo) Unmarshal 

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

func (*TransientWorkflowTaskInfo) XXX_DiscardUnknown 

func (m *TransientWorkflowTaskInfo) XXX_DiscardUnknown()

func (*TransientWorkflowTaskInfo) XXX_Marshal 

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

func (*TransientWorkflowTaskInfo) XXX_Merge 

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

func (*TransientWorkflowTaskInfo) XXX_Size 

func (m *TransientWorkflowTaskInfo) XXX_Size() int

func (*TransientWorkflowTaskInfo) XXX_Unmarshal 

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

type VersionHistories 

type VersionHistories struct {
	CurrentVersionHistoryIndex int32             `` /* 144-byte string literal not displayed */
	Histories                  []*VersionHistory `protobuf:"bytes,2,rep,name=histories,proto3" json:"histories,omitempty"`
}

VersionHistories contains all version histories from all branches.

func (*VersionHistories) Descriptor 

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

func (*VersionHistories) Equal 

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

func (*VersionHistories) GetCurrentVersionHistoryIndex 

func (m *VersionHistories) GetCurrentVersionHistoryIndex() int32

func (*VersionHistories) GetHistories 

func (m *VersionHistories) GetHistories() []*VersionHistory

func (*VersionHistories) GoString 

func (this *VersionHistories) GoString() string

func (*VersionHistories) Marshal 

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

func (*VersionHistories) MarshalTo 

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

func (*VersionHistories) MarshalToSizedBuffer 

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

func (*VersionHistories) ProtoMessage 

func (*VersionHistories) ProtoMessage()

func (*VersionHistories) Reset 

func (m *VersionHistories) Reset()

func (*VersionHistories) Size 

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

func (*VersionHistories) String 

func (this *VersionHistories) String() string

func (*VersionHistories) Unmarshal 

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

func (*VersionHistories) XXX_DiscardUnknown 

func (m *VersionHistories) XXX_DiscardUnknown()

func (*VersionHistories) XXX_Marshal 

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

func (*VersionHistories) XXX_Merge 

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

func (*VersionHistories) XXX_Size 

func (m *VersionHistories) XXX_Size() int

func (*VersionHistories) XXX_Unmarshal 

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

type VersionHistory 

type VersionHistory struct {
	BranchToken []byte                `protobuf:"bytes,1,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	Items       []*VersionHistoryItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
}

VersionHistory contains the version history of a branch.

func (*VersionHistory) Descriptor 

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

func (*VersionHistory) Equal 

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

func (*VersionHistory) GetBranchToken 

func (m *VersionHistory) GetBranchToken() []byte

func (*VersionHistory) GetItems 

func (m *VersionHistory) GetItems() []*VersionHistoryItem

func (*VersionHistory) GoString 

func (this *VersionHistory) GoString() string

func (*VersionHistory) Marshal 

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

func (*VersionHistory) MarshalTo 

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

func (*VersionHistory) MarshalToSizedBuffer 

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

func (*VersionHistory) ProtoMessage 

func (*VersionHistory) ProtoMessage()

func (*VersionHistory) Reset 

func (m *VersionHistory) Reset()

func (*VersionHistory) Size 

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

func (*VersionHistory) String 

func (this *VersionHistory) String() string

func (*VersionHistory) Unmarshal 

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

func (*VersionHistory) XXX_DiscardUnknown 

func (m *VersionHistory) XXX_DiscardUnknown()

func (*VersionHistory) XXX_Marshal 

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

func (*VersionHistory) XXX_Merge 

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

func (*VersionHistory) XXX_Size 

func (m *VersionHistory) XXX_Size() int

func (*VersionHistory) XXX_Unmarshal 

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

type VersionHistoryItem 

type VersionHistoryItem struct {
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

VersionHistoryItem contains signal eventId and the corresponding version.

func (*VersionHistoryItem) Descriptor 

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

func (*VersionHistoryItem) Equal 

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

func (*VersionHistoryItem) GetEventId 

func (m *VersionHistoryItem) GetEventId() int64

func (*VersionHistoryItem) GetVersion 

func (m *VersionHistoryItem) GetVersion() int64

func (*VersionHistoryItem) GoString 

func (this *VersionHistoryItem) GoString() string

func (*VersionHistoryItem) Marshal 

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

func (*VersionHistoryItem) MarshalTo 

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

func (*VersionHistoryItem) MarshalToSizedBuffer 

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

func (*VersionHistoryItem) ProtoMessage 

func (*VersionHistoryItem) ProtoMessage()

func (*VersionHistoryItem) Reset 

func (m *VersionHistoryItem) Reset()

func (*VersionHistoryItem) Size 

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

func (*VersionHistoryItem) String 

func (this *VersionHistoryItem) String() string

func (*VersionHistoryItem) Unmarshal 

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

func (*VersionHistoryItem) XXX_DiscardUnknown 

func (m *VersionHistoryItem) XXX_DiscardUnknown()

func (*VersionHistoryItem) XXX_Marshal 

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

func (*VersionHistoryItem) XXX_Merge 

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

func (*VersionHistoryItem) XXX_Size 

func (m *VersionHistoryItem) XXX_Size() int

func (*VersionHistoryItem) XXX_Unmarshal 

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