archiver

type ArchivalTarget int

type ArchiveRequest struct {
	DomainID   string
	DomainName string
	WorkflowID string
	RunID      string

	// history archival
	ShardID              int
	BranchToken          []byte
	NextEventID          int64
	CloseFailoverVersion int64
	URI                  string // should be historyURI, but keep the existing name for backward compatibility

	// visibility archival
	WorkflowTypeName   string
	StartTimestamp     int64
	ExecutionTimestamp int64
	CloseTimestamp     int64
	CloseStatus        types.WorkflowExecutionCloseStatus
	HistoryLength      int64
	Memo               *types.Memo
	SearchAttributes   map[string][]byte
	VisibilityURI      string

	// archival targets: history and/or visibility
	Targets []ArchivalTarget
}

type BootstrapContainer struct {
	PublicClient     workflowserviceclient.Interface
	MetricsClient    metrics.Client
	Logger           log.Logger
	HistoryV2Manager persistence.HistoryManager
	DomainCache      cache.DomainCache
	Config           *Config
	ArchiverProvider provider.ArchiverProvider
}

type Client interface {
	Archive(context.Context, *ClientRequest) (*ClientResponse, error)
}

type ClientMock struct {
	mock.Mock
}

type ClientRequest struct {
	ArchiveRequest       *ArchiveRequest
	CallerService        string
	AttemptArchiveInline bool
}

type ClientResponse struct {
	HistoryArchivedInline bool
}

type ClientWorker interface {
	Start() error
	Stop()
}

type Config struct {
	ArchiverConcurrency             dynamicconfig.IntPropertyFn
	ArchivalsPerIteration           dynamicconfig.IntPropertyFn
	TimeLimitPerArchivalIteration   dynamicconfig.DurationPropertyFn
	AllowArchivingIncompleteHistory dynamicconfig.BoolPropertyFn
}

type Handler interface {
	Start()
	Finished() []uint64
}

type MockHandler struct {
	mock.Mock
}

type Pump interface {
	Run() PumpResult
}

type PumpMock struct {
	mock.Mock
}

type PumpResult struct {
	PumpedHashes          []uint64
	UnhandledCarryover    []ArchiveRequest
	TimeoutWithoutSignals bool
}