es

Documentation

Index

• func ES(log *zap.Logger, opt options.EsOpt) (out *es, err error)
• func ValidElasticResponse(res *esapi.Response, err error) error
• type Service

Functions

func ES

func ES(log *zap.Logger, opt options.EsOpt) (out *es, err error)

func ValidElasticResponse

func ValidElasticResponse(res *esapi.Response, err error) error

Types

type Service

type Service interface {
	EsClient() *elasticsearch.Client
	EsBulk() esutil.BulkIndexer
	Watch(ctx context.Context)
}