mapping

Documentation

Index

• func MapErrorFromHeader(m tlstatshouse.MetricBytes, h data_model.MappedMetricHeader) error
• func NewTagsCache(loader pcache.LoaderFunc, suffix string, dc *pcache.DiskCache) *pcache.Cache
• type AutoCreate
  • func NewAutoCreate(journal format.MetaStorageInterface, fn AutoCreateFunc) *AutoCreate
  • func (ac *AutoCreate) Shutdown()
• type AutoCreateFunc
• type MapCallbackFunc
• type Mapper
  • func NewMapper(suffix string, pmcLoader pcache.LoaderFunc, dc *pcache.DiskCache, ...) *Mapper
  • func (m *Mapper) Map(metric *tlstatshouse.MetricBytes, metricInfo *format.MetricMetaValue, ...) (data_model.MappedMetricHeader, bool)
  • func (m *Mapper) SetBootstrapValue(now time.Time, key string, v pcache.Value, ttl time.Duration) error
  • func (m *Mapper) Stop()
  • func (m *Mapper) TagValueDiskCacheSize() int

Functions

func MapErrorFromHeader

func MapErrorFromHeader(m tlstatshouse.MetricBytes, h data_model.MappedMetricHeader) error

func NewTagsCache

func NewTagsCache(loader pcache.LoaderFunc, suffix string, dc *pcache.DiskCache) *pcache.Cache

Types

type AutoCreate

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

func NewAutoCreate

func NewAutoCreate(journal format.MetaStorageInterface, fn AutoCreateFunc) *AutoCreate

func (*AutoCreate) Shutdown

func (ac *AutoCreate) Shutdown()

type AutoCreateFunc

type AutoCreateFunc func(context.Context, tlstatshouse.AutoCreate) error

type MapCallbackFunc

type MapCallbackFunc func(tlstatshouse.MetricBytes, data_model.MappedMetricHeader)

type Mapper

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

func NewMapper

func NewMapper(suffix string, pmcLoader pcache.LoaderFunc, dc *pcache.DiskCache, ac *AutoCreate, metricMapQueueSize int, mapCallback MapCallbackFunc) *Mapper

func (*Mapper) Map

func (m *Mapper) Map(metric *tlstatshouse.MetricBytes, metricInfo *format.MetricMetaValue, cb MapCallbackFunc) (data_model.MappedMetricHeader, bool)

cb.MetricInfo must be set from journal. If nil, will lookup allowed built-in metric, otherwise set ingestion status not found

func (*Mapper) SetBootstrapValue

func (m *Mapper) SetBootstrapValue(now time.Time, key string, v pcache.Value, ttl time.Duration) error

func (*Mapper) Stop

func (m *Mapper) Stop()

func (*Mapper) TagValueDiskCacheSize

func (m *Mapper) TagValueDiskCacheSize() int