topk

type NullProjectTracker ¶

type NullProjectTracker struct{}

func (p *NullProjectTracker) Close()

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

type ProjectTracker ¶

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

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(metrics metrics.Receiver, k int) Receiver