archiver

type ArchivalTarget int

type ArchiveRequest 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 []ArchivalTarget
}

type BootstrapContainer struct {
	SdkClientFactory sdk.ClientFactory
	MetricsHandler   metrics.Handler
	Logger           log.Logger
	HistoryV2Manager persistence.ExecutionManager
	NamespaceCache   namespace.Registry
	Config           *Config
	ArchiverProvider provider.ArchiverProvider
	HistoryClient    historyservice.HistoryServiceClient
}

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

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

type ClientResponse struct {
	HistoryArchivedInline bool
}

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

type Config struct {
	MaxConcurrentActivityExecutionSize     dynamicconfig.IntPropertyFn
	MaxConcurrentWorkflowTaskExecutionSize dynamicconfig.IntPropertyFn
	MaxConcurrentActivityTaskPollers       dynamicconfig.IntPropertyFn
	MaxConcurrentWorkflowTaskPollers       dynamicconfig.IntPropertyFn

	ArchiverConcurrency           dynamicconfig.IntPropertyFn
	ArchivalsPerIteration         dynamicconfig.IntPropertyFn
	TimeLimitPerArchivalIteration dynamicconfig.DurationPropertyFn
}

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

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

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

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

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

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

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

type Pump interface {
	Run() PumpResult
}

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