datastore

Jun 22, 2022

Changes in this version

type Datastore

+ EngineStatus func(ctx context.Context) (model.Event, error)

+ WriteEvent func(context.Context, model.Event) error

type SQLiteStore

+ func (s *SQLiteStore) EngineStatus(ctx context.Context) (model.Event, error)

+ func (s *SQLiteStore) WriteEvent(ctx context.Context, event model.Event) error

Jun 21, 2022

Changes in this version

+ const DefaultLimit

+ const LimitMaxValue

type Datastore

+ GetEngineStatus func(context.Context) (model.EngineStatus, error)

+ GetFields func(context.Context) (model.FieldGroups, error)

+ GetResource func(context.Context, string) (*model.Resource, error)

+ Ping func() error

+ WriteEngineStatusEnd func(context.Context, string, error) error

+ WriteEngineStatusStart func(context.Context, string) error

type SQLiteStore

+ func (s *SQLiteStore) GetEngineStatus(context.Context) (model.EngineStatus, error)

+ func (s *SQLiteStore) GetFields(context.Context) (model.FieldGroups, error)

+ func (s *SQLiteStore) GetResource(ctx context.Context, id string) (*model.Resource, error)

+ func (s *SQLiteStore) Ping() error

+ func (s *SQLiteStore) WriteEngineStatusEnd(ctx context.Context, resource string, err error) error

+ func (s *SQLiteStore) WriteEngineStatusStart(ctx context.Context, resource string) error

May 16, 2022

Changes in this version

type Datastore

+ Stats func(context.Context) (model.Stats, error)

type MemoryStore

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

type SQLiteStore

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

May 5, 2022

Changes in this version

+ type Datastore interface

+ GetResources func(context.Context, model.Filter) ([]*model.Resource, error)

+ WriteResources func(context.Context, []*model.Resource) error

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

+ type MemoryStore struct

+ 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) WriteResources(ctx context.Context, resources []*model.Resource) error

+ type SQLiteStore struct

+ 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) WriteResources(ctx context.Context, resources []*model.Resource) error