provider

Documentation

Index

• Variables
• type HistoryArchiverConfigs
• type Provider
  • func NewArchiverProvider(historyContainer *archiver.HistoryBootstrapContainer, ...) Provider
• type VisibilityArchiverConfigs

Variables

var (
	// ErrUnknownScheme is the error for unknown archiver scheme
	ErrUnknownScheme = errors.New("unknown archiver scheme")
)

Types

type HistoryArchiverConfigs

type HistoryArchiverConfigs struct {
	FileStore *filestore.HistoryArchiverConfig
}

HistoryArchiverConfigs contain config for all implementations of the HistoryArchiver interface

type Provider

type Provider interface {
	GetHistoryArchiver(scheme string, serviceName string, tags ...tag.Tag) (archiver.HistoryArchiver, error)
	GetVisibilityArchiver(scheme string, serviceName string, tags ...tag.Tag) (archiver.VisibilityArchiver, error)
}

Provider returns history or visiblity archiver based on the scheme and serviceName. The archiver for each combination of scheme and serviceName will be created only once and cached.

func NewArchiverProvider

func NewArchiverProvider(
	historyContainer *archiver.HistoryBootstrapContainer,
	visibilityContainer *archiver.VisibilityBootstrapContainer,
	historyArchiverConfigs *HistoryArchiverConfigs,
	visibilityArchiverConfigs *VisibilityArchiverConfigs,
) Provider

NewArchiverProvider returns a new Archiver provider

type VisibilityArchiverConfigs

type VisibilityArchiverConfigs struct {
	FileStore *filestore.VisibilityArchiverConfig
}

VisibilityArchiverConfigs contain config for all implementations of the VisibilityArchiver interface