elasticsearch

Documentation

Index

• Constants
• type Client
• type ClientSet
  • func NewClient(config *Config, cod codec.Codec, indexPattern *pattern.Pattern, ...) (*ClientSet, error)
  • func (c *ClientSet) BulkIndex(ctx context.Context, batch api.Batch) error
  • func (c *ClientSet) Stop()
• type Config
  • func (c *Config) Validate() error
• type Sink
  • func NewSink() *Sink
  • func (s *Sink) Category() api.Category
  • func (s *Sink) Config() interface{}
  • func (s *Sink) Consume(batch api.Batch) api.Result
  • func (s *Sink) Init(context api.Context) error
  • func (s *Sink) SetCodec(c codec.Codec)
  • func (s *Sink) Start() error
  • func (s *Sink) Stop()
  • func (s *Sink) String() string
  • func (s *Sink) Type() api.Type

Constants

const Type = "elasticsearch"

Types

type Client

type Client interface {
	BulkCreate(content []byte, index string) error
	Stop()
}

type ClientSet

type ClientSet struct {
	Version string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config *Config, cod codec.Codec, indexPattern *pattern.Pattern, documentIdPattern *pattern.Pattern) (*ClientSet, error)

func (*ClientSet) BulkIndex

func (c *ClientSet) BulkIndex(ctx context.Context, batch api.Batch) error

func (*ClientSet) Stop

func (c *ClientSet) Stop()

type Config

type Config struct {
	Hosts      []string `yaml:"hosts,omitempty" validate:"required"`
	UserName   string   `yaml:"username,omitempty"`
	Password   string   `yaml:"password,omitempty"`
	Index      string   `yaml:"index,omitempty" validate:"required"`
	Etype      string   `yaml:"etype,omitempty"` // elasticsearch type, for v5.* backward compatibility
	DocumentId string   `yaml:"documentId,omitempty"`
	Schema     string   `yaml:"schema,omitempty"`
	Sniff      *bool    `yaml:"sniff,omitempty"`
	Gzip       *bool    `yaml:"gzip,omitempty"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Sink

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

func NewSink

func NewSink() *Sink

func (*Sink) Category

func (s *Sink) Category() api.Category

func (*Sink) Config

func (s *Sink) Config() interface{}

func (*Sink) Consume

func (s *Sink) Consume(batch api.Batch) api.Result

func (*Sink) Init

func (s *Sink) Init(context api.Context) error

func (*Sink) SetCodec

func (s *Sink) SetCodec(c codec.Codec)

func (*Sink) Start

func (s *Sink) Start() error

func (*Sink) Stop

func (s *Sink) Stop()

func (*Sink) String

func (s *Sink) String() string

func (*Sink) Type

func (s *Sink) Type() api.Type