Documentation ¶
Index ¶
Constants ¶
View Source
const ChanQueueLength = 100
ChanQueueLength buffered channel length
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct { InChan chan interface{} OutChan chan interface{} // contains filtered or unexported fields }
Connection : basic interface representing a connection to the dispatcher
func NewConnection ¶
func NewConnection() *Connection
NewConnection creates a new dispatcher connection
func (*Connection) Close ¶
func (connection *Connection) Close()
Close closes the connection, possible issues...
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher main dispatcher class
func (*Dispatcher) AddConnection ¶
func (dispatcher *Dispatcher) AddConnection(connection *Connection)
AddConnection adds a connection to the dispatcher
type Object ¶
type Object map[string]interface{}
Object native representation of a UAVPacket, just a map
type Request ¶
Request is the packet that requests a common data, is forwarded to the owner of a definition (the one that sent the definition)
type Subscription ¶
type Subscription struct {
ObjectID uint32 `json:"objectId"`
}
Subscription adds an objectID to the subscriptions of the sending connection
type Unsubscription ¶
type Unsubscription struct {
ObjectID uint32 `json:"objectId"`
}
Unsubscription removes an objectID from the subscriptions of the sending connection
Click to show internal directories.
Click to hide internal directories.