edge

type Edge interface {
	Out() chan Record
	In() chan Record
}

type KafkaRecord struct {
	Message *sarama.ConsumerMessage
	Session sarama.ConsumerGroupSession
}

type Record interface {
}

type Records []Record

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