routers

type Connections interface {
	Add(clientId string, conn model.TagyouConn)
	Exists(clientId string) (model.TagyouConn, bool)
	Close(clientId string) error
	Remove(clientId string)
}

type Router interface {
	Send(clientId string, payload []byte)
	Forward(topic string, packet *packet.Packet)
	AddDestination(clientId string, conn model.TagyouConn)
	RemoveDestination(clientId string)
	DestinationExists(clientId string) bool
}

type SimpleConnections struct {
	Conns map[string]model.TagyouConn
	Mu    sync.RWMutex
}

type SimpleRouter struct {
	Conns Connections
}