broker

type Broker interface {
	Publish(msg []byte)
	Subscribe() (chan []byte, error)
	Unsubscribe(ch chan []byte)
}

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

type RedisRegistrar struct{}

type Registrar interface {
	Register(id util.UUID) error
	IsRegistered(id util.UUID) bool
}