Documentation
¶
Index ¶
- type Client
- func (m *Client) CloseIndex(ctx context.Context, index string) error
- func (m *Client) Count(ctx context.Context, index string) (int, error)
- func (m *Client) CreateIndex(ctx context.Context, index string, body map[string]any) error
- func (m *Client) DeleteByQuery(ctx context.Context, req *searchstore.DeleteByQueryRequest) error
- func (m *Client) DeleteIndex(ctx context.Context, index []string) error
- func (m *Client) GetIndexAlias(ctx context.Context, name string) (map[string]any, error)
- func (m *Client) GetIndexMappings(ctx context.Context, index string) (*searchstore.Mappings, error)
- func (m *Client) GetIndicesStats(ctx context.Context, pattern string) ([]searchstore.IndexStats, error)
- func (m *Client) GetMapper() searchstore.Mapper
- func (m *Client) Index(ctx context.Context, req *searchstore.IndexRequest) error
- func (m *Client) IndexExists(ctx context.Context, index string) (bool, error)
- func (m *Client) IndexWithID(ctx context.Context, req *searchstore.IndexWithIDRequest) error
- func (m *Client) ListIndices(ctx context.Context, indices []string) ([]string, error)
- func (m *Client) Perform(req *http.Request) (*http.Response, error)
- func (m *Client) PutIndexAlias(ctx context.Context, index []string, name string) error
- func (m *Client) PutIndexMappings(ctx context.Context, index string, body map[string]any) error
- func (m *Client) PutIndexSettings(ctx context.Context, index string, body map[string]any) error
- func (m *Client) RefreshIndex(ctx context.Context, index string) error
- func (m *Client) Search(ctx context.Context, req *searchstore.SearchRequest) (*searchstore.SearchResponse, error)
- func (m *Client) SendBulkRequest(ctx context.Context, items []searchstore.BulkItem) ([]searchstore.BulkItem, error)
- type Mapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
CloseIndexFn func(ctx context.Context, index string) error
CountFn func(ctx context.Context, index string) (int, error)
CreateIndexFn func(ctx context.Context, index string, body map[string]any) error
DeleteByQueryFn func(ctx context.Context, req *searchstore.DeleteByQueryRequest) error
DeleteIndexFn func(ctx context.Context, index []string) error
GetIndexAliasFn func(ctx context.Context, name string) (map[string]any, error)
GetIndexMappingsFn func(ctx context.Context, index string) (*searchstore.Mappings, error)
GetIndicesStatsFn func(ctx context.Context, pattern string) ([]searchstore.IndexStats, error)
IndexFn func(ctx context.Context, req *searchstore.IndexRequest) error
IndexWithIDFn func(ctx context.Context, req *searchstore.IndexWithIDRequest) error
IndexExistsFn func(ctx context.Context, index string) (bool, error)
ListIndicesFn func(ctx context.Context, indices []string) ([]string, error)
PerformFn func(req *http.Request) (*http.Response, error)
PutIndexAliasFn func(ctx context.Context, index []string, name string) error
PutIndexMappingsFn func(ctx context.Context, index string, body map[string]any) error
PutIndexSettingsFn func(ctx context.Context, index string, body map[string]any) error
RefreshIndexFn func(ctx context.Context, index string) error
SearchFn func(ctx context.Context, req *searchstore.SearchRequest) (*searchstore.SearchResponse, error)
SendBulkRequestFn func(ctx context.Context, items []searchstore.BulkItem) ([]searchstore.BulkItem, error)
GetMapperFn func() searchstore.Mapper
}
func (*Client) CreateIndex ¶
func (*Client) DeleteByQuery ¶
func (m *Client) DeleteByQuery(ctx context.Context, req *searchstore.DeleteByQueryRequest) error
func (*Client) DeleteIndex ¶
func (*Client) GetIndexAlias ¶
func (*Client) GetIndexMappings ¶
func (*Client) GetIndicesStats ¶
func (m *Client) GetIndicesStats(ctx context.Context, pattern string) ([]searchstore.IndexStats, error)
func (*Client) GetMapper ¶
func (m *Client) GetMapper() searchstore.Mapper
func (*Client) Index ¶
func (m *Client) Index(ctx context.Context, req *searchstore.IndexRequest) error
func (*Client) IndexExists ¶
func (*Client) IndexWithID ¶
func (m *Client) IndexWithID(ctx context.Context, req *searchstore.IndexWithIDRequest) error
func (*Client) ListIndices ¶
func (*Client) PutIndexAlias ¶
func (*Client) PutIndexMappings ¶
func (*Client) PutIndexSettings ¶
func (*Client) RefreshIndex ¶
func (*Client) Search ¶
func (m *Client) Search(ctx context.Context, req *searchstore.SearchRequest) (*searchstore.SearchResponse, error)
func (*Client) SendBulkRequest ¶
func (m *Client) SendBulkRequest(ctx context.Context, items []searchstore.BulkItem) ([]searchstore.BulkItem, error)
type Mapper ¶
type Mapper struct {
GetDefaultIndexSettingsFn func() map[string]any
FieldMappingFn func(*searchstore.Field) (map[string]any, error)
}
func (*Mapper) FieldMapping ¶
func (*Mapper) GetDefaultIndexSettings ¶
Click to show internal directories.
Click to hide internal directories.