provider

package
v1.3.7-prerelease21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 11 Imported by: 7

Documentation

Overview

Package provider is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
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 added in v1.2.7 

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

func RegisterVisibilityArchiver added in v1.2.7 

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

Types

type ArchiverProvider added in v0.7.0 

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

func NewNoOpArchiverProvider added in v1.2.13 

func NewNoOpArchiverProvider() ArchiverProvider

type MockArchiverProvider added in v0.7.0 

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

MockArchiverProvider is a mock of ArchiverProvider interface.

func NewMockArchiverProvider added in v1.3.6 

func NewMockArchiverProvider(ctrl *gomock.Controller) *MockArchiverProvider

NewMockArchiverProvider creates a new mock instance.

func (*MockArchiverProvider) EXPECT added in v1.3.6 

func (m *MockArchiverProvider) EXPECT() *MockArchiverProviderMockRecorder

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

func (*MockArchiverProvider) GetHistoryArchiver added in v0.7.0 

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

GetHistoryArchiver mocks base method.

func (*MockArchiverProvider) GetVisibilityArchiver added in v0.7.0 

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

GetVisibilityArchiver mocks base method.

func (*MockArchiverProvider) RegisterBootstrapContainer added in v0.7.0 

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

RegisterBootstrapContainer mocks base method.

type MockArchiverProviderMockRecorder added in v1.3.6 

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

MockArchiverProviderMockRecorder is the mock recorder for MockArchiverProvider.

func (*MockArchiverProviderMockRecorder) GetHistoryArchiver added in v1.3.6 

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

GetHistoryArchiver indicates an expected call of GetHistoryArchiver.

func (*MockArchiverProviderMockRecorder) GetVisibilityArchiver added in v1.3.6 

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

GetVisibilityArchiver indicates an expected call of GetVisibilityArchiver.

func (*MockArchiverProviderMockRecorder) RegisterBootstrapContainer added in v1.3.6 

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

RegisterBootstrapContainer indicates an expected call of RegisterBootstrapContainer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.