servernode

Documentation

Index

• func New(uuid string, logicChannel chan string) serverprotocol.Node
• type Node
  • func (self *Node) GetNotification(data json.RawMessage) *notifications.Notification
  • func (self *Node) GetPing() bool
  • func (self *Node) GetPong() bool
  • func (self *Node) LogicChannel() chan string
  • func (self *Node) Reset(key string)
  • func (self *Node) Set(key string, value interface{})
  • func (self *Node) SetConn(conn net.Conn)
  • func (self *Node) State() interface{}
  • func (n *Node) Write(b []byte) (int, error)

Functions

func New

func New(uuid string, logicChannel chan string) serverprotocol.Node

Types

type Node

type Node struct {
	protocol.Node
	State_ map[string]interface{} `json:"State"`
	// contains filtered or unexported fields
}

func (*Node) GetNotification

func (self *Node) GetNotification(data json.RawMessage) *notifications.Notification

func (*Node) GetPing

func (self *Node) GetPing() bool

func (*Node) GetPong

func (self *Node) GetPong() bool

func (*Node) LogicChannel

func (self *Node) LogicChannel() chan string

func (*Node) Reset

func (self *Node) Reset(key string)

func (*Node) Set

func (self *Node) Set(key string, value interface{})

func (*Node) SetConn

func (self *Node) SetConn(conn net.Conn)

func (*Node) State

func (self *Node) State() interface{}

func (*Node) Write

func (n *Node) Write(b []byte) (int, error)