ptinput

Documentation

Overview

Package ptinput impl ppl input interface

Index

• Constants
• Variables
• type DoFeedCache
• type InputWithVarbMapR
• type InputWithVarbMapRW
• type InputWithoutVarbMap
• type KeyKind
• type PlInputPt
  • func NewPlPoint(category point.Category, name string, tags map[string]string, ...) PlInputPt
  • func WrapPoint(cat point.Category, pt *point.Point) PlInputPt
• type PlPoint
  • func (pt *PlPoint) AppendSubPoint(plpt PlInputPt)
  • func (pt *PlPoint) Category() point.Category
  • func (pt *PlPoint) Delete(key string)
  • func (pt *PlPoint) Dropped() bool
  • func (pt *PlPoint) Fields() map[string]any
  • func (pt *PlPoint) Get(key string) (any, ast.DType, error)
  • func (pt *PlPoint) GetAggBuckets() *plmap.AggBuckets
  • func (pt *PlPoint) GetCache() *plcache.Cache
  • func (pt *PlPoint) GetIPDB() ipdb.IPdb
  • func (pt *PlPoint) GetPlReferTables() refertable.PlReferTables
  • func (pt *PlPoint) GetPtName() string
  • func (pt *PlPoint) GetSubPoint() []PlInputPt
  • func (pt *PlPoint) GetWithIsTag(key string) (any, bool, bool)
  • func (pt *PlPoint) KeyTime2Time()
  • func (pt *PlPoint) MarkDrop(drop bool)
  • func (pt *PlPoint) Point() *point.Point
  • func (pt *PlPoint) PtTime() time.Time
  • func (pt *PlPoint) RenameKey(from, to string) error
  • func (pt *PlPoint) Set(key string, value any, dtype ast.DType) error
  • func (pt *PlPoint) SetAggBuckets(buks *plmap.AggBuckets)
  • func (pt *PlPoint) SetCache(c *plcache.Cache)
  • func (pt *PlPoint) SetIPDB(db ipdb.IPdb)
  • func (pt *PlPoint) SetPlReferTables(refTable refertable.PlReferTables)
  • func (pt *PlPoint) SetPtName(m string)
  • func (pt *PlPoint) SetTag(key string, value any, dtype ast.DType) error
  • func (pt *PlPoint) Tags() map[string]string
• type PlmapManager
• type PtFlag

Constants

const Originkey = "message"

Variables

var DoFeedNOP = func(name, category string, pt *point.Point) error { return nil }

Types

type DoFeedCache

type DoFeedCache func(name, category string, pt *point.Point) error

type InputWithVarbMapR

type InputWithVarbMapR interface {
	Get(key string) (any, ast.DType, bool)
}

type InputWithVarbMapRW

type InputWithVarbMapRW interface {
	Get(key string) (any, ast.DType, bool)
	Set(key string, value any, dtype ast.DType) bool
	Delete(key string) bool
}

type InputWithoutVarbMap

type InputWithoutVarbMap interface{}

type KeyKind

type KeyKind uint

const (
	KindPtDefault KeyKind = iota
	KindPtTag
)

type PlInputPt

type PlInputPt interface {
	GetPtName() string
	SetPtName(m string)

	Get(key string) (any, ast.DType, error)
	GetWithIsTag(key string) (any, bool, bool)
	Set(key string, value any, dtype ast.DType) error
	Delete(key string)
	RenameKey(from, to string) error

	SetTag(key string, value any, dtype ast.DType) error

	PtTime() time.Time

	GetAggBuckets() *plmap.AggBuckets
	SetAggBuckets(*plmap.AggBuckets)

	AppendSubPoint(PlInputPt)
	GetSubPoint() []PlInputPt
	Category() point.Category

	KeyTime2Time()

	MarkDrop(bool)
	Dropped() bool
	Point() *point.Point

	GetIPDB() ipdb.IPdb
	SetIPDB(ipdb.IPdb)

	GetPlReferTables() refertable.PlReferTables
	SetPlReferTables(refertable.PlReferTables)

	Tags() map[string]string
	Fields() map[string]any

	GetCache() *plcache.Cache
	SetCache(*plcache.Cache)
}

func NewPlPoint

func NewPlPoint(category point.Category, name string,
	tags map[string]string, fields map[string]any, ptTime time.Time,
) PlInputPt

func WrapPoint

func WrapPoint(cat point.Category, pt *point.Point) PlInputPt

type PlPoint

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

func (*PlPoint) AppendSubPoint

func (pt *PlPoint) AppendSubPoint(plpt PlInputPt)

func (*PlPoint) Category

func (pt *PlPoint) Category() point.Category

func (*PlPoint) Delete

func (pt *PlPoint) Delete(key string)

func (*PlPoint) Dropped

func (pt *PlPoint) Dropped() bool

func (*PlPoint) Fields

func (pt *PlPoint) Fields() map[string]any

func (*PlPoint) Get

func (pt *PlPoint) Get(key string) (any, ast.DType, error)

func (*PlPoint) GetAggBuckets

func (pt *PlPoint) GetAggBuckets() *plmap.AggBuckets

func (*PlPoint) GetCache

func (pt *PlPoint) GetCache() *plcache.Cache

func (*PlPoint) GetIPDB

func (pt *PlPoint) GetIPDB() ipdb.IPdb

func (*PlPoint) GetPlReferTables

func (pt *PlPoint) GetPlReferTables() refertable.PlReferTables

func (*PlPoint) GetPtName

func (pt *PlPoint) GetPtName() string

func (*PlPoint) GetSubPoint

func (pt *PlPoint) GetSubPoint() []PlInputPt

func (*PlPoint) GetWithIsTag

func (pt *PlPoint) GetWithIsTag(key string) (any, bool, bool)

func (*PlPoint) KeyTime2Time

func (pt *PlPoint) KeyTime2Time()

func (*PlPoint) MarkDrop

func (pt *PlPoint) MarkDrop(drop bool)

func (*PlPoint) Point

func (pt *PlPoint) Point() *point.Point

func (*PlPoint) PtTime

func (pt *PlPoint) PtTime() time.Time

func (*PlPoint) RenameKey

func (pt *PlPoint) RenameKey(from, to string) error

func (*PlPoint) Set

func (pt *PlPoint) Set(key string, value any, dtype ast.DType) error

func (*PlPoint) SetAggBuckets

func (pt *PlPoint) SetAggBuckets(buks *plmap.AggBuckets)

func (*PlPoint) SetCache

func (pt *PlPoint) SetCache(c *plcache.Cache)

func (*PlPoint) SetIPDB

func (pt *PlPoint) SetIPDB(db ipdb.IPdb)

func (*PlPoint) SetPlReferTables

func (pt *PlPoint) SetPlReferTables(refTable refertable.PlReferTables)

func (*PlPoint) SetPtName

func (pt *PlPoint) SetPtName(m string)

func (*PlPoint) SetTag

func (pt *PlPoint) SetTag(key string, value any, dtype ast.DType) error

func (*PlPoint) Tags

func (pt *PlPoint) Tags() map[string]string

type PlmapManager

type PlmapManager interface {
}

type PtFlag

type PtFlag uint

const (
	PtMeasurement PtFlag = iota
	PtTag
	PtField
	PtTFDefaulutOrKeep
	PtTime
)