netsample

type Aggregator interface {
	Run(ctx context.Context, deps core.AggregatorDeps) error
	Report(sample *Sample)
}

type PhoutConfig struct {
	Destination     string                    // Destination file name
	Id              bool                      // Print ammo ids if true.
	FlushTime       time.Duration             `config:"flush-time"`
	SampleQueueSize int                       `config:"sample-queue-size"`
	Buffer          coreutil.BufferSizeConfig `config:",squash"`
}

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

type TestAggregator struct {
	Samples []*Sample
}