provider

Documentation

Overview

Package provider is a generated GoMock package.

Index

• Variables
• type ArchiverProvider
  • func NewArchiverProvider(historyArchiverConfigs *config.HistoryArchiverProvider, ...) ArchiverProvider
• type MockArchiverProvider
  • func NewMockArchiverProvider(ctrl *gomock.Controller) *MockArchiverProvider
  • func (m *MockArchiverProvider) EXPECT() *MockArchiverProviderMockRecorder
  • func (m *MockArchiverProvider) GetHistoryArchiver(scheme, serviceName string) (archiver.HistoryArchiver, error)
  • func (m *MockArchiverProvider) GetVisibilityArchiver(scheme, serviceName string) (archiver.VisibilityArchiver, error)
  • func (m *MockArchiverProvider) RegisterBootstrapContainer(serviceName string, historyContainer *archiver.HistoryBootstrapContainer, ...) error
• type MockArchiverProviderMockRecorder
  • func (mr *MockArchiverProviderMockRecorder) GetHistoryArchiver(scheme, serviceName any) *gomock.Call
  • func (mr *MockArchiverProviderMockRecorder) GetVisibilityArchiver(scheme, serviceName any) *gomock.Call
  • func (mr *MockArchiverProviderMockRecorder) RegisterBootstrapContainer(serviceName, historyContainer, visibilityContainter any) *gomock.Call

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")
)

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 {
	// contains filtered or unexported fields
}

MockArchiverProvider is a mock of ArchiverProvider interface.

func NewMockArchiverProvider

func NewMockArchiverProvider(ctrl *gomock.Controller) *MockArchiverProvider

NewMockArchiverProvider creates a new mock instance.

func (*MockArchiverProvider) EXPECT

func (m *MockArchiverProvider) EXPECT() *MockArchiverProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockArchiverProvider) GetHistoryArchiver

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

GetHistoryArchiver mocks base method.

func (*MockArchiverProvider) GetVisibilityArchiver

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

GetVisibilityArchiver mocks base method.

func (*MockArchiverProvider) RegisterBootstrapContainer

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

RegisterBootstrapContainer mocks base method.

type MockArchiverProviderMockRecorder

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

MockArchiverProviderMockRecorder is the mock recorder for MockArchiverProvider.

func (*MockArchiverProviderMockRecorder) GetHistoryArchiver

func (mr *MockArchiverProviderMockRecorder) GetHistoryArchiver(scheme, serviceName any) *gomock.Call

GetHistoryArchiver indicates an expected call of GetHistoryArchiver.

func (*MockArchiverProviderMockRecorder) GetVisibilityArchiver

func (mr *MockArchiverProviderMockRecorder) GetVisibilityArchiver(scheme, serviceName any) *gomock.Call

GetVisibilityArchiver indicates an expected call of GetVisibilityArchiver.

func (*MockArchiverProviderMockRecorder) RegisterBootstrapContainer

func (mr *MockArchiverProviderMockRecorder) RegisterBootstrapContainer(serviceName, historyContainer, visibilityContainter any) *gomock.Call

RegisterBootstrapContainer indicates an expected call of RegisterBootstrapContainer.