archival

Documentation

Overview

Package archival is a generated GoMock package.

Index

• Variables
• type Archiver
  • func NewArchiver(archiverProvider provider.ArchiverProvider, logger log.Logger, ...) Archiver
• type MockArchiver
  • func NewMockArchiver(ctrl *gomock.Controller) *MockArchiver
  • func (m *MockArchiver) Archive(arg0 context.Context, arg1 *Request) (*Response, error)
  • func (m *MockArchiver) EXPECT() *MockArchiverMockRecorder
• type MockArchiverMockRecorder
  • func (mr *MockArchiverMockRecorder) Archive(arg0, arg1 any) *gomock.Call
• type Request
• type Response
• type Target

Variables

var Module = fx.Options(
	fx.Provide(NewArchiver),
	fx.Provide(func(config *configs.Config) quotas.RateLimiter {
		return quotas.NewDefaultOutgoingRateLimiter(quotas.RateFn(config.ArchivalBackendMaxRPS))
	}),
)

Types

type Archiver

type Archiver interface {
	Archive(context.Context, *Request) (*Response, error)
}

Archiver is used to archive workflow history and visibility data. If a target fails, it returns an error, unlike archiver.Client, which will try to signal an archival workflow whenever an error occurs.

func NewArchiver

func NewArchiver(
	archiverProvider provider.ArchiverProvider,
	logger log.Logger,
	metricsHandler metrics.Handler,
	rateLimiter quotas.RateLimiter,
	searchAttributeProvider searchattribute.Provider,
	visibilityManger manager.VisibilityManager,
) Archiver

NewArchiver creates a new Archiver

type MockArchiver

type MockArchiver struct {
	// contains filtered or unexported fields
}

MockArchiver is a mock of Archiver interface.

func NewMockArchiver

func NewMockArchiver(ctrl *gomock.Controller) *MockArchiver

NewMockArchiver creates a new mock instance.

func (*MockArchiver) Archive

func (m *MockArchiver) Archive(arg0 context.Context, arg1 *Request) (*Response, error)

Archive mocks base method.

func (*MockArchiver) EXPECT

func (m *MockArchiver) EXPECT() *MockArchiverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockArchiverMockRecorder

type MockArchiverMockRecorder struct {
	// contains filtered or unexported fields
}

MockArchiverMockRecorder is the mock recorder for MockArchiver.

func (*MockArchiverMockRecorder) Archive

func (mr *MockArchiverMockRecorder) Archive(arg0, arg1 any) *gomock.Call

Archive indicates an expected call of Archive.

type Request

type Request struct {
	ShardID     int32
	NamespaceID string
	Namespace   string
	WorkflowID  string
	RunID       string

	// history archival
	BranchToken          []byte
	NextEventID          int64
	CloseFailoverVersion int64
	// HistoryURI is the URI of the history archival backend.
	HistoryURI carchiver.URI

	// visibility archival
	WorkflowTypeName  string
	StartTime         *timestamppb.Timestamp
	ExecutionTime     *timestamppb.Timestamp
	CloseTime         *timestamppb.Timestamp
	ExecutionDuration *durationpb.Duration
	Status            enumspb.WorkflowExecutionStatus
	HistoryLength     int64
	Memo              *commonpb.Memo
	SearchAttributes  *commonpb.SearchAttributes
	// VisibilityURI is the URI of the visibility archival backend.
	VisibilityURI carchiver.URI

	// archival targets: history and/or visibility
	Targets       []Target
	CallerService string
}

type Response

type Response struct {
}

type Target

type Target string

const (
	TargetHistory    Target = "history"
	TargetVisibility Target = "visibility"
)