Versions in this module Expand all Collapse all v0 v0.7.1 Mar 28, 2026 v0.7.0 Mar 28, 2026 Changes in this version + const DedicatedTenantIndexPrefix + const DefaultShardCountPerIndex + const DefaultSharedIndexName + const TenantIndexAliasPrefix + var DefaultRoute = &Route + func BuildAliasNameFromNamespace(ns *namespace.Namespace) string + func BuildIndexNameFromNamespace(ns *namespace.Namespace) string + func WithInstantRefresh() func(*DiscoveryRepository) + type AssetModel struct + NamespaceID string + type Client struct + func NewClient(config Config, opts ...ClientOption) (*Client, error) + func (c *Client) CreateIdxAlias(ctx context.Context, ns *namespace.Namespace) error + func (c *Client) CreateIndex(ctx context.Context, name string, shardCount int) error + func (c *Client) IndexExists(ctx context.Context, ns *namespace.Namespace) (bool, error) + func (c *Client) Init() (string, error) + type ClientOption func(*Client) + func WithClient(cli *elasticsearch.Client) ClientOption + type Config struct + Brokers string + Password string + RequestTimeout int + Username string + type DiscoveryRepository struct + func NewDiscoveryRepository(cli *Client, opts ...func(*DiscoveryRepository)) *DiscoveryRepository + func (repo *DiscoveryRepository) CreateNamespace(ctx context.Context, ns *namespace.Namespace) error + func (repo *DiscoveryRepository) DeleteByID(ctx context.Context, ns *namespace.Namespace, assetID string) error + func (repo *DiscoveryRepository) DeleteByURN(ctx context.Context, ns *namespace.Namespace, assetURN string) error + func (repo *DiscoveryRepository) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error) + func (repo *DiscoveryRepository) Search(ctx context.Context, cfg asset.SearchConfig) ([]asset.SearchResult, error) + func (repo *DiscoveryRepository) SoftDeleteByURN(ctx context.Context, ns *namespace.Namespace, assetURN string) error + func (repo *DiscoveryRepository) Suggest(ctx context.Context, cfg asset.SearchConfig) (results []string, err error) + func (repo *DiscoveryRepository) Upsert(ctx context.Context, ns *namespace.Namespace, ast *asset.Asset) error + type Route struct + FilterKey string + Index string + ReadKey string + WriteKey string
Go to main page