search

type ConsistencyCounts struct {
	Expected    int `json:"expected"`
	Observed    int `json:"observed"`
	Missing     int `json:"missing"`
	Stale       int `json:"stale"`
	Unsupported int `json:"unsupported"`
	Upserted    int `json:"upserted"`
	Deleted     int `json:"deleted"`
	Skipped     int `json:"skipped"`
	Failed      int `json:"failed"`
	Clean       int `json:"clean"`
}

type ConsistencyObjectCount struct {
	Organization string `json:"organization"`
	Index        string `json:"index"`
	Expected     int    `json:"expected"`
	Observed     int    `json:"observed"`
	Missing      int    `json:"missing"`
	Stale        int    `json:"stale"`
}

type ConsistencyPlan struct {
	AllOrganizations bool
	Organization     string
	Index            string
	Repair           bool
	DryRun           bool
}

type ConsistencyResult struct {
	AllOrganizations  bool                     `json:"all_organizations"`
	Organization      string                   `json:"organization,omitempty"`
	Index             string                   `json:"index,omitempty"`
	Repair            bool                     `json:"repair,omitempty"`
	DryRun            bool                     `json:"dry_run,omitempty"`
	Counts            ConsistencyCounts        `json:"counts"`
	ObjectCounts      []ConsistencyObjectCount `json:"object_counts,omitempty"`
	MissingDocuments  []string                 `json:"missing_documents,omitempty"`
	StaleDocuments    []string                 `json:"stale_documents,omitempty"`
	UnsupportedScopes []string                 `json:"unsupported_scopes,omitempty"`
	Failures          []string                 `json:"failures,omitempty"`
	Duration          time.Duration            `json:"duration"`
}

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

type ConsistencyTarget interface {
	Ping(context.Context) error
	EnsureChefIndex(context.Context) error
	SearchIDs(context.Context, Query) ([]string, error)
	BulkUpsert(context.Context, []Document) error
	DeleteDocument(context.Context, string) error
	Refresh(context.Context) error
}

type Document struct {
	Index    string
	Name     string
	Object   map[string]any
	Partial  map[string]any
	Fields   map[string][]string
	Resource authz.Resource
}

type DocumentBuilder struct{}

type DocumentIndexer interface {
	UpsertDocuments(context.Context, []Document) error
	DeleteDocuments(context.Context, []DocumentRef) error
}

type DocumentRef struct {
	Organization string
	Index        string
	Name         string
}

type Index interface {
	Name() string
	Status() Status
	Indexes(context.Context, string) ([]string, error)
	Search(context.Context, Query) (Result, error)
}

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

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

type OpenSearchCapabilities struct {
	IndexExistsChecks             bool
	CreateIndex                   bool
	PutMapping                    bool
	BulkIndexing                  bool
	SearchIDs                     bool
	SearchAfterPagination         bool
	Refresh                       bool
	DeleteDocument                bool
	DeleteByQuery                 bool
	DeleteByQueryFallbackRequired bool
	TotalHitsObjectResponses      bool
}

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

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

type OpenSearchOption func(*openSearchOptions)

type OpenSearchProviderInfo struct {
	Distribution  string
	Version       string
	VersionParsed bool
	Major         int
	Minor         int
	Patch         int
	Tagline       string
	NodeName      string
	ClusterName   string
	BuildFlavor   string
	BuildType     string
	BuildHash     string
	Capabilities  OpenSearchCapabilities
}

type OpenSearchTransport interface {
	Do(*http.Request) (*http.Response, error)
}

type Query struct {
	Organization string
	Index        string
	Q            string
}

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

type ReindexCounts struct {
	Scanned  int `json:"scanned"`
	Upserted int `json:"upserted"`
	Deleted  int `json:"deleted"`
	Skipped  int `json:"skipped"`
	Missing  int `json:"missing"`
	Failed   int `json:"failed"`
}

type ReindexMode string

type ReindexPlan struct {
	Mode             ReindexMode
	AllOrganizations bool
	Organization     string
	Index            string
	Names            []string
	DryRun           bool
}

type ReindexResult struct {
	Mode             ReindexMode   `json:"mode"`
	AllOrganizations bool          `json:"all_organizations"`
	Organization     string        `json:"organization,omitempty"`
	Index            string        `json:"index,omitempty"`
	Names            []string      `json:"names,omitempty"`
	DryRun           bool          `json:"dry_run,omitempty"`
	Counts           ReindexCounts `json:"counts"`
	Failures         []string      `json:"failures,omitempty"`
	Duration         time.Duration `json:"duration"`
}

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

type ReindexTarget interface {
	Ping(context.Context) error
	EnsureChefIndex(context.Context) error
	DeleteByQuery(context.Context, string, string) error
	DeleteDocument(context.Context, string) error
	BulkUpsert(context.Context, []Document) error
	Refresh(context.Context) error
}

type Result struct {
	Documents []Document `json:"documents"`
}

type Status struct {
	Backend    string `json:"backend"`
	Configured bool   `json:"configured"`
	Message    string `json:"message"`
}