datastore

Documentation

Index

• Constants
• type Datastore
  • func NewDatastore(ctx context.Context, cfg config.Config, logger *zap.Logger) (Datastore, error)
• type SQLiteStore
  • func NewSQLiteStore(ctx context.Context, cfg config.Config, zapLogger *zap.Logger) (*SQLiteStore, error)
  • func (s *SQLiteStore) EngineStatus(ctx context.Context) (model.Event, error)
  • func (s *SQLiteStore) GetFields(ctx context.Context) (model.FieldGroups, error)
  • func (s *SQLiteStore) GetResource(ctx context.Context, id string) (*model.Resource, error)
  • func (s *SQLiteStore) GetResources(ctx context.Context, jsonQuery []byte) (model.ResourcesResponse, error)
  • func (s *SQLiteStore) Ping() error
  • func (s *SQLiteStore) Stats(context.Context) (model.Stats, error)
  • func (s *SQLiteStore) WriteEvent(ctx context.Context, event model.Event) error
  • func (s *SQLiteStore) WriteResources(ctx context.Context, resources model.Resources) error

Constants

const (
	//limit number of resource returned
	DefaultLimit  = 25
	LimitMaxValue = 2000
)

Types

type Datastore

type Datastore interface {
	GetResource(context.Context, string) (*model.Resource, error)
	GetResources(context.Context, []byte) (model.ResourcesResponse, error)
	WriteResources(context.Context, model.Resources) error
	Stats(context.Context) (model.Stats, error)
	WriteEvent(context.Context, model.Event) error
	EngineStatus(ctx context.Context) (model.Event, error)
	Ping() error
}

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

func NewDatastore

func NewDatastore(ctx context.Context, cfg config.Config, logger *zap.Logger) (Datastore, error)

type SQLiteStore

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

func NewSQLiteStore

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

func (*SQLiteStore) EngineStatus

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

func (*SQLiteStore) GetFields

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

TODO remove this api

func (*SQLiteStore) GetResource

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

func (*SQLiteStore) GetResources

func (s *SQLiteStore) GetResources(ctx context.Context, jsonQuery []byte) (model.ResourcesResponse, error)

func (*SQLiteStore) Ping

func (s *SQLiteStore) Ping() error

func (*SQLiteStore) Stats

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

func (*SQLiteStore) WriteEvent

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

func (*SQLiteStore) WriteResources

func (s *SQLiteStore) WriteResources(ctx context.Context, resources model.Resources) error