Documentation ¶
Index ¶
Constants ¶
View Source
const EtcdMinionSpace = "/gru/minion"
Minions keyspace in etcd
Variables ¶
This section is empty.
Functions ¶
func EtcdUnmarshalTask ¶
func EtcdUnmarshalTask(node *etcdclient.Node) (*task.Task, error)
Unmarshals task from etcd
Types ¶
type Minion ¶
type Minion interface { // Returns the unique identifier of a minion ID() uuid.UUID // Sets the name of the minion SetName(string) error // Sets the time the minion was last seen SetLastseen(int64) error // Sets a classifier for the minion SetClassifier(*classifier.Classifier) error // Listens for new tasks and processes them TaskListener(c chan<- *task.Task) error // Runs new tasks as received by the TaskListener TaskRunner(c <-chan *task.Task) error // Saves the result of a task SaveTaskResult(t *task.Task) error // Start serving Serve() error // Stops the minion Stop() error }
func NewEtcdMinion ¶
func NewEtcdMinion(name string, cfg etcdclient.Config) Minion
Creates a new etcd minion
Click to show internal directories.
Click to hide internal directories.