search

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

type FacetValue struct {
	Value string `json:"value"`
	Count int    `json:"count"`
}

type Facets struct {
	Types      map[ResultType]int `json:"types"`
	AssetTypes []FacetValue       `json:"asset_types"`
	Providers  []FacetValue       `json:"providers"`
	Tags       []FacetValue       `json:"tags"`
}

type Filter struct {
	Query      string       `json:"query" validate:"omitempty,max=256"` // Optional query for full-text search
	Types      []ResultType `json:"types,omitempty"`
	AssetTypes []string     `json:"asset_types,omitempty"` // Filter assets by type (TABLE, VIEW, etc.)
	Providers  []string     `json:"providers,omitempty"`   // Filter assets by provider
	Tags       []string     `json:"tags,omitempty"`        // Filter assets by tags
	Limit      int          `json:"limit" validate:"omitempty,gte=1,lte=100"`
	Offset     int          `json:"offset" validate:"omitempty,gte=0"`
}

type IndexRepository interface {
	GetSearchDocument(ctx context.Context, entityType, entityID string) (*SearchDocument, error)
	ScanSearchDocuments(ctx context.Context, afterType, afterID string, limit int) ([]SearchDocument, error)
	CountSearchDocuments(ctx context.Context) (int, error)
}

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

type NoopReindexBroadcaster struct{}

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

type ReindexBroadcaster interface {
	BroadcastStarted(total int)
	BroadcastProgress(indexed, errors, total int)
	BroadcastCompleted(indexed, errors, total int)
	BroadcastFailed(err error, indexed, errors, total int)
}

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

type Repository interface {
	Search(ctx context.Context, filter Filter) ([]*Result, int, *Facets, error)
	GetMetadata(ctx context.Context, resultType ResultType, ids []string) (map[string]map[string]interface{}, error)
}

type Response struct {
	Results []*Result `json:"results"`
	Total   int       `json:"total"`
	Facets  *Facets   `json:"facets"`
	Limit   int       `json:"limit"`
	Offset  int       `json:"offset"`
}

type Result struct {
	Type        ResultType             `json:"type"`
	ID          string                 `json:"id"`
	Name        string                 `json:"name"`
	Description *string                `json:"description,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	URL         string                 `json:"url"`
	Rank        float32                `json:"rank"`
	UpdatedAt   *time.Time             `json:"updated_at,omitempty"`
}

type ResultType string

type SearchDocument struct {
	Type            string
	EntityID        string
	Name            string
	Description     *string
	URLPath         string
	AssetType       *string
	PrimaryProvider *string
	Providers       []string
	Tags            []string
	MRN             *string
	CreatedBy       *string
	CreatedAt       *time.Time
	UpdatedAt       time.Time
	Metadata        map[string]interface{}
	Documentation   *string
}

type SearchIndexer interface {
	Index(ctx context.Context, doc SearchDocument) error
	BulkIndex(ctx context.Context, docs []SearchDocument) error
	Delete(ctx context.Context, entityType, entityID string) error
	Search(ctx context.Context, filter Filter) ([]*Result, int, *Facets, error)
	Healthy(ctx context.Context) bool
	CreateIndex(ctx context.Context) error
	Close() error
}

type SearchObserver interface {
	OnEntityChanged(ctx context.Context, entityType, entityID string)
	OnEntityDeleted(ctx context.Context, entityType, entityID string)
}

type Service interface {
	Search(ctx context.Context, filter Filter) (*Response, error)
}