events

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

type CommandSender struct {
	UnityCommandSender
	// contains filtered or unexported fields
}

type Config struct {
	ConsumerName string
	RabbitHost   string
	RabbitPort   int
	RabbitUser   string
	RabbitPass   string
	RabbitQueue  string
}

type EventType string

type EventUnit string

type Publisher struct {
	UnityEventPublisher
	// contains filtered or unexported fields
}

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

type UnityCommand struct {
	DeviceId string `json:"d"`
	State    string `json:"s"`
	Value    string `json:"v"`
	Target   string `json:"t"`
}

type UnityCommandReceiver func(event UnityCommand)

type UnityCommandSender interface {
	Send(cmd UnityCommand)
}

type UnityCommandSubscriber interface {
	Receiver() error
	AddHandler(handler UnityCommandReceiver)
}

type UnityEvent struct {
	DeviceId  string    `json:"d"`
	EventType EventType `json:"e"`
	Timestamp int64     `json:"t"`
	Units     EventUnit `json:"u"`
	Value     string    `json:"v"`
}

type UnityEventPublisher interface {
	Publish(event UnityEvent) error
}

type UnityEventReceiver func(event UnityEvent)

type UnityEventSubscriber interface {
	Subscriber() error
	AddHandler(handler UnityEventReceiver)
}