useractivity

func NewUserActivityReporter ¶

func NewUserActivityReporter(
	metricChannel chan *pb.Metric,
	outputChannel chan *pb.Metric,
	segmentioToken string,
	window time.Duration,
	dockerBuild string,
) *reporter

Creates a new instance of the plugin. The plugin consumes a set of events, generated by the platform, and aggregates them into activity sessions. An activity session is a set of events, that happen closer than a given duration apart.

metricChannel:  The channel for inbound metrics.
segmentioToken: The segmentio write token.
window:         A maximum duration between two events, that would still be
                considered a part of one session.
dockerBuild:    A string identifying the platform build.