es7

Documentation

Index

• func InitClients()
• type Client
  • func GetEsClient(key string) *Client
  • func (t *Client) AggregateBySource(ctx context.Context, model elasticsearch.AggregateModel, result ...interface{}) (err error)
  • func (t *Client) BatchInsert(ctx context.Context, esIndexName string, ids []string, items []interface{}) (err error)
  • func (t *Client) CreateIndexByMapping(ctx context.Context, esIndexName, esMapping string) (err error)
  • func (t *Client) CreateIndexByModel(ctx context.Context, esIndexName string, model *MappingModel) (err error)
  • func (t *Client) DeleteById(ctx context.Context, esIndexName, id string) (err error)
  • func (t *Client) FindByModel(ctx context.Context, model elasticsearch.QueryModel) error
  • func (t *Client) FindBySource(ctx context.Context, model elasticsearch.SourceModel) error
  • func (t *Client) Insert(ctx context.Context, esIndexName, id string, data interface{}) (err error)
  • func (t *Client) UpdateById(ctx context.Context, esIndexName, id string, updateM map[string]interface{}) (err error)
• type Mapping
• type MappingModel

Functions

func InitClients

func InitClients()

Types

type Client

type Client struct {
	*elastic.Client
}

func GetEsClient

func GetEsClient(key string) *Client

func (*Client) AggregateBySource

func (t *Client) AggregateBySource(ctx context.Context, model elasticsearch.AggregateModel, result ...interface{}) (err error)

func (*Client) BatchInsert

func (t *Client) BatchInsert(ctx context.Context, esIndexName string, ids []string, items []interface{}) (err error)

func (*Client) CreateIndexByMapping

func (t *Client) CreateIndexByMapping(ctx context.Context, esIndexName, esMapping string) (err error)

func (*Client) CreateIndexByModel

func (t *Client) CreateIndexByModel(ctx context.Context, esIndexName string, model *MappingModel) (err error)

func (*Client) DeleteById

func (t *Client) DeleteById(ctx context.Context, esIndexName, id string) (err error)

func (*Client) FindByModel

func (t *Client) FindByModel(ctx context.Context, model elasticsearch.QueryModel) error

func (*Client) FindBySource

func (t *Client) FindBySource(ctx context.Context, model elasticsearch.SourceModel) error

func (*Client) Insert

func (t *Client) Insert(ctx context.Context, esIndexName, id string, data interface{}) (err error)

func (*Client) UpdateById

func (t *Client) UpdateById(ctx context.Context, esIndexName, id string, updateM map[string]interface{}) (err error)

type Mapping

type Mapping struct {
	Dynamic    bool                                      `json:"dynamic"` // false
	Properties map[string]*elasticsearch.MappingProperty `json:"properties"`
}

type MappingModel

type MappingModel struct {
	Mapping  `json:"mappings"`
	Settings elasticsearch.MappingSettings `json:"settings"`
}

/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////