memory

Documentation

Index

• type Config
• type Provider
  • func New(cfg Config) *Provider
  • func (p *Provider) Capabilities(context.Context) (types.CapabilitySet, error)
  • func (p *Provider) DeleteBySource(_ context.Context, index, registrationKey string, sourceIDs []string) error
  • func (p *Provider) DeleteDocuments(_ context.Context, index string, ids []string) error
  • func (p *Provider) EnsureIndex(_ context.Context, def types.IndexDefinition) error
  • func (p *Provider) Health(_ context.Context, req types.HealthRequest) (types.HealthStatus, error)
  • func (p *Provider) Name() string
  • func (p *Provider) ReplaceDocuments(_ context.Context, index, registrationKey string, sourceIDs []string, ...) error
  • func (p *Provider) ResetRegistration(_ context.Context, index, registrationKey string) error
  • func (p *Provider) Search(_ context.Context, req types.SearchRequest) (types.SearchResultPage, error)
  • func (p *Provider) SearchBatch(ctx context.Context, requests []types.SearchRequest) ([]types.SearchResultPage, error)
  • func (p *Provider) Suggest(_ context.Context, req types.SuggestRequest) (types.SuggestResult, error)
  • func (p *Provider) UpsertDocuments(_ context.Context, index string, docs []types.Document) error

Types

type Config

type Config struct {
	Clock types.Clock
}

type Provider

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

func New

func New(cfg Config) *Provider

func (*Provider) Capabilities

func (p *Provider) Capabilities(context.Context) (types.CapabilitySet, error)

func (*Provider) DeleteBySource

func (p *Provider) DeleteBySource(_ context.Context, index, registrationKey string, sourceIDs []string) error

func (*Provider) DeleteDocuments

func (p *Provider) DeleteDocuments(_ context.Context, index string, ids []string) error

func (*Provider) EnsureIndex

func (p *Provider) EnsureIndex(_ context.Context, def types.IndexDefinition) error

func (*Provider) Health

func (p *Provider) Health(_ context.Context, req types.HealthRequest) (types.HealthStatus, error)

func (*Provider) Name

func (p *Provider) Name() string

func (*Provider) ReplaceDocuments

func (p *Provider) ReplaceDocuments(_ context.Context, index, registrationKey string, sourceIDs []string, docs []types.Document) error

func (*Provider) ResetRegistration

func (p *Provider) ResetRegistration(_ context.Context, index, registrationKey string) error

func (*Provider) Search

func (p *Provider) Search(_ context.Context, req types.SearchRequest) (types.SearchResultPage, error)

func (*Provider) SearchBatch

func (p *Provider) SearchBatch(ctx context.Context, requests []types.SearchRequest) ([]types.SearchResultPage, error)

func (*Provider) Suggest

func (p *Provider) Suggest(_ context.Context, req types.SuggestRequest) (types.SuggestResult, error)

func (*Provider) UpsertDocuments

func (p *Provider) UpsertDocuments(_ context.Context, index string, docs []types.Document) error