sielastic

Documentation

Index

• Variables
• func DefaultElasticsearchClient(elasticAddresses, userName, password string) (*elasticsearch.Client, error)
• type Client
  • func NewClient(client *elasticsearch.Client) *Client
  • func (c *Client) IndexDocument(ctx context.Context, indexName string, body []byte) (map[string]interface{}, error)
  • func (c *Client) SearchDocuments(ctx context.Context, indexName string, body map[string]interface{}, dest any) error
• type Resp
• type RespError
• type RespRootCause

Variables

var ErrElasticResponseHasError = errors.New("response has error")

Functions

func DefaultElasticsearchClient

func DefaultElasticsearchClient(elasticAddresses, userName, password string) (*elasticsearch.Client, error)

Types

type Client

type Client struct {
	*elasticsearch.Client
}

func NewClient

func NewClient(client *elasticsearch.Client) *Client

func (*Client) IndexDocument

func (c *Client) IndexDocument(ctx context.Context, indexName string, body []byte) (map[string]interface{}, error)

func (*Client) SearchDocuments

func (c *Client) SearchDocuments(ctx context.Context, indexName string, body map[string]interface{}, dest any) error

type Resp

type Resp struct {
	Error  RespError `json:"error"`
	Status int       `json:"status"`
}

type RespError

type RespError struct {
	RootCause []RespRootCause `json:"root_cause"`
	Reason    string          `json:"reason"`
}

type RespRootCause

type RespRootCause struct {
	Type   string `json:"type"`
	Reason string `json:"reason"`
	Line   int    `json:"line"`
	Col    int    `json:"col"`
}