common

type Event struct {
	Time     string      `json:"time"`
	TimeNano int64       `json:"timeNano"`
	Channel  string      `json:"channel"`
	Type     string      `json:"type"`
	Data     interface{} `json:"data"`
	// contains filtered or unexported fields
}

type Input interface {
	Start(wg *sync.WaitGroup, outputs *Outputs)
}

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

type Output interface {
	Send(event *Event)
}

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