embedded

package

v0.0.0-...-eab3a14 Latest Latest Go to latest Published: Mar 26, 2015 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Creates client/coordinator pairs which use channels to communicate.

Meant to be used embedded in applications which do not need/want external coordination, especially tests.

This section is empty.

This section is empty.

func NewEmbeddedClient(taskchan chan string, cmdchan chan *NodeCommand, nodechan chan []string) metafora.Client

func NewEmbeddedCoordinator(nodeid string, taskchan chan string, cmdchan chan *NodeCommand, nodechan chan []string) metafora.Coordinator

func NewEmbeddedPair(nodeid string) (metafora.Coordinator, metafora.Client)

Returns a connected client/coordinator pair for embedded/testing use

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

func (ec *EmbeddedClient) DeleteTask(taskid string) error

func (ec *EmbeddedClient) Nodes() ([]string, error)

func (ec *EmbeddedClient) SubmitCommand(nodeid string, command metafora.Command) error

func (ec *EmbeddedClient) SubmitTask(taskid string) error

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

Coordinator which listens for tasks on a channel

func (e *EmbeddedCoordinator) Claim(taskID string) bool

func (e *EmbeddedCoordinator) Close()

func (e *EmbeddedCoordinator) Command() (metafora.Command, error)

func (e *EmbeddedCoordinator) Done(taskID string)

func (e *EmbeddedCoordinator) Init(c metafora.CoordinatorContext) error

func (e *EmbeddedCoordinator) Release(taskID string)

func (e *EmbeddedCoordinator) Watch() (taskID string, err error)

type NodeCommand struct {
	Cmd    metafora.Command
	NodeId string
}