index

package

Go to main page

Versions in this module

v0

v0.3.2

Feb 2, 2024

v0.3.1

Feb 1, 2024

v0.3.0

Feb 1, 2024

Changes in this version

+ const IndexerStopTimeout

+ const ScopeIndexAdmin

+ func ListenAndServe(ctx context.Context, addr string, h http.Handler) error

+ func RequireAnyScope(ctx context.Context, scopes ...string) (*elephantine.AuthInfo, error)

+ func RunIndex(ctx context.Context, p Parameters) error

+ type ActiveIndexGetter interface

+ GetActiveIndex func() (*opensearch.Client, string)

+ type ClusterAuth struct

+ IAM bool

+ type ClusterGetter interface

+ GetCluster func(ctx context.Context, name string) (postgres.Cluster, error)

+ type Coordinator struct

+ func NewCoordinator(db *pgxpool.Pool, opt CoordinatorOptions) (*Coordinator, error)

+ func (c *Coordinator) EnsureDefaultIndexSet(ctx context.Context, defaultClusterURL string, clusterAuth ClusterAuth) error

+ func (c *Coordinator) GetActiveIndex() (*opensearch.Client, string)

+ func (c *Coordinator) Run(ctx context.Context) error

+ func (c *Coordinator) Stop(timeout time.Duration)

+ type CoordinatorOptions struct

+ ClientGetter OpenSearchClientFunc

+ DefaultLanguage string

+ Documents repository.Documents

+ Logger *slog.Logger

+ Metrics *Metrics

+ Validator ValidatorSource

type ElasticErrorType

+ const ErrorTypeClusterUnavailable

type Indexer

+ func (idx *Indexer) Stop(timeout time.Duration) error

+ func (idx *Indexer) Stopping() <-chan struct{}

+ type ManagementService struct

+ func NewManagementService(logger *slog.Logger, db *pgxpool.Pool) (*ManagementService, error)

+ func (s *ManagementService) DeleteCluster(ctx context.Context, req *index.DeleteClusterRequest) (*index.DeleteClusterResponse, error)

+ func (s *ManagementService) DeleteIndexSet(ctx context.Context, req *index.DeleteIndexSetRequest) (*index.DeleteIndexSetResponse, error)

+ func (s *ManagementService) ListClusters(ctx context.Context, _ *index.ListClustersRequest) (*index.ListClustersResponse, error)

+ func (s *ManagementService) ListIndexSets(ctx context.Context, req *index.ListIndexSetsRequest) (*index.ListIndexSetsResponse, error)

+ func (s *ManagementService) PartialReindex(ctx context.Context, _ *index.PartialReindexRequest) (*index.PartialReindexResponse, error)

+ func (s *ManagementService) RegisterCluster(ctx context.Context, req *index.RegisterClusterRequest) (*index.RegisterClusterResponse, error)

+ func (s *ManagementService) Reindex(ctx context.Context, req *index.ReindexRequest) (*index.ReindexResponse, error)

+ func (s *ManagementService) SetIndexSetStatus(ctx context.Context, req *index.SetIndexSetStatusRequest) (*index.SetIndexSetStatusResponse, error)

+ type Notification struct

+ Name string

+ Type NotifyChannel

+ func (n Notification) Send(ctx context.Context, q *postgres.Queries) error

+ type NotifyChannel string

+ const NotifyIndexStatusChange

+ type OSClientProvider struct

+ func NewOSClientProvider(clusters ClusterGetter) *OSClientProvider

+ func (o *OSClientProvider) GetClientForCluster(ctx context.Context, cluster string) (*opensearch.Client, error)

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

+ type Parameters struct

+ Addr string

+ Client OpenSearchClientFunc

+ ClusterAuth ClusterAuth

+ Database *pgxpool.Pool

+ DefaultCluster string

+ DefaultLanguage string

+ Documents repository.Documents

+ Logger *slog.Logger

+ Metrics *Metrics

+ NoIndexer bool

+ ProfileAddr string

+ PublicJWTKey *ecdsa.PublicKey

+ Validator ValidatorSource

+ type ServerOptions struct

+ AuthMiddleware func(w http.ResponseWriter, r *http.Request, next http.Handler) error

+ Hooks *twirp.ServerHooks

+ func (so *ServerOptions) SetJWTValidation(jwtKey *ecdsa.PublicKey)

v0.2.0

Jan 9, 2024

Changes in this version

type BooleanQuery

+ MustNot []ElasticQuery

+ type DocumentSource struct

+ DocumentLanguage []string

type ElasticQuery

+ Ids *IdsQuery

+ type IdsQuery struct

+ Values []string

+ type SearchResponseBody struct

+ Hits struct{ ... }

v0.1.7

Dec 1, 2023

v0.1.6

Dec 1, 2023

v0.1.5

Nov 30, 2023

v0.1.4

Nov 10, 2023

Changes in this version

+ func ElasticHandler(logger *slog.Logger, w http.ResponseWriter, r *http.Request, ...)

+ type ACLEntry struct

+ Permissions []string

+ URI string

+ type BooleanQuery struct

