storage

Documentation

Index

• type SQLiteStorage
  • func NewSQLiteStorage(ctx context.Context, path string) (*SQLiteStorage, error)
  • func (s *SQLiteStorage) Events(ctx context.Context, c chan<- service.BridgeEvent) error
  • func (s *SQLiteStorage) StoreEvent(ctx context.Context, evt service.BridgeEvent) error

Types

type SQLiteStorage

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

func NewSQLiteStorage

func NewSQLiteStorage(ctx context.Context, path string) (*SQLiteStorage, error)

NewSQLiteStorage opens and migrates storage from given path.

func (*SQLiteStorage) Events

func (s *SQLiteStorage) Events(ctx context.Context, c chan<- service.BridgeEvent) error

Events sends all events from state archive through given channels grouped by their creation date.

func (*SQLiteStorage) StoreEvent

func (s *SQLiteStorage) StoreEvent(ctx context.Context, evt service.BridgeEvent) error

StoreEvent stores given bridge event in sqlite event storage.