storage

Documentation

Index

• Variables
• type StorageBackend
  • func Connect(cfg config.Storage, logger zerolog.Logger, recv chan msg.ParsedMsg) (*StorageBackend, error)
  • func (b *StorageBackend) Start() error
  • func (b *StorageBackend) Stop() error

Variables

var (
	ErrInvalidStorageUri  = errors.New("invalid storage uri")
	ErrUnsupportedBackend = errors.New("unsupported storage backend")
	ErrRecvChanNotSet     = errors.New("receive channel not set")
	ErrUnsupportedMsgType = errors.New("unsupported message type")
)

Types

type StorageBackend

type StorageBackend struct {
	Store eventstore.Store

	sync.WaitGroup
	// contains filtered or unexported fields
}

func Connect

func Connect(cfg config.Storage, logger zerolog.Logger, recv chan msg.ParsedMsg) (*StorageBackend, error)

Connect establishes the connection to the given storage backend based on a URI

func (*StorageBackend) Start

func (b *StorageBackend) Start() error

Start satisfies the StorageBackend interface

func (*StorageBackend) Stop

func (b *StorageBackend) Stop() error

Stop satisfies the StorageBackend interface