protocol

Documentation

Index

• func WriteUpdate(w io.Writer, msg *protocol.Update) error
• type Devices
  • func NewDevices() *Devices
  • func (n *Devices) Add(device *devices.Device) error
  • func (n *Devices) All() map[string]*devices.Device
  • func (n *Devices) AllWithState(nodes *Nodes) map[string]*devices.Device
  • func (n *Devices) ByUuid(uuid string) *devices.Device
  • func (n *Devices) Delete(uuid string)
  • func (n *Devices) RestoreFromFile(path string)
  • func (n *Devices) SaveToFile(path string)
  • func (n *Devices) SetOfflineByNode(nodeUUID string) (list []*devices.Device)
  • func (n *Devices) ShallowCopy() map[string]*devices.Device
• type Node
  • func NewNode() Node
• type Nodes
  • func NewNodes() *Nodes
  • func (n *Nodes) Add(node Node) error
  • func (n *Nodes) All() map[string]Node
  • func (n *Nodes) ByName(name string) Node
  • func (n *Nodes) ByUuid(uuid string) Node
  • func (n *Nodes) Delete(uuid string)
  • func (n *Nodes) Search(nameoruuid string) Node
• type Searchable

Functions

func WriteUpdate

func WriteUpdate(w io.Writer, msg *protocol.Update) error

Types

type Devices

type Devices struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDevices

func NewDevices() *Devices

func (*Devices) Add

func (n *Devices) Add(device *devices.Device) error

func (*Devices) All

func (n *Devices) All() map[string]*devices.Device

func (*Devices) AllWithState

func (n *Devices) AllWithState(nodes *Nodes) map[string]*devices.Device

func (*Devices) ByUuid

func (n *Devices) ByUuid(uuid string) *devices.Device

func (*Devices) Delete

func (n *Devices) Delete(uuid string)

func (*Devices) RestoreFromFile

func (n *Devices) RestoreFromFile(path string)

func (*Devices) SaveToFile

func (n *Devices) SaveToFile(path string)

func (*Devices) SetOfflineByNode

func (n *Devices) SetOfflineByNode(nodeUUID string) (list []*devices.Device)

SetOfflineByNode marks device from a single node offline and returns a list of all marked devices

func (*Devices) ShallowCopy

func (n *Devices) ShallowCopy() map[string]*devices.Device

type Node

type Node interface {
	SetState(interface{})
	State() interface{}

	Devices() *devices.Map
	SetDevices(*devices.Map)

	Config() *protocol.ConfigMap
	SetConfig(*protocol.ConfigMap)

	SetElements([]*protocol.Element)
	Elements() []*protocol.Element

	Uuid() string
	Name() string
	SetUuid(string)
	SetName(string)
	Write(b []byte) (int, error)
	SetConn(conn net.Conn)
	GetNotification(json.RawMessage) *notifications.Notification
}

func NewNode

func NewNode() Node

type Nodes

type Nodes struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TODO: write tests for Nodes struct (jonaz) <Fri 10 Oct 2014 04:31:22 PM CEST>

func NewNodes

func NewNodes() *Nodes

func (*Nodes) Add

func (n *Nodes) Add(node Node) error

func (*Nodes) All

func (n *Nodes) All() map[string]Node

func (*Nodes) ByName

func (n *Nodes) ByName(name string) Node

func (*Nodes) ByUuid

func (n *Nodes) ByUuid(uuid string) Node

func (*Nodes) Delete

func (n *Nodes) Delete(uuid string)

func (*Nodes) Search

func (n *Nodes) Search(nameoruuid string) Node

type Searchable

type Searchable interface {
	Search(string) Node
}