ptinput

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

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

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 interface{}

type KeyKind uint

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

	Get(key string) (any, ast.DType, error)
	Set(key string, value any, dtype ast.DType) bool

	Delete(key string)
	RenameKey(from, to string) error

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

	PtTime() time.Time

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

	SetPtWinPool(w *ptwindow.WindowPool)
	PtWinRegister(before, after int, k, v []string)
	PtWinHit()
	CallbackPtWinMove() (result []*point.Point)

	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)
}

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

type PlmapManager interface {
}

type PtFlag uint