datastore

type Datastore ¶

type Datastore interface {
	GetResources(context.Context, model.Filter) ([]*model.Resource, error)
	WriteResources(context.Context, []*model.Resource) error
	Stats(context.Context) (model.Stats, error)
}

Datastore provides an interface to read/write/update to a store

func NewDatastore(ctx context.Context, cfg config.Config) (Datastore, error)

type MemoryStore ¶

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

MemoryStore stores the last resources written in memory and return it without any filtering Not for production use!

func NewMemoryStore(ctx context.Context, cfg config.Config) *MemoryStore

func (m *MemoryStore) GetResources(ctx context.Context, filter model.Filter) ([]*model.Resource, error)

func (m *MemoryStore) Stats(context.Context) (model.Stats, error)

func (m *MemoryStore) WriteResources(ctx context.Context, resources []*model.Resource) error

type SQLiteStore ¶

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

func NewSQLiteStore(ctx context.Context, cfg config.Config) (*SQLiteStore, error)

func (s *SQLiteStore) GetResources(ctx context.Context, filter model.Filter) ([]*model.Resource, error)

func (s *SQLiteStore) Stats(context.Context) (model.Stats, error)

func (s *SQLiteStore) WriteResources(ctx context.Context, resources []*model.Resource) error