archiver

Aug 12, 2019

Changes in this version

type ClientRequest

+ AttemptArchiveInline bool

+ type ClientResponse struct

+ ArchivedInline bool

Jul 30, 2019

Changes in this version

type ArchiveRequest

+ URI string

type BootstrapContainer

+ ArchiverProvider provider.ArchiverProvider

+ type ClientRequest struct

+ ArchiveInline bool

+ ArchiveRequest *ArchiveRequest

+ CallerService string

+ type Handler interface

+ Finished func() []uint64

+ Start func()

+ func NewHandler(ctx workflow.Context, logger log.Logger, metricsClient metrics.Client, ...) Handler

+ type MockHandler struct

+ func (_m *MockHandler) Finished() []uint64

+ func (_m *MockHandler) Start()

Jul 24, 2019

Changes in this version

type BootstrapContainer

+ HistoryArchivers map[string]carchiver.HistoryArchiver

type HistoryBlobIterator

+ GetState func() ([]byte, error)

type HistoryBlobIteratorMock

+ func (_m *HistoryBlobIteratorMock) GetState() ([]byte, error)

+ type HistoryBlobUploader interface

+ UploadHistory func(context.Context, *ArchiveRequest) (*uploadResult, error)

+ func NewHistoryBlobUploader() HistoryBlobUploader

Jun 17, 2019

Changes in this version

+ func GetHighestVersion(tags map[string]string) (*int64, error)

+ func MaxArchivalIterationTimeout() time.Duration

+ func NewHistoryIndexBlobKey(domainID, workflowID, runID string) (blob.Key, error)

+ func NewNonDeterministicBlobKey(key blob.Key) (blob.Key, error)

+ func NewReplayMetricsScope(scope metrics.Scope, ctx workflow.Context) metrics.Scope

type ArchiveRequest

+ BucketName string

+ DomainName string

type BootstrapContainer

+ HistoryBlobDownloader HistoryBlobDownloader

+ HistorySizeEstimator SizeEstimator

type Config

+ BlobIntegrityCheckProbability dynamicconfig.FloatPropertyFn

+ TimeLimitPerArchivalIteration dynamicconfig.DurationPropertyFn

+ type DownloadBlobRequest struct

+ ArchivalBucket string

+ CloseFailoverVersion *int64

+ DomainID string

+ NextPageToken []byte

+ RunID string

+ WorkflowID string

+ type DownloadBlobResponse struct

+ HistoryBlob *HistoryBlob

+ NextPageToken []byte

+ type HistoryBlobDownloader interface

+ DownloadBlob func(context.Context, *DownloadBlobRequest) (*DownloadBlobResponse, error)

+ func NewHistoryBlobDownloader(blobstoreClient blobstore.Client) HistoryBlobDownloader

+ type HistoryBlobDownloaderMock struct

+ func (_m *HistoryBlobDownloaderMock) DownloadBlob(_a0 context.Context, _a1 *DownloadBlobRequest) (*DownloadBlobResponse, error)

+ type SizeEstimator interface

+ EstimateSize func(v interface{}) (int, error)

+ func NewJSONSizeEstimator() SizeEstimator

May 8, 2019

Changes in this version

+ func ConvertHeaderToTags(header *HistoryBlobHeader) (map[string]string, error)

+ func IsLast(tags map[string]string) bool

+ func NewHistoryBlobKey(domainID, workflowID, runID string, pageToken int) (blob.Key, error)

+ func NewReplayMetricsClient(client metrics.Client, ctx workflow.Context) metrics.Client

+ func StringPageToken(pageToken int) string

+ type ArchiveRequest struct

+ BranchToken []byte

+ CloseFailoverVersion int64

+ DomainID string

+ EventStoreVersion int32

+ NextEventID int64

+ RunID string

+ ShardID int

+ WorkflowID string

+ type Archiver interface

+ Finished func() []uint64

+ Start func()

+ func NewArchiver(ctx workflow.Context, logger log.Logger, metricsClient metrics.Client, ...) Archiver

+ type BootstrapContainer struct

+ Blobstore blobstore.Client

+ ClusterMetadata cluster.Metadata

+ Config *Config

+ DomainCache cache.DomainCache

+ HistoryBlobReader HistoryBlobReader

+ HistoryManager persistence.HistoryManager

+ HistoryV2Manager persistence.HistoryV2Manager

+ Logger log.Logger

+ MetricsClient metrics.Client

+ PublicClient workflowserviceclient.Interface

+ type Client interface

+ Archive func(*ArchiveRequest) error

+ func NewClient(metricsClient metrics.Client, logger log.Logger, ...) Client

+ type ClientMock struct

+ func (_m *ClientMock) Archive(_a0 *ArchiveRequest) error

+ type ClientWorker interface

+ Start func() error

+ Stop func()

+ func NewClientWorker(container *BootstrapContainer) ClientWorker

+ type Config struct

+ ArchivalsPerIteration dynamicconfig.IntPropertyFn

+ ArchiverConcurrency dynamicconfig.IntPropertyFn

+ DeterministicConstructionCheckProbability dynamicconfig.FloatPropertyFn

+ EnableArchivalCompression dynamicconfig.BoolPropertyFnWithDomainFilter

+ HistoryPageSize dynamicconfig.IntPropertyFnWithDomainFilter

+ TargetArchivalBlobSize dynamicconfig.IntPropertyFnWithDomainFilter

+ type HistoryBlob struct

+ Body *shared.History

+ Header *HistoryBlobHeader

+ type HistoryBlobHeader struct

+ CloseFailoverVersion *int64

+ CurrentPageToken *int

+ DomainID *string

+ DomainName *string

+ EventCount *int64

+ FirstEventID *int64

+ FirstFailoverVersion *int64

+ IsLast *bool

+ LastEventID *int64

+ LastFailoverVersion *int64

+ NextPageToken *int

+ RunID *string

+ UploadCluster *string

+ UploadDateTime *string

+ WorkflowID *string

+ type HistoryBlobIterator interface

+ HasNext func() bool

+ Next func() (*HistoryBlob, error)

+ func NewHistoryBlobIterator(request ArchiveRequest, container *BootstrapContainer, domainName string, ...) HistoryBlobIterator

+ type HistoryBlobIteratorMock struct

+ func (_m *HistoryBlobIteratorMock) HasNext() bool

+ func (_m *HistoryBlobIteratorMock) Next() (*HistoryBlob, error)

+ type HistoryBlobReader interface

+ GetBlob func(pageToken int) (*HistoryBlob, error)

+ func NewHistoryBlobReader(itr HistoryBlobIterator) HistoryBlobReader

+ type HistoryBlobReaderMock struct

+ func (_m *HistoryBlobReaderMock) GetBlob(pageToken int) (*HistoryBlob, error)

+ type MockArchiver struct

+ func (_m *MockArchiver) Finished() []uint64

+ func (_m *MockArchiver) Start()

+ type Pump interface

+ Run func() PumpResult

+ func NewPump(ctx workflow.Context, logger log.Logger, metricsClient metrics.Client, ...) Pump

+ type PumpMock struct

+ func (_m *PumpMock) Run() PumpResult

+ type PumpResult struct

+ PumpedHashes []uint64

+ TimeoutWithoutSignals bool

+ UnhandledCarryover []ArchiveRequest