consumer

Documentation

Index

• type Consumer
  • func New(pool *redis.Pool) Consumer
• type DeviceEvent
• type RedisStreamEvent

Types

type Consumer

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

func New

func New(pool *redis.Pool) Consumer

type DeviceEvent

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

type RedisStreamEvent

type RedisStreamEvent struct {
	ID          string
	DeviceEvent *DeviceEvent
}