provider

Documentation

Index

• Variables
• func RegisterHistoryArchiver(scheme, configKey string, ...) error
• func RegisterVisibilityArchiver(scheme, configKey string, ...) error
• type ArchiverProvider
  • func NewArchiverProvider(historyArchiverConfigs config.HistoryArchiverProvider, ...) ArchiverProvider
• type MockArchiverProvider
  • func (_m *MockArchiverProvider) GetHistoryArchiver(scheme string, serviceName string) (archiver.HistoryArchiver, error)
  • func (_m *MockArchiverProvider) GetVisibilityArchiver(scheme string, serviceName string) (archiver.VisibilityArchiver, error)
  • func (_m *MockArchiverProvider) RegisterBootstrapContainer(serviceName string, historyContainer *archiver.HistoryBootstrapContainer, ...) error

Variables

var (
	// ErrUnknownScheme is the error for unknown archiver scheme
	ErrUnknownScheme = errors.New("unknown archiver scheme")
	// ErrNotSupported is the error for not supported archiver implementation
	ErrNotSupported = errors.New("archiver provider not supported")
	// ErrBootstrapContainerNotFound is the error for unable to find the bootstrap container given serviceName
	ErrBootstrapContainerNotFound = errors.New("unable to find bootstrap container for the given service name")
	// ErrArchiverConfigNotFound is the error for unable to find the config for an archiver given scheme
	ErrArchiverConfigNotFound = errors.New("unable to find archiver config for the given scheme")
	// ErrBootstrapContainerAlreadyRegistered is the error for registering multiple containers for the same serviceName
	ErrBootstrapContainerAlreadyRegistered = errors.New("bootstrap container has already been registered")
)

Functions

func RegisterHistoryArchiver

func RegisterHistoryArchiver(scheme, configKey string, constructor func(cfg *config.YamlNode, container *archiver.HistoryBootstrapContainer) (archiver.HistoryArchiver, error)) error

func RegisterVisibilityArchiver

func RegisterVisibilityArchiver(scheme, configKey string, constructor func(cfg *config.YamlNode, container *archiver.VisibilityBootstrapContainer) (archiver.VisibilityArchiver, error)) error

Types

type ArchiverProvider

type ArchiverProvider interface {
	RegisterBootstrapContainer(
		serviceName string,
		historyContainer *archiver.HistoryBootstrapContainer,
		visibilityContainter *archiver.VisibilityBootstrapContainer,
	) error
	GetHistoryArchiver(scheme, serviceName string) (archiver.HistoryArchiver, error)
	GetVisibilityArchiver(scheme, serviceName string) (archiver.VisibilityArchiver, error)
}

ArchiverProvider returns history or visibility 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(
	historyArchiverConfigs config.HistoryArchiverProvider,
	visibilityArchiverConfigs config.VisibilityArchiverProvider,
) ArchiverProvider

NewArchiverProvider returns a new Archiver provider

type MockArchiverProvider

type MockArchiverProvider struct {
	mock.Mock
}

MockArchiverProvider is an autogenerated mock type for the ArchiverProvider type

func (*MockArchiverProvider) GetHistoryArchiver

func (_m *MockArchiverProvider) GetHistoryArchiver(scheme string, serviceName string) (archiver.HistoryArchiver, error)

GetHistoryArchiver provides a mock function with given fields: scheme, serviceName

func (*MockArchiverProvider) GetVisibilityArchiver

func (_m *MockArchiverProvider) GetVisibilityArchiver(scheme string, serviceName string) (archiver.VisibilityArchiver, error)

GetVisibilityArchiver provides a mock function with given fields: scheme, serviceName

func (*MockArchiverProvider) RegisterBootstrapContainer

func (_m *MockArchiverProvider) RegisterBootstrapContainer(serviceName string, historyContainer *archiver.HistoryBootstrapContainer, visibilityContainter *archiver.VisibilityBootstrapContainer) error

RegisterBootstrapContainer provides a mock function with given fields: serviceName, historyContainer, visibilityContainter