elasticsearch

Documentation

Index

• type Config
  • func NewConfig() Config
• type RecordDatabase
  • func NewDatabase(logger log.Logger, config Config) RecordDatabase

Types

type Config

type Config struct {
	Host               string
	Index              string
	IndexColumn        string
	BlacklistedColumns []string
	BulkTimeout        time.Duration
}

func NewConfig

func NewConfig() Config

type RecordDatabase

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

func NewDatabase

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