search

type Adapter interface {
	Search(ctx context.Context, req *Request) (*Response, error)
	Index(ctx context.Context, req *IndexRequest) error
	Delete(ctx context.Context, index, id string) error
	BulkIndex(ctx context.Context, index string, documents []any) error
	BulkDelete(ctx context.Context, index string, documentIDs []string) error
	IndexExists(ctx context.Context, indexName string) (bool, error)
	CreateIndex(ctx context.Context, indexName string, settings *IndexSettings) error
	Health(ctx context.Context) error
	Type() Engine
}

type AdapterFactory func(conn any) (Adapter, error)

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

type Collector interface {
	SearchQuery(engine string, err error)
	SearchIndex(engine, operation string)
}

type Config struct {
	IndexPrefix     string
	DefaultEngine   string
	AutoCreateIndex bool
	IndexSettings   *IndexSettings
}

type Engine string

type Hit struct {
	ID     string         `json:"id"`
	Score  float64        `json:"score"`
	Source map[string]any `json:"source"`
}

type IndexRequest struct {
	Index      string `json:"index"`
	DocumentID string `json:"document_id,omitempty"`
	Document   any    `json:"document"`
}

type IndexSettings struct {
	Shards           int
	Replicas         int
	RefreshInterval  string
	SearchableFields []string
	FilterableFields []string
}

type NoOpCollector struct{}

type Request struct {
	Index  string         `json:"index"`
	Query  string         `json:"query"`
	Filter map[string]any `json:"filter,omitempty"`
	From   int            `json:"from,omitempty"`
	Size   int            `json:"size,omitempty"`
}

type Response struct {
	Total    int64         `json:"total"`
	Hits     []Hit         `json:"hits"`
	Duration time.Duration `json:"duration"`
	Engine   Engine        `json:"engine"`
}