output

Documentation

Index

• type ES
  • func NewES(url string, index_name string, doc_type string, bulk_docs int, worker_num int) (*ES, error)
  • func (e *ES) FromParser() *chan model.OutObject
  • func (e *ES) Index(ctx context.Context, wg *sync.WaitGroup)
  • func (e *ES) LogReport()

Types

type ES

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

func NewES

func NewES(url string, index_name string, doc_type string, bulk_docs int, worker_num int) (*ES, error)

NewES

...

func (*ES) FromParser

func (e *ES) FromParser() *chan model.OutObject

func (*ES) Index

func (e *ES) Index(ctx context.Context, wg *sync.WaitGroup)

Index

Runs indexer

func (*ES) LogReport

func (e *ES) LogReport()

LogReport

Logs ES processing progress