providers

Documentation

Index

• type BaseProviders
  • func NewBaseProviders(ctx context.Context, name string) *BaseProviders
  • func (bp *BaseProviders) CheckProviderAndEnityNames(providerName, connectionName string) error
  • func (bp *BaseProviders) CreateEnity(providerName, enityName string, options interface{}) error
  • func (bp *BaseProviders) GetEnity(providerName, enityName string) (interface{}, error)
  • func (bp *BaseProviders) GetProvider(providerName string) (interface{}, error)
  • func (bp *BaseProviders) GetProviders() *sync.Map
  • func (bp *BaseProviders) Logger() *zerolog.Logger
  • func (bp *BaseProviders) RegisterProvider(providerName string, iface interface{}) error
  • func (bp *BaseProviders) Shutdown() error
  • func (bp *BaseProviders) ShutdownEnity(providerName, serverName string) error
  • func (bp *BaseProviders) Start() error
  • func (bp *BaseProviders) StartEnity(providerName, serverName string) error
• type IBaseProviders

Types

type BaseProviders

type BaseProviders struct {
	IBaseProviders
	// contains filtered or unexported fields
}

func NewBaseProviders

func NewBaseProviders(ctx context.Context, name string) *BaseProviders

Initialize initializes controlling structure.

func (*BaseProviders) CheckProviderAndEnityNames

func (bp *BaseProviders) CheckProviderAndEnityNames(providerName, connectionName string) error

Checks for provider name and connection name for not breaking our rules.

func (*BaseProviders) CreateEnity

func (bp *BaseProviders) CreateEnity(providerName, enityName string, options interface{}) error

CreateEnity creates new connection for specified provider. Provider and connection names should not be empty, otherwise error will be returned.

func (*BaseProviders) GetEnity

func (bp *BaseProviders) GetEnity(providerName, enityName string) (interface{}, error)

GetEnity obtains pointer to connection from specified provider. Provider and connection names should not be empty, otherwise error will be returned.

func (*BaseProviders) GetProvider

func (bp *BaseProviders) GetProvider(providerName string) (interface{}, error)

GetProvider returns requested database provider. Return error if providers wasn't registered.

func (*BaseProviders) GetProviders

func (bp *BaseProviders) GetProviders() *sync.Map

func (*BaseProviders) Logger

func (bp *BaseProviders) Logger() *zerolog.Logger

func (*BaseProviders) RegisterProvider

func (bp *BaseProviders) RegisterProvider(providerName string, iface interface{}) error

RegisterProvider registers provider. If provider with passed name already registered - application will exit.

func (*BaseProviders) Shutdown

func (bp *BaseProviders) Shutdown() error

Shutdown shutdowns all connections.

func (*BaseProviders) ShutdownEnity

func (bp *BaseProviders) ShutdownEnity(providerName, serverName string) error

Shutdown sends Shutdown signal to selected enity.

func (*BaseProviders) Start

func (bp *BaseProviders) Start() error

func (*BaseProviders) StartEnity

func (bp *BaseProviders) StartEnity(providerName, serverName string) error

Start sends start signal to selected enity.

type IBaseProviders

type IBaseProviders interface {
	RegisterProvider(providerName string, iface interface{}) error
	Logger() *zerolog.Logger
	GetProviders() *sync.Map
	Start() error
	Shutdown() error
}