archiver

package
v1.22.5-rc1 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2024 License: MIT Imports: 14 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 HistoryBlob 

type HistoryBlob struct {
	Header *HistoryBlobHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Body   []*v1.History      `protobuf:"bytes,2,rep,name=body,proto3" json:"body,omitempty"`
}

func (*HistoryBlob) Descriptor 

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

func (*HistoryBlob) Equal 

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

func (*HistoryBlob) GetBody 

func (m *HistoryBlob) GetBody() []*v1.History

func (*HistoryBlob) GetHeader 

func (m *HistoryBlob) GetHeader() *HistoryBlobHeader

func (*HistoryBlob) GoString 

func (this *HistoryBlob) GoString() string

func (*HistoryBlob) Marshal 

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

func (*HistoryBlob) MarshalTo 

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

func (*HistoryBlob) MarshalToSizedBuffer 

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

func (*HistoryBlob) ProtoMessage 

func (*HistoryBlob) ProtoMessage()

func (*HistoryBlob) Reset 

func (m *HistoryBlob) Reset()

func (*HistoryBlob) Size 

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

func (*HistoryBlob) String 

func (this *HistoryBlob) String() string

func (*HistoryBlob) Unmarshal 

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

func (*HistoryBlob) XXX_DiscardUnknown 

func (m *HistoryBlob) XXX_DiscardUnknown()

func (*HistoryBlob) XXX_Marshal 

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

func (*HistoryBlob) XXX_Merge 

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

func (*HistoryBlob) XXX_Size 

func (m *HistoryBlob) XXX_Size() int

func (*HistoryBlob) XXX_Unmarshal 

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

type HistoryBlobHeader 

type HistoryBlobHeader struct {
	Namespace            string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId          string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId           string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	IsLast               bool   `protobuf:"varint,5,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	FirstFailoverVersion int64  `protobuf:"varint,6,opt,name=first_failover_version,json=firstFailoverVersion,proto3" json:"first_failover_version,omitempty"`
	LastFailoverVersion  int64  `protobuf:"varint,7,opt,name=last_failover_version,json=lastFailoverVersion,proto3" json:"last_failover_version,omitempty"`
	FirstEventId         int64  `protobuf:"varint,8,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	LastEventId          int64  `protobuf:"varint,9,opt,name=last_event_id,json=lastEventId,proto3" json:"last_event_id,omitempty"`
	EventCount           int64  `protobuf:"varint,10,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
}

func (*HistoryBlobHeader) Descriptor 

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

func (*HistoryBlobHeader) Equal 

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

func (*HistoryBlobHeader) GetEventCount 

func (m *HistoryBlobHeader) GetEventCount() int64

func (*HistoryBlobHeader) GetFirstEventId 

func (m *HistoryBlobHeader) GetFirstEventId() int64

func (*HistoryBlobHeader) GetFirstFailoverVersion 

func (m *HistoryBlobHeader) GetFirstFailoverVersion() int64

func (*HistoryBlobHeader) GetIsLast 

func (m *HistoryBlobHeader) GetIsLast() bool

func (*HistoryBlobHeader) GetLastEventId 

func (m *HistoryBlobHeader) GetLastEventId() int64

func (*HistoryBlobHeader) GetLastFailoverVersion 

func (m *HistoryBlobHeader) GetLastFailoverVersion() int64

func (*HistoryBlobHeader) GetNamespace 

func (m *HistoryBlobHeader) GetNamespace() string

func (*HistoryBlobHeader) GetNamespaceId 

func (m *HistoryBlobHeader) GetNamespaceId() string

func (*HistoryBlobHeader) GetRunId 

func (m *HistoryBlobHeader) GetRunId() string

func (*HistoryBlobHeader) GetWorkflowId 

func (m *HistoryBlobHeader) GetWorkflowId() string

func (*HistoryBlobHeader) GoString 

func (this *HistoryBlobHeader) GoString() string

func (*HistoryBlobHeader) Marshal 

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

func (*HistoryBlobHeader) MarshalTo 

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

func (*HistoryBlobHeader) MarshalToSizedBuffer 

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

func (*HistoryBlobHeader) ProtoMessage 

func (*HistoryBlobHeader) ProtoMessage()

func (*HistoryBlobHeader) Reset 

func (m *HistoryBlobHeader) Reset()

func (*HistoryBlobHeader) Size 

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

func (*HistoryBlobHeader) String 

func (this *HistoryBlobHeader) String() string

func (*HistoryBlobHeader) Unmarshal 

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

func (*HistoryBlobHeader) XXX_DiscardUnknown 

func (m *HistoryBlobHeader) XXX_DiscardUnknown()

func (*HistoryBlobHeader) XXX_Marshal 

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

func (*HistoryBlobHeader) XXX_Merge 

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

func (*HistoryBlobHeader) XXX_Size 

func (m *HistoryBlobHeader) XXX_Size() int

func (*HistoryBlobHeader) XXX_Unmarshal 

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

type VisibilityRecord added in v1.5.7 

type VisibilityRecord struct {
	NamespaceId        string                      `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Namespace          string                      `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId         string                      `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId              string                      `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowTypeName   string                      `protobuf:"bytes,5,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	StartTime          *time.Time                  `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	ExecutionTime      *time.Time                  `protobuf:"bytes,7,opt,name=execution_time,json=executionTime,proto3,stdtime" json:"execution_time,omitempty"`
	CloseTime          *time.Time                  `protobuf:"bytes,8,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
	Status             v11.WorkflowExecutionStatus `protobuf:"varint,9,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength      int64                       `protobuf:"varint,10,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	Memo               *v12.Memo                   `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes   map[string]string           `` /* 198-byte string literal not displayed */
	HistoryArchivalUri string                      `protobuf:"bytes,13,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
}

