server

package

v0.2.3 Latest Latest Go to latest Published: Apr 14, 2014 License: Apache-2.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

func IDService(idChan chan string)

type BlockInfo struct {
	Id       string
	Type     string
	Rule     interface{}
	Position *Coords
	// contains filtered or unexported fields
}

type BlockManager struct {
	Mu *sync.Mutex
	// contains filtered or unexported fields
}

func NewBlockManager() *BlockManager

func (b *BlockManager) Connect(connInfo *ConnectionInfo) (*ConnectionInfo, error)

func (b *BlockManager) Create(blockInfo *BlockInfo) (*BlockInfo, error)

func (b *BlockManager) DeleteBlock(id string) ([]string, error)

func (b *BlockManager) DeleteConnection(id string) (string, error)

func (b *BlockManager) DeleteSocket(blockId string, connId string) error

func (b *BlockManager) GetBlock(id string) (*BlockInfo, error)

func (b *BlockManager) GetConnection(id string) (*ConnectionInfo, error)

func (b *BlockManager) GetId() string

func (b *BlockManager) GetSocket(fromId string) (chan *blocks.Msg, string, error)

func (b *BlockManager) IdExists(id string) bool

func (b *BlockManager) IdSafe(id string) bool

func (b *BlockManager) ListBlocks() []*BlockInfo

func (b *BlockManager) ListConnections() []*ConnectionInfo

func (b *BlockManager) QueryBlock(id string, route string) (interface{}, error)

func (b *BlockManager) QueryConnection(id string, route string) (interface{}, error)

func (b *BlockManager) Send(id string, route string, msg interface{}) error

func (b *BlockManager) StatusBlocks() []string

func (b *BlockManager) UpdateBlock(id string, coord *Coords) (*BlockInfo, error)

type ConnectionInfo struct {
	Id      string
	FromId  string
	ToId    string
	ToRoute string
	// contains filtered or unexported fields
}

type Coords struct {
	X float64
	Y float64
}

type Server struct {
	Port   string
	Domain string
	Id     string
	// contains filtered or unexported fields
}

func NewServer() *Server

func (s *Server) Run()