elastic

Documentation

Index

• type Export
  • func NewExport(cfg config.ElasticSearchCfg) *Export
  • func (export *Export) CLOSE() error
  • func (export *Export) CONSOLE(ev *core.RowsEvent)
  • func (export *Export) DELETE(ev *core.RowsEvent) error
  • func (export *Export) Do(ev *core.RowsEvent) error
  • func (export *Export) INSERT(ev *core.RowsEvent) error
  • func (export *Export) UPDATE(ev *core.RowsEvent) error

Types

type Export

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

Export export data

func NewExport

func NewExport(cfg config.ElasticSearchCfg) *Export

NewExport new export

func (*Export) CLOSE

func (export *Export) CLOSE() error

CLOSE close

func (*Export) CONSOLE

func (export *Export) CONSOLE(ev *core.RowsEvent)

CONSOLE print data to console

func (*Export) DELETE

func (export *Export) DELETE(ev *core.RowsEvent) error

DELETE delete data to elastic

func (*Export) Do

func (export *Export) Do(ev *core.RowsEvent) error

Do do bulk

func (*Export) INSERT

func (export *Export) INSERT(ev *core.RowsEvent) error

INSERT insert data to elastic

func (*Export) UPDATE

func (export *Export) UPDATE(ev *core.RowsEvent) error

UPDATE update data to elastic