+ Filter []ElasticQuery

+ Must []json.RawMessage

+ Should []ElasticQuery

+ type Document struct

+ Fields map[string]Field

+ func BuildDocument(validator *revisor.Validator, state *DocumentState) *Document

+ func NewDocument() *Document

+ func (d *Document) AddField(name string, t FieldType, value string)

+ func (d *Document) AddInteger(name string, value int64)

+ func (d *Document) AddTime(name string, value time.Time)

+ func (d *Document) Mappings() Mappings

+ func (d *Document) SetField(name string, t FieldType, values ...string)

+ func (d *Document) Values() map[string][]string

+ type DocumentState struct

+ ACL []ACLEntry

+ Created time.Time

+ CurrentVersion int64

+ Document newsdoc.Document

+ Heads map[string]Status

+ Modified time.Time

+ type ElasticError struct

+ Details string

+ Reason string

+ Type ElasticErrorType

+ type ElasticErrorResponse struct

+ ErrorInfo ElasticError

+ Status int

+ func ElasticErrorf(t ElasticErrorType, format string, a ...any) ElasticErrorResponse

+ func (er ElasticErrorResponse) Error() string

+ type ElasticErrorType string

+ const ErrorTypeAccessDenied

+ const ErrorTypeBadRequest

+ const ErrorTypeInternal

+ const ErrorTypeNotFound

+ const ErrorTypeUnauthorized

+ func (et ElasticErrorType) Reason() string

+ func (et ElasticErrorType) StatusCode() int

+ type ElasticProxy struct

+ func NewElasticProxy(logger *slog.Logger, client *opensearch.Client, publicJWTKey *ecdsa.PublicKey) *ElasticProxy

+ func (ep *ElasticProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ElasticQuery struct

+ Bool *BooleanQuery

+ Term map[string]string

+ type ElasticSearchRequest struct

+ Fields json.RawMessage

+ From *int

+ Query ElasticQuery

+ Size *int

+ Sort json.RawMessage

+ Source *bool

+ type Field struct

+ Type FieldType

+ Values []string

+ type FieldType string

+ const TypeBoolean

+ const TypeDate

+ const TypeDouble

+ const TypeKeyword

+ const TypeLong

+ const TypePercolator

+ const TypeText

+ const TypeUnknown

+ func (ft FieldType) Priority() int

+ type Indexer struct

+ func NewIndexer(ctx context.Context, opts IndexerOptions) (*Indexer, error)

+ func (idx *Indexer) Run(ctx context.Context) error

+ type IndexerOptions struct

+ Client *opensearch.Client

+ Database *pgxpool.Pool

+ DefaultLanguage string

+ Documents repository.Documents

+ Logger *slog.Logger

+ Metrics *Metrics

+ SetName string

+ Validator ValidatorSource

+ type Language struct

+ Analyzer string

+ Code string

+ Language string

+ type LanguageConfig struct

+ Language string

+ NameSuffix string

+ Settings OpensearchSettings

+ func GetLanguageConfig(code string, defaultLanguage string) (LanguageConfig, error)

+ type Mapping struct

+ Type FieldType

+ type MappingChange struct

+ New bool

+ type MappingChanges map[string]MappingChange

+ func (mc MappingChanges) HasNew() bool

+ func (mc MappingChanges) Superset(mappings Mappings) Mappings

+ type Mappings struct

+ Properties map[string]Mapping

+ func NewMappings() Mappings

+ func (m *Mappings) ChangesFrom(mappings Mappings) MappingChanges

+ type Metrics struct

+ func NewMetrics(reg prometheus.Registerer) (*Metrics, error)

+ type OpensearchSettings struct

+ Settings struct{ ... }

+ type RawSearchRequest struct

+ Fields json.RawMessage

+ From *int

+ Query json.RawMessage

+ Size *int

+ Sort json.RawMessage

+ Source *bool

+ type SchemaLoader struct

+ func NewSchemaLoader(ctx context.Context, logger *slog.Logger, client repository.Schemas) (*SchemaLoader, error)

+ func (sl *SchemaLoader) GetValidator() *revisor.Validator

+ type Status struct

+ Created time.Time

+ Creator string

+ ID int64

+ Meta newsdoc.DataMap

+ Version int64

+ type ValidatorSource interface

+ GetValidator func() *revisor.Validator

+ type ValueCollector struct

+ func NewValueCollector() *ValueCollector

+ func (c *ValueCollector) CollectValue(a revisor.ValueAnnotation)

+ func (c *ValueCollector) Values() []revisor.ValueAnnotation

+ func (c *ValueCollector) With(ref revisor.EntityRef) revisor.ValueCollector

v0.1.4-pre1

Nov 9, 2023

v0.1.3

Sep 22, 2023

v0.1.2

Jul 18, 2023

v0.1.1

Jul 18, 2023

v0.1.0

Jul 18, 2023

v0.1.0-alpha4

May 29, 2023

v0.1.0-alpha3

May 5, 2023

v0.1.0-alpha2

May 5, 2023

v0.1.0-alpha1

May 5, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL