elastic

Documentation

Index

• Constants
• func String(v interface{}, err error) (string, error)
• type BulkRequest
• type BulkResult
  • func (bres *BulkResult) AppendError(format string, a ...interface{})
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) AddAliasAndDeleteIndex(newIndex string, alias string) (bool, error)
  • func (c *Client) BulkIndex(batchSize int, bulkRequests []*BulkRequest) (result *BulkResult)
  • func (c *Client) Delete(index string, id string) error
  • func (c *Client) DeleteIndex(index string) (bool, error)
  • func (c *Client) Exists(index string, id string) bool
  • func (c *Client) GetDocumentById(index string, id string, v interface{}) error
  • func (c *Client) GetDocumentByQuery(ctx context.Context, index string, query map[string]interface{}, v interface{}) (*string, error)
  • func (c *Client) GetDocumentField(index string, id string, key string) (interface{}, error)
  • func (c *Client) Index(index string, id string, v interface{}) error
  • func (c *Client) Search(ctx context.Context, index string, query string) (*ElasticSearchResult, error)
  • func (c *Client) Update(index string, id string, v interface{}) error
• type ElasticAggregateBucket
• type ElasticResultHit
• type ElasticResultHits
• type ElasticResultShards
• type ElasticResultTotal
• type ElasticSearchResult

Constants

const (
	TimeLayout = "20060102150405"
)

Functions

func String

func String(v interface{}, err error) (string, error)

Types

type BulkRequest

type BulkRequest struct {
	Index    string
	ID       string
	Document interface{}
}

type BulkResult

type BulkResult struct {
	Errors  []error
	Indexed int
}

func (*BulkResult) AppendError

func (bres *BulkResult) AppendError(format string, a ...interface{})

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*Client, error)

func (*Client) AddAliasAndDeleteIndex

func (c *Client) AddAliasAndDeleteIndex(newIndex string, alias string) (bool, error)

func (*Client) BulkIndex

func (c *Client) BulkIndex(batchSize int, bulkRequests []*BulkRequest) (result *BulkResult)

https://github.com/elastic/go-elasticsearch/blob/example_bulk/_examples/bulk/bulk.go

func (*Client) Delete

func (c *Client) Delete(index string, id string) error

func (*Client) DeleteIndex

func (c *Client) DeleteIndex(index string) (bool, error)

func (*Client) Exists

func (c *Client) Exists(index string, id string) bool

func (*Client) GetDocumentById

func (c *Client) GetDocumentById(index string, id string, v interface{}) error

func (*Client) GetDocumentByQuery

func (c *Client) GetDocumentByQuery(ctx context.Context, index string, query map[string]interface{}, v interface{}) (*string, error)

func (*Client) GetDocumentField

func (c *Client) GetDocumentField(index string, id string, key string) (interface{}, error)

func (*Client) Index

func (c *Client) Index(index string, id string, v interface{}) error

func (*Client) Search

func (c *Client) Search(ctx context.Context, index string, query string) (*ElasticSearchResult, error)

func (*Client) Update

func (c *Client) Update(index string, id string, v interface{}) error

type ElasticAggregateBucket

type ElasticAggregateBucket struct {
	DocCount int         `json:"doc_count"`
	Key      interface{} `json:"key"`
}

type ElasticResultHit

type ElasticResultHit struct {
	Index  string          `json:"_index"`
	Type   string          `json:"_type"`
	ID     string          `json:"_id"`
	Score  float64         `json:"_score"`
	Source json.RawMessage `json:"_source"`
	Fields json.RawMessage `json:"fields,omitempty"`
	Sort   []int64         `json:"sort,omitempty"`
}

type ElasticResultHits

type ElasticResultHits struct {
	Total    ElasticResultTotal `json:"total"`
	MaxScore float64            `json:"max_score"`
	Hits     []ElasticResultHit `json:"hits"`
}

type ElasticResultShards

type ElasticResultShards struct {
	Total      int `json:"total"`
	Successful int `json:"successful"`
	Skipped    int `json:"skipped"`
	Failed     int `json:"failed"`
}

type ElasticResultTotal

type ElasticResultTotal struct {
	Value    int    `json:"value"`
	Relation string `json:"relation"`
}

type ElasticSearchResult

type ElasticSearchResult struct {
	Took         int                 `json:"took"`
	TimedOut     bool                `json:"timed_out"`
	Shards       ElasticResultShards `json:"_shards"`
	Hits         ElasticResultHits   `json:"hits"`
	Aggregations json.RawMessage     `json:"aggregations"`
}