elastic

Documentation

Index

• type Config
• type ElasticProducer
  • func (p *ElasticProducer) Close() error
  • func (p *ElasticProducer) Initialize(configFile string)
  • func (p *ElasticProducer) Produce(k []byte, v []byte, o any)

Types

type Config

type Config struct {
	ElasticURI      string `json:"es_uri"`
	ElasticIndex    string `json:"index"`
	ElasticUsername string `json:"username"`
	ElasticPassword string `json:"password"`
}

type ElasticProducer

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

func (*ElasticProducer) Close

func (p *ElasticProducer) Close() error

func (*ElasticProducer) Initialize

func (p *ElasticProducer) Initialize(configFile string)

func (*ElasticProducer) Produce

func (p *ElasticProducer) Produce(k []byte, v []byte, o any)