Documentation
¶
Overview ¶
Package archival is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Archiver ¶
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.MetricsHandler, rateLimiter quotas.RateLimiter, ) 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) 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 interface{}) *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 string // visibility archival WorkflowTypeName string StartTime time.Time ExecutionTime time.Time CloseTime time.Time Status enumspb.WorkflowExecutionStatus HistoryLength int64 Memo *commonpb.Memo SearchAttributes *commonpb.SearchAttributes VisibilityURI string // archival targets: history and/or visibility Targets []Target CallerService string }
Click to show internal directories.
Click to hide internal directories.