operator

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

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

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

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

type Handler interface {
	// Reconcile is called whenever there is an internal state change in the cluster
	Reconcile(executor Executor, e *proto.Cluster, node *proto.Node, plan *proto.Plan) error

	// EvaluatePlan evaluates and modifies the execution plan
	EvaluatePlan(plan *proto.Plan) 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 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 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)

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

	// Update the status of the node
	UpdateNodeStatus(*proto.Node) (*proto.Node, error)

	// LoadCluster loads a Cluster at the specific resourceVersion
	LoadCluster(name string) (*proto.Cluster, error)

	// GetTask receives updates for ensembles
	GetTask() (*proto.Task, error)

	// FinalizeTask is used to notify the provider that the given task is done
	FinalizeTask(uuid string) error
}

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

type Resource interface {
	GetName() string
	Delete(conn interface{}) error
	Reconcile(conn interface{}) error
}

type Server struct {
	Provider Provider
	// 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
}