broker

type Broker struct {
	BLock sync.Mutex
	Hubs  map[string]*Hub
	// contains filtered or unexported fields
}

type DirectPacket struct {
	Name  string
	Body  []byte
	Ntype NodeType
}

type Hub struct {
	AllUserConns  map[wire.UID]*NodeConn // TODO lock if ..
	AllAgentConns map[wire.UID]*NodeConn

	ListOfAgents map[string]wire.UID // agentkey (not deploy key) with one most current connection

	AddConnection    chan *NodeConn
	RemoveConnection chan *NodeConn

	PacketChan chan *packet

	CDirectSend chan *DirectPacket

	Ctx       context.Context
	CtxCancel context.CancelFunc

	IDGenerator *generator

	BroadCastEvent chan []byte
	// contains filtered or unexported fields
}

type NodeConn struct {
	Connectionid wire.UID
	Identifier   string   // key for agent userid for user
	Type         NodeType // UserType or AgentType

	CloseReader context.CancelFunc

	CloseWriter context.CancelFunc
	MyHub       *Hub
	Running     bool
	// contains filtered or unexported fields
}

type NodeType byte