edge

Documentation

Index

• type Edge
• type KafkaRecord
• type Record
• type Records
• type StatEdge
  • func NewEdge(name string, size int) *StatEdge
  • func (e *StatEdge) In() chan Record
  • func (e *StatEdge) Out() chan Record

Types

type Edge

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

type KafkaRecord

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

type Record

type Record interface {
}

type Records

type Records []Record

type StatEdge

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

func NewEdge

func NewEdge(name string, size int) *StatEdge

func (*StatEdge) In

func (e *StatEdge) In() chan Record

func (*StatEdge) Out

func (e *StatEdge) Out() chan Record