es

Documentation

Index

• func GetWriterIndexerFromESConf(esConf config.ElasticSearchConf) (writer *Writer, indexer *Index)
• type Index
  • func NewIndex(client *elastic.Client, indexFormat string, loc *time.Location) *Index
  • func (idx *Index) GetIndex(m map[string]any) string
• type IndexFormat
• type IndexFunc
• type Writer
  • func NewWriter(c config.ElasticSearchConf) (*Writer, error)
  • func (w *Writer) Write(index, val string) error

Functions

func GetWriterIndexerFromESConf

func GetWriterIndexerFromESConf(esConf config.ElasticSearchConf) (writer *Writer, indexer *Index)

Types

type Index

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

func NewIndex

func NewIndex(client *elastic.Client, indexFormat string, loc *time.Location) *Index

func (*Index) GetIndex

func (idx *Index) GetIndex(m map[string]any) string

type IndexFormat

type IndexFormat func(m map[string]any) string

type IndexFunc

type IndexFunc func() string

type Writer

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

func NewWriter

func NewWriter(c config.ElasticSearchConf) (*Writer, error)

func (*Writer) Write

func (w *Writer) Write(index, val string) error