out

type BufferedWriter struct {
	FlushInterval   int
	MetricsPerFlush int
	FlushCB         funFlush
	WriteBufferSize int
	// contains filtered or unexported fields
}

type Carbon struct {
	Id int
	// contains filtered or unexported fields
}

type Kafka struct {
	Id int
	// contains filtered or unexported fields
}

type Multiplexer struct {
	Id int
	// contains filtered or unexported fields
}

type Out interface {
	Start()
	Put(*schema.MetricData)
}