topk

Documentation

Index

• Constants
• type NullProjectTracker
  • func (p *NullProjectTracker) Close()
  • func (p *NullProjectTracker) Track(projectId int32, tags ...string)
• type ProjectTracker
  • func NewProjectTracker(client mixpanel.Client, receiver metrics.Receiver, flushInterval time.Duration, ...) ProjectTracker
• type Receiver
  • func New(metrics metrics.Receiver, k int) Receiver

Constants

const (
	CountTag        = "count"
	PreSamplingTag  = "pre_sampling"
	PostSamplingTag = "post_sampling"
	CETag           = "ce_event"
)

Types

type NullProjectTracker

type NullProjectTracker struct{}

func (*NullProjectTracker) Close

func (p *NullProjectTracker) Close()

func (*NullProjectTracker) Track

func (p *NullProjectTracker) Track(projectId int32, tags ...string)

type ProjectTracker

type ProjectTracker interface {
	Track(projectId int32, tags ...string)
	Close()
}

func NewProjectTracker

func NewProjectTracker(client mixpanel.Client,
	receiver metrics.Receiver,
	flushInterval time.Duration,
	eventName string) ProjectTracker

type Receiver

type Receiver interface {
	Track(int32)
	Close()
}

A best-effort receiver. We buffer up to chanBufferSize values, and process them in a single goroutine. The top K values will be reported to the provided Receiver.

func New

func New(metrics metrics.Receiver, k int) Receiver