elastic

Documentation

Index

• Constants
• type BulkRequest
• type BulkResponse
• type BulkResponseItem
• type Client
  • func NewClient(conf *ClientConfig) *Client
  • func (c *Client) Bulk(items []*BulkRequest) (*BulkResponse, error)
  • func (c *Client) CreateMapping(index string, docType string, mapping map[string]interface{}) error
  • func (c *Client) Delete(index string, docType string, id string) error
  • func (c *Client) DeleteIndex(index string) error
  • func (c *Client) Do(method string, url string, body map[string]interface{}) (*Response, error)
  • func (c *Client) DoBulk(url string, items []*BulkRequest) (*BulkResponse, error)
  • func (c *Client) DoRequest(method string, url string, body *bytes.Buffer) (*http.Response, error)
  • func (c *Client) Exists(index string, docType string, id string) (bool, error)
  • func (c *Client) Get(index string, docType string, id string) (*Response, error)
  • func (c *Client) IndexBulk(index string, items []*BulkRequest) (*BulkResponse, error)
  • func (c *Client) IndexTypeBulk(index string, docType string, items []*BulkRequest) (*BulkResponse, error)
  • func (c *Client) Update(index string, docType string, id string, data map[string]interface{}) error
• type ClientConfig
• type Response
• type ResponseItem

Constants

const (
	ActionCreate = "create"
	ActionUpdate = "update"
	ActionDelete = "delete"
	ActionIndex  = "index"
)

See http://www.elasticsearch.org/guide/en/elasticsearch/guide/current/bulk.html

Types

type BulkRequest

type BulkRequest struct {
	Action string
	Index  string
	Type   string
	ID     string
	Parent string

	Data map[string]interface{}
}

type BulkResponse

type BulkResponse struct {
	Code   int
	Took   int  `json:"took"`
	Errors bool `json:"errors"`

	Items []map[string]*BulkResponseItem `json:"items"`
}

type BulkResponseItem

type BulkResponseItem struct {
	Index   string          `json:"_index"`
	Type    string          `json:"_type"`
	ID      string          `json:"_id"`
	Version int             `json:"_version"`
	Status  int             `json:"status"`
	Error   json.RawMessage `json:"error"`
	Found   bool            `json:"found"`
}

type Client

type Client struct {
	Addr     string
	User     string
	Password string
	// contains filtered or unexported fields
}

Although there are many Elasticsearch clients with Go, I still want to implement one by myself. Because we only need some very simple usages.

func NewClient

func NewClient(conf *ClientConfig) *Client

func (*Client) Bulk

func (c *Client) Bulk(items []*BulkRequest) (*BulkResponse, error)

only support parent in 'Bulk' related apis

func (*Client) CreateMapping

func (c *Client) CreateMapping(index string, docType string, mapping map[string]interface{}) error

func (*Client) Delete

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

func (*Client) DeleteIndex

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

func (*Client) Do

func (c *Client) Do(method string, url string, body map[string]interface{}) (*Response, error)

func (*Client) DoBulk

func (c *Client) DoBulk(url string, items []*BulkRequest) (*BulkResponse, error)

func (*Client) DoRequest

func (c *Client) DoRequest(method string, url string, body *bytes.Buffer) (*http.Response, error)

func (*Client) Exists

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

func (*Client) Get

func (c *Client) Get(index string, docType string, id string) (*Response, error)

func (*Client) IndexBulk

func (c *Client) IndexBulk(index string, items []*BulkRequest) (*BulkResponse, error)

func (*Client) IndexTypeBulk

func (c *Client) IndexTypeBulk(index string, docType string, items []*BulkRequest) (*BulkResponse, error)

func (*Client) Update

func (c *Client) Update(index string, docType string, id string, data map[string]interface{}) error

Can use Update to create or update the data

type ClientConfig

type ClientConfig struct {
	Addr     string
	User     string
	Password string
}

type Response

type Response struct {
	Code int
	ResponseItem
}

type ResponseItem

type ResponseItem struct {
	ID      string                 `json:"_id"`
	Index   string                 `json:"_index"`
	Type    string                 `json:"_type"`
	Version int                    `json:"_version"`
	Found   bool                   `json:"found"`
	Source  map[string]interface{} `json:"_source"`
}