dispatcher

package

v0.0.1-alpha Latest Latest Go to latest Published: Jul 26, 2015 License: Apache-2.0 Imports: 3 Imported by: 9

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const ChanQueueLength = 100

ChanQueueLength buffered channel length

This section is empty.

This section is empty.

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() *Connection

NewConnection creates a new dispatcher connection

func (connection *Connection) Close()

Close closes the connection, possible issues...

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

Dispatcher main dispatcher class

func NewDispatcher() *Dispatcher

NewDispatcher creates a dispatcher

func (dispatcher *Dispatcher) AddConnection(connection *Connection)

AddConnection adds a connection to the dispatcher

func (dispatcher *Dispatcher) Start()

Start starts the dispatcher

type Object map[string]interface{}

Object native representation of a UAVPacket, just a map

type Request struct {
	ObjectID   uint32 `json:"objectId"`
	InstanceID uint16 `json:"instanceId"`
}

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 struct {
	ObjectID uint32 `json:"objectId"`
}

Subscription adds an objectID to the subscriptions of the sending connection

type Unsubscription struct {
	ObjectID uint32 `json:"objectId"`
}

Unsubscription removes an objectID from the subscriptions of the sending connection

type Update struct {
	ObjectID   uint32 `json:"objectId"`
	InstanceID uint16 `json:"instanceId"`
	Data       Object `json:"data"`
}

Update is the UAVTalk protocol packet, encapsulates a common in the field Data