elastic

Documentation

Index

• type Proxy
  • func NewProxy(config ProxyConfig) *Proxy
  • func (p *Proxy) CreateIndex(indexName string, mapping string) error
  • func (p *Proxy) DeleteIndex(indexName string) error
  • func (p *Proxy) Index(indexName string, storesToIndex []models.StoreRecord) *models.IndexerResponse
  • func (p *Proxy) Search(request models.StoreQueryRequest, indexName string) (*models.StoreQueryResponse, error)
  • func (p *Proxy) Stats() (*elastic.ClusterStatsResponse, error)
• type ProxyConfig

Types

type Proxy

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

Proxy elastic search proxy

func NewProxy

func NewProxy(config ProxyConfig) *Proxy

NewProxy initializes a new proxy

func (*Proxy) CreateIndex

func (p *Proxy) CreateIndex(indexName string, mapping string) error

CreateIndex creates an elastic search index

func (*Proxy) DeleteIndex

func (p *Proxy) DeleteIndex(indexName string) error

DeleteIndex deletes elastic search index

func (*Proxy) Index

func (p *Proxy) Index(indexName string, storesToIndex []models.StoreRecord) *models.IndexerResponse

Index indexes csv data

func (*Proxy) Search

func (p *Proxy) Search(request models.StoreQueryRequest, indexName string) (*models.StoreQueryResponse, error)

Search executes a store location elastic query and returns response

func (*Proxy) Stats

func (p *Proxy) Stats() (*elastic.ClusterStatsResponse, error)

Stats returns cluster stats

type ProxyConfig

type ProxyConfig struct {
	ElasticURL *url.URL
	Username   string
	Password   string
}

ProxyConfig represents EsProxy configuration