elasticsearch

Documentation

Index

• type Elasticsearch
  • func (es *Elasticsearch) Connect(url string, timeout time.Duration) error
  • func (es *Elasticsearch) CreateIndexIfNotExists(ctx context.Context, esIndex string, esType string, mapping string) error
  • func (es *Elasticsearch) GetClient() *elastic.Client
  • func (es *Elasticsearch) Index(ctx context.Context, esIndex string, esType string, body interface{}) error

Types

type Elasticsearch

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

Elasticsearch wrapper

func (*Elasticsearch) Connect

func (es *Elasticsearch) Connect(url string, timeout time.Duration) error

Connect to the elastic search server

func (*Elasticsearch) CreateIndexIfNotExists

func (es *Elasticsearch) CreateIndexIfNotExists(ctx context.Context, esIndex string, esType string, mapping string) error

CreateIndexIfNotExists Creates an index if it doesn't already exists

func (*Elasticsearch) GetClient

func (es *Elasticsearch) GetClient() *elastic.Client

GetClient returns the native elastic search client

func (*Elasticsearch) Index

func (es *Elasticsearch) Index(ctx context.Context, esIndex string, esType string, body interface{}) error

Index store a document inside elastic search