index

type ACLEntry struct {
	URI         string
	Permissions []string
}

type ActiveIndexGetter interface {
	GetActiveIndex() (*opensearch.Client, string)
}

type BooleanQuery struct {
	Must    []json.RawMessage `json:"must,omitempty"`
	MustNot []ElasticQuery    `json:"must_not,omitempty"`
	Should  []ElasticQuery    `json:"should,omitempty"`
	Filter  []ElasticQuery    `json:"filter,omitempty"`
}

type ClusterAuth struct {
	IAM bool
}

type ClusterGetter interface {
	GetCluster(ctx context.Context, name string) (postgres.Cluster, error)
}

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

type CoordinatorOptions struct {
	Logger          *slog.Logger
	Metrics         *Metrics
	Documents       repository.Documents
	ClientGetter    OpenSearchClientFunc
	Validator       ValidatorSource
	DefaultLanguage string
}

type Document struct {
	Fields map[string]Field
}

type DocumentSource struct {
	DocumentLanguage []string `json:"document.language"`
}

type DocumentState struct {
	Created        time.Time         `json:"created"`
	Modified       time.Time         `json:"modified"`
	CurrentVersion int64             `json:"current_version"`
	ACL            []ACLEntry        `json:"acl"`
	Heads          map[string]Status `json:"heads"`
	Document       newsdoc.Document  `json:"document"`
}

type ElasticError struct {
	Reason  string           `json:"reason"`
	Details string           `json:"details"`
	Type    ElasticErrorType `json:"type"`
}

type ElasticErrorResponse struct {
	ErrorInfo ElasticError `json:"error"`
	Status    int          `json:"status"`
}

type ElasticErrorType string

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

type ElasticQuery struct {
	Bool *BooleanQuery     `json:"bool,omitempty"`
	Term map[string]string `json:"term,omitempty"`
	Ids  *IdsQuery         `json:"ids,omitempty"`
}

type ElasticSearchRequest struct {
	Query  ElasticQuery    `json:"query"`
	Fields json.RawMessage `json:"fields,omitempty"`
	Sort   json.RawMessage `json:"sort,omitempty"`
	Source *bool           `json:"_source,omitempty"`
	From   *int            `json:"from,omitempty"`
	Size   *int            `json:"size,omitempty"`
}

type Field struct {
	Type   FieldType `json:"type"`
	Values []string  `json:"values"`
}

type FieldType string

type IdsQuery struct {
	Values []string `json:"values,omitempty"`
}

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

type IndexerOptions struct {
	Logger          *slog.Logger
	SetName         string
	Database        *pgxpool.Pool
	Client          *opensearch.Client
	Documents       repository.Documents
	Validator       ValidatorSource
	Metrics         *Metrics
	DefaultLanguage string
}

type Language struct {
	Code     string
	Language string
	Analyzer string
}

type LanguageConfig struct {
	NameSuffix string
	Language   string
	Settings   OpensearchSettings
}

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

type Mapping struct {
	Type FieldType `json:"type"`
}

type MappingChange struct {
	Mapping

	New bool `json:"new"`
}

type MappingChanges map[string]MappingChange

type Mappings struct {
	Properties map[string]Mapping `json:"properties"`
}

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

type Notification struct {
	Type NotifyChannel
	Name string
}

type NotifyChannel string

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

type OpenSearchClientFunc func(
	ctx context.Context, cluster string,
) (*opensearch.Client, error)

type OpensearchSettings struct {
	Settings struct {
		Analysis struct {
			Analyzer struct {
				Default struct {
					Type string `json:"type"`
				} `json:"default"`
			} `json:"analyzer"`
		} `json:"analysis"`
	} `json:"settings"`
}

type Parameters struct {
	Addr            string
	ProfileAddr     string
	Logger          *slog.Logger
	Database        *pgxpool.Pool
	DefaultCluster  string
	ClusterAuth     ClusterAuth
	Client          OpenSearchClientFunc
	Documents       repository.Documents
	Validator       ValidatorSource
	Metrics         *Metrics
	DefaultLanguage string
	NoIndexer       bool
	PublicJWTKey    *ecdsa.PublicKey
}

type RawSearchRequest struct {
	Query  json.RawMessage `json:"query"`
	Fields json.RawMessage `json:"fields"`
	Sort   json.RawMessage `json:"sort"`
	Source *bool           `json:"_source,omitempty"`
	From   *int            `json:"from,omitempty"`
	Size   *int            `json:"size,omitempty"`
}

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

type SearchResponseBody struct {
	Hits struct {
		Hits []struct {
			ID     string         `json:"_id"`
			Index  string         `json:"_index"`
			Source DocumentSource `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}

type ServerOptions struct {
	Hooks          *twirp.ServerHooks
	AuthMiddleware func(
		w http.ResponseWriter, r *http.Request, next http.Handler,
	) error
}

type Status struct {
	ID      int64
	Version int64
	Creator string
	Created time.Time
	Meta    newsdoc.DataMap
}

type ValidatorSource interface {
	GetValidator() *revisor.Validator
}

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