storages

package

v0.0.0-...-70d6eb3 Latest Latest Go to latest Published: Apr 19, 2025 License: LGPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func NewInMemory(size int) notilog.Storage

func NewSqliteStorage(ctx context.Context, logger logz.Logger, dbPath string) (notilog.Storage, error)

type InMemoryStorage struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (s *InMemoryStorage) Append(_ context.Context, n *notilog.Notification) error

func (s *InMemoryStorage) Prune(context.Context) error

func (s *InMemoryStorage) Query(_ context.Context, criteria ...notilog.Criterion) (res []*notilog.Notification, err error)

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

func (s *SqliteStorage) Append(ctx context.Context, notification *notilog.Notification) error

func (s *SqliteStorage) Prune(ctx context.Context) error

func (s *SqliteStorage) Query(ctx context.Context, criteria ...notilog.Criterion) ([]*notilog.Notification, error)