plmap

Documentation

Overview

Package plmap used to store data during pl script execution

Index

• Constants
• func InitLog()
• func NewAggMetric(name, action string) (aggMetric, bool)
• type AggBuckets
  • func NewAggBuks(upFn UploadFunc, globalTags [][2]string) *AggBuckets
  • func (a *AggBuckets) CreateBucket(cat point.Category, name string, interval time.Duration, count int, ...)
  • func (a *AggBuckets) GetBucket(cat point.Category, name string) (*bucket, bool)
  • func (a *AggBuckets) SetUploadFunc(fn UploadFunc)
  • func (a *AggBuckets) StopAllBukScanner()
• type PlMapIface
• type UploadFunc

Constants

const FeedName = "pl_agg"

Functions

func InitLog

func InitLog()

func NewAggMetric

func NewAggMetric(name, action string) (aggMetric, bool)

Types

type AggBuckets

type AggBuckets struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewAggBuks

func NewAggBuks(upFn UploadFunc, globalTags [][2]string) *AggBuckets

func (*AggBuckets) CreateBucket

func (a *AggBuckets) CreateBucket(cat point.Category, name string, interval time.Duration,
	count int, keepValue bool, constTags map[string]string,
)

func (*AggBuckets) GetBucket

func (a *AggBuckets) GetBucket(cat point.Category, name string) (*bucket, bool)

func (*AggBuckets) SetUploadFunc

func (a *AggBuckets) SetUploadFunc(fn UploadFunc)

func (*AggBuckets) StopAllBukScanner

func (a *AggBuckets) StopAllBukScanner()

type PlMapIface

type PlMapIface interface {
	SetUploadFunc(UploadFunc)
}

type UploadFunc

type UploadFunc func(cat point.Category, ptID string, elem any) error