search

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

type Document struct {
	ID      string
	Schema  string
	Data    map[string]any
	Version int
	Delete  bool
}

type DocumentError struct {
	Document Document
	Severity Severity
	Error    string
}

type ErrSchemaAlreadyExists struct {
	SchemaName string
}

type ErrSchemaNotFound struct {
	SchemaName string
}

type ErrSchemaUpdateOutOfOrder struct {
	SchemaName       string
	SchemaID         string
	NewVersion       int
	CurrentVersion   int
	CurrentCreatedAt time.Time
	NewCreatedAt     time.Time
}

type ErrTypeInvalid struct {
	Input string
}

type IndexerConfig struct {
	Batch batch.Config
}

type Mapper interface {
	ColumnToSearchMapping(column schemalog.Column) (map[string]any, error)
	MapColumnValue(column schemalog.Column, value any) (any, error)
}

type Option func(*BatchIndexer)

type Severity uint

type Store interface {
	GetMapper() Mapper
	// schema operations
	ApplySchemaChange(ctx context.Context, logEntry *schemalog.LogEntry) error
	DeleteSchema(ctx context.Context, schemaName string) error
	// data operations
	DeleteTableDocuments(ctx context.Context, schemaName string, tableIDs []string) error
	SendDocuments(ctx context.Context, docs []Document) ([]DocumentError, error)
}

type StoreOption func(*StoreRetrier)

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

type StoreRetryConfig struct {
	// If not provided it defaults to using exponential backoff with initial
	// interval of 1s, max interval of 1min, and 0 max retries.
	Backoff backoff.Config
}