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 *es.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) (*es.Mappings, error)
- func (m *Client) GetIndicesStats(ctx context.Context, pattern string) ([]es.IndexStats, error)
- func (m *Client) Index(ctx context.Context, req *es.IndexRequest) error
- func (m *Client) IndexExists(ctx context.Context, index string) (bool, error)
- func (m *Client) IndexWithID(ctx context.Context, req *es.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 *es.SearchRequest) (*es.SearchResponse, error)
- func (m *Client) SendBulkRequest(ctx context.Context, items []es.BulkItem) ([]es.BulkItem, error)
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 *es.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) (*es.Mappings, error)
GetIndicesStatsFn func(ctx context.Context, pattern string) ([]es.IndexStats, error)
IndexFn func(ctx context.Context, req *es.IndexRequest) error
IndexWithIDFn func(ctx context.Context, req *es.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 *es.SearchRequest) (*es.SearchResponse, error)
SendBulkRequestFn func(ctx context.Context, items []es.BulkItem) ([]es.BulkItem, error)
}
func (*Client) CreateIndex ¶
func (*Client) DeleteByQuery ¶
func (*Client) DeleteIndex ¶
func (*Client) GetIndexAlias ¶
func (*Client) GetIndexMappings ¶
func (*Client) GetIndicesStats ¶
func (*Client) IndexExists ¶
func (*Client) IndexWithID ¶
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 *es.SearchRequest) (*es.SearchResponse, error)
Click to show internal directories.
Click to hide internal directories.