elasticsearch

Documentation

Index

• type ESConfig
• type Exporter
  • func New(cfg ESConfig) (*Exporter, error)
  • func (e *Exporter) Export(ctx context.Context, msgc chan *pb.ProtoMessage)
  • func (e *Exporter) ExportK8S(ctx context.Context, msgc chan *pb.K8SProtoMessage)
  • func (e *Exporter) Stop() error

Types

type ESConfig

type ESConfig struct {
	Addresses    string `mapstructure:"EXPORTER_ELASTICSEARCH_ADDRESSES"`
	Username     string `mapstructure:"EXPORTER_ELASTICSEARCH_USERNAME"`
	Password     string `mapstructure:"EXPORTER_ELASTICSEARCH_PASSWORD"`
	CloudID      string `mapstructure:"EXPORTER_ELASTICSEARCH_CLOUDID"`
	APIKey       string `mapstructure:"EXPORTER_ELASTICSEARCH_APIKEY"`
	ServiceToken string `mapstructure:"EXPORTER_ELASTICSEARCH_SERVICETOKEN"`
	Fingerprint  string `mapstructure:"EXPORTER_ELASTICSEARCH_FINGERPRINT"`
}

type Exporter

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

func New

func New(cfg ESConfig) (*Exporter, error)

func (*Exporter) Export

func (e *Exporter) Export(ctx context.Context, msgc chan *pb.ProtoMessage)

func (*Exporter) ExportK8S

func (e *Exporter) ExportK8S(ctx context.Context, msgc chan *pb.K8SProtoMessage)

func (*Exporter) Stop

func (e *Exporter) Stop() error