operator

type ApplyResourceRequest struct {
	Deployment *proto.Deployment
	Resource   *proto.ResourceSpec
	Action     string
}

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

type CallbackRequest struct {
	Client interface{}
	Data   *schema.ResourceData
}

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

	// State is the state access
	State *boltdb.BoltDB

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

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

type ControlPlane interface {
	UpsertInstance(*proto.Instance) error
	GetInstance(instanceID string) (*proto.Instance, error)
	SubscribeInstanceUpdates() <-chan *InstanceUpdate
}

type GetSchemasResponse struct {
	Nodes     map[string]schema.Schema2
	Resources map[string]schema.Schema2
}

type Handler interface {
	// Name returns the name of the handler (TODO. it can be removed later)
	Name() string

	// Setup starts the backend and passes the control plane reference
	Setup(cplane ControlPlane)

	// Evaluate evaluates a component schema
	Evaluate(comp *proto.Component) (*proto.Component, error)

	// GetSchemas returns the schemas for the backend
	GetSchemas() GetSchemasResponse

	// ApplyNodes applies to the spec the changes required
	ApplyNodes(n []*proto.Instance, cluster []*proto.Instance) ([]*proto.Instance, error)

	// ApplyResource applies a resource change
	ApplyResource(req *ApplyResourceRequest) error
}

type Handler2 interface {
	Spec() *Spec
	Initialize(n []*proto.Instance, target *proto.Instance) (*proto.NodeSpec, error)
	Client(node *proto.Instance) (interface{}, error)
}

type HandlerFactory func() Handler

type Harness struct {
	Deployment *proto.Deployment
	Handler    Handler
	Scheduler  Scheduler
	Component  *proto.Component
	// contains filtered or unexported fields
}

type HarnessExpect struct {
	Status string
	Nodes  []*HarnessExpectInstance
}

type HarnessExpectInstance struct {
	Name   string
	KV     map[string]string
	Status proto.Instance_Status
	Spec   *proto.NodeSpec
}

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

type InstanceUpdate struct {
	InstanceID string
}

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

	// Config is the configuration fields for this node type
	Config interface{} // out

	Schema schema.Schema2

	// Version is the default docker image for the node
	DefaultVersion 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(ControlPlane) error

	// Start starts the provider
	Start() error

	Stop() error

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

	// Resources returns a struct that defines the node resources
	// that can be configured for this provider
	Resources() ProviderResources

	Name() string
}

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

type ProviderResources struct {
	Resources schema.Schema2
	Storage   schema.Schema2
}

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

type Resource2 struct {
	Name     string
	Schema   schema.Schema2
	DeleteFn func(req *CallbackRequest) error
	ApplyFn  func(req *CallbackRequest) error
}

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

type Scheduler interface {
	Process(eval *proto.Evaluation) (*proto.Plan, error)
}

type Server struct {
	Provider Provider
	State    *boltdb.BoltDB
	// contains filtered or unexported fields
}

type Spec struct {
	Name      string // out
	Nodetypes map[string]Nodetype
	Resources []*Resource2
	Validate  func(comp *proto.Component) (*proto.Component, error)
	Handlers  map[string]func(spec *proto.NodeSpec, grp *proto.ClusterSpec_Group, data *schema.ResourceData)
	Startup   func(i *proto.Instance) error
}

type Volume struct {
	Name        string
	Path        string
	Description string
}