// Mgmt // Copyright (C) 2013-2018+ James Shubin and the project contributors // Written by James Shubin and the project contributors // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . package engine import ( "github.com/purpleidea/mgmt/etcd/scheduler" ) // World is an interface to the rest of the different graph state. It allows // the GAPI to store state and exchange information throughout the cluster. It // is the interface each machine uses to communicate with the rest of the world. type World interface { // TODO: is there a better name for this interface? ResWatch() chan error ResExport([]Res) error // FIXME: should this method take a "filter" data struct instead of many args? ResCollect(hostnameFilter, kindFilter []string) ([]Res, error) StrWatch(namespace string) chan error StrIsNotExist(error) bool StrGet(namespace string) (string, error) StrSet(namespace, value string) error StrDel(namespace string) error // XXX: add the exchange primitives in here directly? StrMapWatch(namespace string) chan error StrMapGet(namespace string) (map[string]string, error) StrMapSet(namespace, value string) error StrMapDel(namespace string) error Scheduler(namespace string, opts ...scheduler.Option) (*scheduler.Result, error) Fs(uri string) (Fs, error) }