storage

Documentation

Index

• Variables
• func Close() error
• func Register(ctx context.Context, name string, options ...Option) error
• func RegisterConnector(driver string, conn connector)
• func Storage(name string) eventstream.Storager
• type Config
• type Option
  • func WithBuffer(size uint) Option
  • func WithConfig(conf *Config) Option
  • func WithConnect(driver, connect string) Option
  • func WithConnectURL(connect string) Option
  • func WithDebug(debug bool) Option
  • func WithObjectConfig(obj any) Option
  • func WithRawConfig(raw json.RawMessage) Option

Variables

var (
	// ErrInvalidOption if not supported
	ErrInvalidOption = errors.New(`invalid option`)
)

var (
	ErrUndefinedDriver = errors.New(`[storage::registry] undefined driver`)
)

Error list...

Functions

func Close

func Close() error

Close listener

func Register

func Register(ctx context.Context, name string, options ...Option) error

Register connection

func RegisterConnector

func RegisterConnector(driver string, conn connector)

RegisterConnector function

func Storage

func Storage(name string) eventstream.Storager

Storage connection object

Types

type Config

type Config = eventstream.StorageConfig

Config of the storage

type Option

type Option func(cnf *Config)

Option of the connection

func WithBuffer

func WithBuffer(size uint) Option

WithBuffer size of the stream

func WithConfig

func WithConfig(conf *Config) Option

WithConfig custom

func WithConnect

func WithConnect(driver, connect string) Option

WithConnect to the database

func WithConnectURL

func WithConnectURL(connect string) Option

WithConnectURL to the database

func WithDebug

func WithDebug(debug bool) Option

WithDebug mode

func WithObjectConfig

func WithObjectConfig(obj any) Option

WithObjectConfig converts Object to JSON storage config

func WithRawConfig

func WithRawConfig(raw json.RawMessage) Option

WithRawConfig storage config