elasticsearch

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

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
}

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

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

type TimeIndexSuffix int