aggregators

Documentation

Index

• type NodeWrapper
  • func (r *NodeWrapper) Record(depth, totalDepth int, bucket, rp, measurement string, key []byte, ...)
• type RollupNode
• type RollupNodeFactory
  • func CreateNodeFactory(detailed, exact bool) *RollupNodeFactory
  • func (f *RollupNodeFactory) PrintDivider(tw *tabwriter.Writer) error
  • func (f *RollupNodeFactory) PrintHeader(tw *tabwriter.Writer) error

Types

type NodeWrapper

type NodeWrapper struct {
	RollupNode
}

func (*NodeWrapper) Record

func (r *NodeWrapper) Record(depth, totalDepth int, bucket, rp, measurement string, key []byte, field []byte, tags models.Tags)

type RollupNode

type RollupNode interface {
	sync.Locker
	report.Counter
	Children() rollupNodeMap
	RecordSeries(bucket, rp, ms string, key, field []byte, tags models.Tags)
	Print(tw *tabwriter.Writer, printTags bool, bucket, rp, ms string) error
	// contains filtered or unexported methods
}

type RollupNodeFactory

type RollupNodeFactory struct {
	EstTitle string
	NewNode  func(isLeaf bool) NodeWrapper
	// contains filtered or unexported fields
}

func CreateNodeFactory

func CreateNodeFactory(detailed, exact bool) *RollupNodeFactory

func (*RollupNodeFactory) PrintDivider

func (f *RollupNodeFactory) PrintDivider(tw *tabwriter.Writer) error

func (*RollupNodeFactory) PrintHeader

func (f *RollupNodeFactory) PrintHeader(tw *tabwriter.Writer) error