server

Documentation

Index

• Variables
• type OnDemandServer
  • func NewOnDemandServer(g *graph.Graph, pool *ws.StructClientPool, handler OnDemandServerHandler) (*OnDemandServer, error)
  • func (o *OnDemandServer) OnNodeDeleted(n *graph.Node)
  • func (o *OnDemandServer) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)
  • func (o *OnDemandServer) Start() error
  • func (o *OnDemandServer) Stop()
• type OnDemandServerHandler

Variables

var ErrTaskNotFound = errors.New("task not found")

ErrTaskNotFound used when a task is not found for a specific node

Types

type OnDemandServer

type OnDemandServer struct {
	common.RWMutex
	graph.DefaultGraphListener
	ws.DefaultSpeakerEventHandler
	Graph *graph.Graph
	// contains filtered or unexported fields
}

OnDemandServer describes an ondemand task server based on websocket

func NewOnDemandServer

func NewOnDemandServer(g *graph.Graph, pool *ws.StructClientPool, handler OnDemandServerHandler) (*OnDemandServer, error)

NewOnDemandServer creates a new Ondemand tasks server based on graph and websocket

func (*OnDemandServer) OnNodeDeleted

func (o *OnDemandServer) OnNodeDeleted(n *graph.Node)

OnNodeDeleted graph event

func (*OnDemandServer) OnStructMessage

func (o *OnDemandServer) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

OnStructMessage websocket message, valid message type are Start, Stop

func (*OnDemandServer) Start

func (o *OnDemandServer) Start() error

Start the task

func (*OnDemandServer) Stop

func (o *OnDemandServer) Stop()

Stop the task

type OnDemandServerHandler

type OnDemandServerHandler interface {
	ResourceName() string
	DecodeMessage(msg json.RawMessage) (types.Resource, error)
	CreateTask(*graph.Node, types.Resource) (interface{}, error)
	RemoveTask(*graph.Node, types.Resource, interface{}) error
}

OnDemandServerHandler is the interface to be implemented by ondemand servers