consumer

type Consumer interface {
	Consume() <-chan *DeviceEvent
}

type DeviceEvent struct {
	Object api.Object
	State  api.DeviceState
}

type RedisStreamEvent struct {
	ID          string
	DeviceEvent *DeviceEvent
}