instrumentation

Documentation

Index

• func NewStore(inner search.Store, instrumentation *otel.Instrumentation) (search.Store, error)
• type SearchStore
  • func (s *SearchStore) ApplySchemaChange(ctx context.Context, logEntry *schemalog.LogEntry) (err error)
  • func (s *SearchStore) DeleteSchema(ctx context.Context, schemaName string) (err error)
  • func (s *SearchStore) DeleteTableDocuments(ctx context.Context, schemaName string, tableIDs []string) (err error)
  • func (s *SearchStore) GetMapper() search.Mapper
  • func (s *SearchStore) SendDocuments(ctx context.Context, docs []search.Document) (docErrs []search.DocumentError, err error)

Functions

func NewStore

func NewStore(inner search.Store, instrumentation *otel.Instrumentation) (search.Store, error)

Types

type SearchStore

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

func (*SearchStore) ApplySchemaChange

func (s *SearchStore) ApplySchemaChange(ctx context.Context, logEntry *schemalog.LogEntry) (err error)

func (*SearchStore) DeleteSchema

func (s *SearchStore) DeleteSchema(ctx context.Context, schemaName string) (err error)

func (*SearchStore) DeleteTableDocuments

func (s *SearchStore) DeleteTableDocuments(ctx context.Context, schemaName string, tableIDs []string) (err error)

func (*SearchStore) GetMapper

func (s *SearchStore) GetMapper() search.Mapper

func (*SearchStore) SendDocuments

func (s *SearchStore) SendDocuments(ctx context.Context, docs []search.Document) (docErrs []search.DocumentError, err error)