output

Documentation

Index

• type Conf
• type EsOutput
  • func NewEs(confs []Conf, in chan processor.DataUnit, sizeRes int) EsOutput
  • func (out EsOutput) Handle(un Unit) error
  • func (out EsOutput) Results() ([]byte, error)
  • func (out EsOutput) Start()
• type Output
• type PostResponse
• type Unit

Types

type Conf

type Conf struct {
	Type     string `json:"type"`
	User     string `json:"user"`
	Password string `json:"password"`
	Host     string `json:"host"`
	Index    string `json:"index"`
}

type EsOutput

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

func NewEs

func NewEs(confs []Conf, in chan processor.DataUnit, sizeRes int) EsOutput

func (EsOutput) Handle

func (out EsOutput) Handle(un Unit) error

func (EsOutput) Results

func (out EsOutput) Results() ([]byte, error)

func (EsOutput) Start

func (out EsOutput) Start()

type Output

type Output interface {
	Start()
	Handle(Unit) error
	Results() ([]byte, error)
}

type PostResponse

type PostResponse struct {
	Index  string `json:"_index"`
	Type   string `json:"_type"`
	Id     string `json:"_id"`
	Result string `json:"result"`
}

type Unit

type Unit struct {
	Url     string
	Outputs []interface{}
}