ingest

Documentation

Index

• type Ingester
  • func NewSample(host string) (ing Ingester, err error)

Types

type Ingester

type Ingester interface {
	io.Closer
	Ingest(key string, val string, sample_prefix bool) error
	IngestSet(key string, val []string, sample_prefix bool) error
	IngestTS(key string, timestamp int64, val float64, sample_prefix bool) error
}

Ingester handles storing key/value pairs in a data store

func NewSample

func NewSample(host string) (ing Ingester, err error)

Create new Ingester for starting a sample writing down start time