datastore

Documentation

Index

• type Blackhole
  • func (s *Blackhole) Count() int
  • func (s *Blackhole) EngineStatus(ctx context.Context) (model.Event, error)
  • func (s *Blackhole) GetFields(context.Context) (model.FieldGroups, error)
  • func (s *Blackhole) GetResource(ctx context.Context, id string) (*model.Resource, error)
  • func (s *Blackhole) GetResources(ctx context.Context, query []byte) (model.ResourcesResponse, error)
  • func (s *Blackhole) Ping() error
  • func (s *Blackhole) SetWriteError(err error)
  • func (s *Blackhole) Stats(context.Context) (model.Stats, error)
  • func (s *Blackhole) WriteEvent(ctx context.Context, event model.Event) error
  • func (s *Blackhole) WriteResources(ctx context.Context, resources model.Resources) error

Types

type Blackhole

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

Datastore implementation that drops all inserted data, but keeps track of number of resources written (returned via Stats()) Useful for tests, and can return a provided error on write

func (*Blackhole) Count

func (s *Blackhole) Count() int

func (*Blackhole) EngineStatus

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

func (*Blackhole) GetFields

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

func (*Blackhole) GetResource

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

func (*Blackhole) GetResources

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

func (*Blackhole) Ping

func (s *Blackhole) Ping() error

func (*Blackhole) SetWriteError

func (s *Blackhole) SetWriteError(err error)

func (*Blackhole) Stats

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

func (*Blackhole) WriteEvent

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

func (*Blackhole) WriteResources

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