timewheel

type AfterCountFunc interface {
	AfterCount(msg Message) (err error)
}

type Aggregate struct {
	*Counter
}

type Counter struct {
	Output chan Message
	// contains filtered or unexported fields
}

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

type Message interface {
	proto.Message
	Type() string
	NewCounter(tw *TimeWheel, size uint64, d time.Duration) (*Counter, error)
	Add(Message)
	Clean()
}

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

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

type Ticker struct {
	C chan time.Time
	// contains filtered or unexported fields
}

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

type Timer = Ticker

type TriggerDirection uint64

type TriggerMethod uint64

type TypeFactory func() (msg Message)

type Uint64 struct {
	pb.Uint64
}