elasticsearch

Documentation

Index

• Variables
• type CloseOp
• type Elasticsearch
  • func (d *Elasticsearch) Cleanup() error
  • func (d *Elasticsearch) ClearWork() error
  • func (d *Elasticsearch) GetWork() (io.Reader, error)
  • func (d *Elasticsearch) HandleFailure() error
  • func (d *Elasticsearch) Init() error
  • func (d *Elasticsearch) LoadEnv(prefix string) error
  • func (d *Elasticsearch) LoadFlags() error

Variables

var (
	CloseOpDelete   = CloseOp("delete")
	CloseOpPut      = CloseOp("put")
	CloseOpMergePut = CloseOp("merge-put")
	CloseOpMove     = CloseOp("move")
)

Types

type CloseOp

type CloseOp string

type Elasticsearch

type Elasticsearch struct {
	Client   *elasticsearch8.Client
	Address  string
	Username string
	Password string
	// TLS
	EnableTLS     *bool
	TLSInsecure   *bool
	TLSCert       *string
	TLSKey        *string
	TLSCA         *string
	RetrieveIndex *string
	RetrieveQuery string
	ClearDoc      string
	ClearIndex    *string
	ClearOp       CloseOp
	FailDoc       string
	FailIndex     *string
	FailOp        CloseOp
	Key           *string
	// contains filtered or unexported fields
}

func (*Elasticsearch) Cleanup

func (d *Elasticsearch) Cleanup() error

func (*Elasticsearch) ClearWork

func (d *Elasticsearch) ClearWork() error

func (*Elasticsearch) GetWork

func (d *Elasticsearch) GetWork() (io.Reader, error)

func (*Elasticsearch) HandleFailure

func (d *Elasticsearch) HandleFailure() error

func (*Elasticsearch) Init

func (d *Elasticsearch) Init() error

func (*Elasticsearch) LoadEnv

func (d *Elasticsearch) LoadEnv(prefix string) error

func (*Elasticsearch) LoadFlags

func (d *Elasticsearch) LoadFlags() error