operator

type BaseHandler struct {
}

type BaseResource struct {
	ID string `schema:"id"`
}

type Config struct {
	// Provider is the provider used by the operator
	Provider Provider

	// State is the state access
	State state.State

	// Backends are the list of backends handled by the operator
	HandlerFactories []HandlerFactory

	// GRPCAddr is the address of the grpc server
	GRPCAddr *net.TCPAddr
}

type Executor interface {
	Exec(n *proto.Node, path string, cmd ...string) error
}

type Handler interface {

	// EvaluatePlan evaluates and modifies the execution plan
	EvaluatePlan(*PlanCtx) error

	// PostHook is executed when a node changes the state
	PostHook(*HookCtx) error

	// Spec returns the specification for the cluster
	Spec() *Spec

	// Client returns a connection with a specific node in the cluster
	Client(node *proto.Node) (interface{}, error)
}

type HandlerFactory func() Handler

type HookCtx struct {
	Cluster  *proto.Cluster
	Node     *proto.Node
	Executor Executor
}

type NodeUpdate struct {
	// id of the node that has failed
	ID        string
	ClusterID string
}

type Nodetype struct {
	// Image is the default docker image for the node
	Image string

	// Version is the default docker image for the node
	Version string

	// Volume is a list volumes for this node type
	Volumes []*Volume

	// Ports is a list of ports for this node type
	Ports []*Port
}

type PlanCtx struct {
	Cluster *proto.Cluster
	Plan    *proto.Plan
}

type Port struct {
	Name        string
	Port        uint64
	Description string
}

type Provider interface {
	// Setup setups the provider (Maybe do this on the factory)
	Setup() error

	// Start starts the provider
	Start() error

	// CreateResource creates the computational resource
	CreateResource(*proto.Node) (*proto.Node, error)

	// DeleteResource deletes the computational resource
	DeleteResource(*proto.Node) (*proto.Node, error)

	// WatchUpdates watches for updates from nodes
	WatchUpdates() chan *NodeUpdate

	// Exec executes a shell script
	Exec(handler string, path string, args ...string) error
}

type ProviderFactory func(map[string]interface{}) error

type Resource interface {
	GetName() string
	Delete(conn interface{}) error
	Reconcile(conn interface{}) error
	Init(spec map[string]interface{}) error
}

type Server struct {
	Provider Provider
	State    state.State
	// contains filtered or unexported fields
}

type Spec struct {
	Name      string
	Nodetypes map[string]Nodetype
	Resources []Resource
}

type Volume struct {
	Name        string
	Path        string
	Description string
}