meta

Documentation

Index

• type BulkType
• type EsIndex
• type EsMetric
• type EsTagKey
• type EsTagValue
• type LogMeta
• type Meta
  • func New(log *zap.Logger, sts *tsstats.StatsTS, es *rubber.Elastic, bc *bcache.Bcache, ...) (*Meta, error)
  • func (meta *Meta) CheckTSID(esType, id string) (bool, gobol.Error)
  • func (meta *Meta) Handle(pkt *pb.Meta)
  • func (meta *Meta) SaveTxtMeta(packet *pb.Meta)
• type MetaData
• type MetaInfo
• type RestError
• type RestErrorUser
• type RestErrors
• type Settings
• type StructV2Error
• type Tag

Types

type BulkType

type BulkType struct {
	ID EsIndex `json:"index"`
}

type EsIndex

type EsIndex struct {
	EsID    string `json:"_id"`
	EsType  string `json:"_type"`
	EsIndex string `json:"_index"`
}

type EsMetric

type EsMetric struct {
	Metric string `json:"metric"`
}

type EsTagKey

type EsTagKey struct {
	Key string `json:"key"`
}

type EsTagValue

type EsTagValue struct {
	Value string `json:"value"`
}

type LogMeta

type LogMeta struct {
	Action string   `json:"action"`
	Meta   MetaInfo `json:"meta"`
}

type Meta

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

func New

func New(
	log *zap.Logger,
	sts *tsstats.StatsTS,
	es *rubber.Elastic,
	bc *bcache.Bcache,
	set *Settings,
) (*Meta, error)

func (*Meta) CheckTSID

func (meta *Meta) CheckTSID(esType, id string) (bool, gobol.Error)

func (*Meta) Handle

func (meta *Meta) Handle(pkt *pb.Meta)

func (*Meta) SaveTxtMeta

func (meta *Meta) SaveTxtMeta(packet *pb.Meta)

type MetaData

type MetaData interface {
	Handle(pkt *pb.Meta)
	SaveTxtMeta(packet *pb.Meta)
	CheckTSID(esType, id string) (bool, gobol.Error)
}

type MetaInfo

type MetaInfo struct {
	Metric string `json:"metric"`
	ID     string `json:"id"`
	Tags   []Tag  `json:"tagsNested"`
}

type RestError

type RestError struct {
	Datapoint gorilla.TSDBpoint `json:"datapoint"`
	Gerr      gobol.Error       `json:"error"`
}

type RestErrorUser

type RestErrorUser struct {
	Datapoint gorilla.TSDBpoint `json:"datapoint"`
	Error     interface{}       `json:"error"`
}

type RestErrors

type RestErrors struct {
	Errors  []RestErrorUser `json:"errors"`
	Failed  int             `json:"failed"`
	Success int             `json:"success"`
}

type Settings

type Settings struct {
	MetaSaveInterval    string
	MaxConcurrentBulks  int
	MaxConcurrentPoints int
	MaxMetaBulkSize     int
	MetaBufferSize      int
	MetaHeadInterval    string
}

type StructV2Error

type StructV2Error struct {
	Key    string `json:"key"`
	Metric string `json:"metric"`
	Tags   []Tag  `json:"tagsError"`
}

type Tag

type Tag struct {
	Key   string `json:"tagKey"`
	Value string `json:"tagValue"`
}