elasticsearch

Documentation

Index

• type Codec
  • func NewCodec(logger log.Logger, config Config) Codec
• type Config
  • func NewConfig() Config
• type InsertResponse
• type RecordDatabase
  • func NewDatabase(logger log.Logger, config Config, metrics metrics.MetricsPublisher) RecordDatabase
• type TimeIndexSuffix

Types

type Codec

type Codec interface {
	EncodeElasticRecords(records []*models.Record) ([]*models.ElasticRecord, error)
}

func NewCodec

func NewCodec(logger log.Logger, config Config) Codec

type Config

type Config struct {
	Host               string
	User               string
	Pwd                string
	IgnoreCertificate  bool
	Scheme             string
	Index              string
	IndexPrefix        string
	IndexColumn        string
	DocIDColumn        string
	BlacklistedColumns []string
	BulkTimeout        time.Duration
	Backoff            time.Duration
	TimeSuffix         TimeIndexSuffix
	DisableSniffing    bool
}

func NewConfig

func NewConfig() Config

type InsertResponse

type InsertResponse struct {
	AlreadyExists []string
	Retry         []*models.ElasticRecord
	Backoff       bool
}

type RecordDatabase

type RecordDatabase interface {
	Insert(records []*models.ElasticRecord) (*InsertResponse, error)
	ReadinessCheck() bool
	// contains filtered or unexported methods
}

func NewDatabase

func NewDatabase(logger log.Logger, config Config, metrics metrics.MetricsPublisher) RecordDatabase

type TimeIndexSuffix

type TimeIndexSuffix int

const (
	TimeSuffixDay  TimeIndexSuffix = 0
	TimeSuffixHour TimeIndexSuffix = 1
)