VisibilityRecord is a single workflow visibility record in archive.

func (*VisibilityRecord) Descriptor added in v1.5.7 

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

func (*VisibilityRecord) Equal added in v1.5.7 

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

func (*VisibilityRecord) GetCloseTime added in v1.5.7 

func (m *VisibilityRecord) GetCloseTime() *time.Time

func (*VisibilityRecord) GetExecutionTime added in v1.5.7 

func (m *VisibilityRecord) GetExecutionTime() *time.Time

func (*VisibilityRecord) GetHistoryArchivalUri added in v1.5.7 

func (m *VisibilityRecord) GetHistoryArchivalUri() string

func (*VisibilityRecord) GetHistoryLength added in v1.5.7 

func (m *VisibilityRecord) GetHistoryLength() int64

func (*VisibilityRecord) GetMemo added in v1.5.7 

func (m *VisibilityRecord) GetMemo() *v12.Memo

func (*VisibilityRecord) GetNamespace added in v1.5.7 

func (m *VisibilityRecord) GetNamespace() string

func (*VisibilityRecord) GetNamespaceId added in v1.5.7 

func (m *VisibilityRecord) GetNamespaceId() string

func (*VisibilityRecord) GetRunId added in v1.5.7 

func (m *VisibilityRecord) GetRunId() string

func (*VisibilityRecord) GetSearchAttributes added in v1.5.7 

func (m *VisibilityRecord) GetSearchAttributes() map[string]string

func (*VisibilityRecord) GetStartTime added in v1.5.7 

func (m *VisibilityRecord) GetStartTime() *time.Time

func (*VisibilityRecord) GetStatus added in v1.5.7 

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

func (*VisibilityRecord) GetWorkflowId added in v1.5.7 

func (m *VisibilityRecord) GetWorkflowId() string

func (*VisibilityRecord) GetWorkflowTypeName added in v1.5.7 

func (m *VisibilityRecord) GetWorkflowTypeName() string

func (*VisibilityRecord) GoString added in v1.5.7 

func (this *VisibilityRecord) GoString() string

func (*VisibilityRecord) Marshal added in v1.5.7 

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

func (*VisibilityRecord) MarshalTo added in v1.5.7 

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

func (*VisibilityRecord) MarshalToSizedBuffer added in v1.5.7 

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

func (*VisibilityRecord) ProtoMessage added in v1.5.7 

func (*VisibilityRecord) ProtoMessage()

func (*VisibilityRecord) Reset added in v1.5.7 

func (m *VisibilityRecord) Reset()

func (*VisibilityRecord) Size added in v1.5.7 

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

func (*VisibilityRecord) String added in v1.5.7 

func (this *VisibilityRecord) String() string

func (*VisibilityRecord) Unmarshal added in v1.5.7 

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

func (*VisibilityRecord) XXX_DiscardUnknown added in v1.5.7 

func (m *VisibilityRecord) XXX_DiscardUnknown()

func (*VisibilityRecord) XXX_Marshal added in v1.5.7 

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

func (*VisibilityRecord) XXX_Merge added in v1.5.7 

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

func (*VisibilityRecord) XXX_Size added in v1.5.7 

func (m *VisibilityRecord) XXX_Size() int

func (*VisibilityRecord) XXX_Unmarshal added in v1.5.7 

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