package storage

import "github.com/fenole/szmaterlok/storage"

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.

Source Files ¶

migrations.go sqlite.go