elasticdriver

Documentation

Index

• Constants
• Variables
• func BulkIndexerOnFailure(ctx context.Context, item esutil.BulkIndexerItem, ...)
• func GetResponseError(response *esapi.Response, err error) error
• type Adapter
  • func New() *Adapter
  • func (a *Adapter) Attach()
  • func (a *Adapter) Detach()
  • func (a *Adapter) GetClient() *elasticsearch.Client
  • func (a *Adapter) Initialize()
  • func (a *Adapter) NewBulkIndexer(index string) esutil.BulkIndexer
  • func (a *Adapter) Register() (string, interface{})
• type Configuration
  • func (*Configuration) Descriptor() ([]byte, []int)
  • func (x *Configuration) GetAddresses() []string
  • func (x *Configuration) GetBulkFlushBytes() int64
  • func (x *Configuration) GetBulkFlushIntervalSeconds() int64
  • func (x *Configuration) GetBulkWorkers() int64
  • func (x *Configuration) GetEnableDebug() bool
  • func (x *Configuration) GetMaxRetries() int64
  • func (*Configuration) ProtoMessage()
  • func (x *Configuration) ProtoReflect() protoreflect.Message
  • func (x *Configuration) Reset()
  • func (x *Configuration) String() string

Constants

const Key = "elasticDriver"

Variables

var (
	ErrElasticsearchApiResponse = errors.New("elasticsearch api response error")
)

var File_adapters_elastic_driver_elastic_driver_proto protoreflect.FileDescriptor

Functions

func BulkIndexerOnFailure

func BulkIndexerOnFailure(ctx context.Context, item esutil.BulkIndexerItem, res esutil.BulkIndexerResponseItem, err error)

func GetResponseError

func GetResponseError(response *esapi.Response, err error) error

Types

type Adapter

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

func New

func New() *Adapter

func (*Adapter) Attach

func (a *Adapter) Attach()

func (*Adapter) Detach

func (a *Adapter) Detach()

func (*Adapter) GetClient

func (a *Adapter) GetClient() *elasticsearch.Client

func (*Adapter) Initialize

func (a *Adapter) Initialize()

func (*Adapter) NewBulkIndexer

func (a *Adapter) NewBulkIndexer(index string) esutil.BulkIndexer

func (*Adapter) Register

func (a *Adapter) Register() (string, interface{})

type Configuration

type Configuration struct {
	Addresses                []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	MaxRetries               int64    `protobuf:"varint,2,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	EnableDebug              bool     `protobuf:"varint,3,opt,name=enable_debug,json=enableDebug,proto3" json:"enable_debug,omitempty"`
	BulkWorkers              int64    `protobuf:"varint,4,opt,name=bulk_workers,json=bulkWorkers,proto3" json:"bulk_workers,omitempty"`
	BulkFlushBytes           int64    `protobuf:"varint,5,opt,name=bulk_flush_bytes,json=bulkFlushBytes,proto3" json:"bulk_flush_bytes,omitempty"`
	BulkFlushIntervalSeconds int64    `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Configuration) Descriptor

func (*Configuration) Descriptor() ([]byte, []int)

Deprecated: Use Configuration.ProtoReflect.Descriptor instead.

func (*Configuration) GetAddresses

func (x *Configuration) GetAddresses() []string

func (*Configuration) GetBulkFlushBytes

func (x *Configuration) GetBulkFlushBytes() int64

func (*Configuration) GetBulkFlushIntervalSeconds

func (x *Configuration) GetBulkFlushIntervalSeconds() int64

func (*Configuration) GetBulkWorkers

func (x *Configuration) GetBulkWorkers() int64

func (*Configuration) GetEnableDebug

func (x *Configuration) GetEnableDebug() bool

func (*Configuration) GetMaxRetries

func (x *Configuration) GetMaxRetries() int64

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) ProtoReflect

func (x *Configuration) ProtoReflect() protoreflect.Message

func (*Configuration) Reset

func (x *Configuration) Reset()

func (*Configuration) String

func (x *Configuration) String() string