emit

Documentation

Index

• type Elasticsearch
  • func (e *Elasticsearch) Close()
  • func (e *Elasticsearch) Connect() error
  • func (e *Elasticsearch) Write(dc <-chan gachifinder.GachiData) error

Types

type Elasticsearch

type Elasticsearch struct {
	Config *gachifinder.Config
	// contains filtered or unexported fields
}

Elasticsearch struct

func (*Elasticsearch) Close

func (e *Elasticsearch) Close()

Close to release Elasticsearch Client.

func (*Elasticsearch) Connect

func (e *Elasticsearch) Connect() error

Connect to Elasticsearch & Create index.

func (*Elasticsearch) Write

func (e *Elasticsearch) Write(dc <-chan gachifinder.GachiData) error

Write the data into the Elasticsearch.