operator

package

Go to main page

Versions in this module

v0

v0.1.3

Jul 30, 2021

Changes in this version

+ const ApplyResourceRequestDelete

+ const ApplyResourceRequestReconcile

+ var ErrInstanceAlreadyRunning = fmt.Errorf("instance already running")

+ var ErrProviderNameAlreadyUsed = fmt.Errorf("name already used")

+ var ErrResourceNotFound = fmt.Errorf("resource not found")

+ type ApplyResourceRequest struct

+ Action string

+ Deployment *proto.Deployment

+ Resource *proto.ResourceSpec

+ type BaseOperator struct

+ func (b *BaseOperator) ApplyNodes(place []*proto.Instance, cluster []*proto.Instance) ([]*proto.Instance, error)

+ func (b *BaseOperator) ApplyResource(req *ApplyResourceRequest) error

+ func (b *BaseOperator) Client(node *proto.Instance) (interface{}, error)

+ func (b *BaseOperator) Evaluate(comp *proto.Component) (*proto.Component, error)

+ func (b *BaseOperator) GetSchemas() GetSchemasResponse

+ func (b *BaseOperator) SetHandler(h Handler2)

+ func (b *BaseOperator) Setup(cplane ControlPlane)

+ type CallbackRequest struct

+ Client interface{}

+ Data *schema.ResourceData

+ func (c *CallbackRequest) Get(s string) interface{}

+ type ControlPlane interface

+ GetInstance func(instanceID string) (*proto.Instance, error)

+ SubscribeInstanceUpdates func() <-chan *InstanceUpdate

+ UpsertInstance func(*proto.Instance) error

+ type GetSchemasResponse struct

+ Nodes map[string]schema.Schema2

+ Resources map[string]schema.Schema2

type Handler

+ ApplyNodes func(n []*proto.Instance, cluster []*proto.Instance) ([]*proto.Instance, error)

+ ApplyResource func(req *ApplyResourceRequest) error

+ Evaluate func(comp *proto.Component) (*proto.Component, error)

+ GetSchemas func() GetSchemasResponse

+ Name func() string

+ Setup func(cplane ControlPlane)

+ type Handler2 interface

+ Client func(node *proto.Instance) (interface{}, error)

+ Initialize func(n []*proto.Instance, target *proto.Instance) (*proto.NodeSpec, error)

+ Spec func() *Spec

+ type Harness struct

+ Component *proto.Component

+ Deployment *proto.Deployment

+ Handler Handler

+ Scheduler Scheduler

+ func NewHarness(t assert.TestingT) *Harness

+ func (h *Harness) AddComponent(c *proto.Component)

+ func (h *Harness) ApplyDep(plan *proto.Plan, callback func(i *proto.Instance)) *proto.Deployment

+ func (h *Harness) Eval() *proto.Plan

+ func (h *Harness) Expect(plan *proto.Plan, expect *HarnessExpect)

+ func (h *Harness) GetComponentByID(dep, id string, sequence int64) (*proto.Component, error)

+ func (h *Harness) GetHandler(id string) (Handler, error)

+ func (h *Harness) LoadDeployment(id string) (*proto.Deployment, error)

+ type HarnessExpect struct

+ Nodes []*HarnessExpectInstance

+ Status string

+ type HarnessExpectInstance struct

+ KV map[string]string

+ Name string

+ Spec *proto.NodeSpec

+ Status proto.Instance_Status

+ type InmemControlPlane struct

+ func (i *InmemControlPlane) GetInstance(InstanceID string) (*proto.Instance, error)

+ func (i *InmemControlPlane) SubscribeInstanceUpdates() <-chan *InstanceUpdate

+ func (i *InmemControlPlane) UpsertInstance(ii *proto.Instance) error

+ type InstanceUpdate struct

+ InstanceID string

type Nodetype

+ Config interface{}

+ DefaultVersion string

+ Schema schema.Schema2

type Provider

+ Name func() string

+ Resources func() ProviderResources

+ Stop func() error

+ type ProviderResources struct

+ Resources schema.Schema2

+ Storage schema.Schema2

+ type Resource2 struct

+ ApplyFn func(req *CallbackRequest) error

+ DeleteFn func(req *CallbackRequest) error

+ Name string

+ Schema schema.Schema2

+ type ResourceScheduler struct

+ func (r *ResourceScheduler) Process(eval *proto.Evaluation) (*proto.Plan, error)

+ type Scheduler interface

+ Process func(eval *proto.Evaluation) (*proto.Plan, error)

+ func NewScheduler(state schedState) Scheduler

type Server

+ func (s *Server) GetComponentByID(deployment, compID string, sequence int64) (*proto.Component, error)

+ func (s *Server) GetHandler(id string) (Handler, error)

+ func (s *Server) GetInstance(instanceID string) (*proto.Instance, error)

+ func (s *Server) LoadDeployment(id string) (*proto.Deployment, error)

+ func (s *Server) SubmitPlan(eval *proto.Evaluation, p *proto.Plan) error

+ func (s *Server) SubscribeInstanceUpdates() <-chan *InstanceUpdate

+ func (s *Server) UpsertInstance(n *proto.Instance) error

type Spec

+ Handlers map[string]func(spec *proto.NodeSpec, grp *proto.ClusterSpec_Group, data *schema.ResourceData)

+ Startup func(i *proto.Instance) error

+ Validate func(comp *proto.Component) (*proto.Component, error)

v0.1.2

Feb 8, 2021

Changes in this version

+ type BaseHandler struct

+ func (b *BaseHandler) PostHook(*HookCtx) error

type BaseResource

+ func (b *BaseResource) Init(spec map[string]interface{}) error

type Handler

+ PostHook func(*HookCtx) error

+ type HookCtx struct

+ Cluster *proto.Cluster

+ Executor Executor

+ Node *proto.Node

+ type NodeUpdate struct

+ ClusterID string

+ ID string

+ type PlanCtx struct

+ Cluster *proto.Cluster

+ Plan *proto.Plan

type Provider

+ WatchUpdates func() chan *NodeUpdate

type Resource

+ Init func(spec map[string]interface{}) error

v0.1.1

Jan 25, 2021

Changes in this version

type Config

+ GRPCAddr *net.TCPAddr

+ State state.State

type Server

+ State state.State

+ func (s *Server) Config() *Config

v0.1.0

Dec 9, 2020

Changes in this version

+ func HandleResource(eval *proto.Evaluation, handler Handler, e *proto.Cluster) error

+ type BaseResource struct

+ ID string

+ func (b *BaseResource) SetID(id string)

+ type Config struct

+ HandlerFactories []HandlerFactory

+ Provider Provider

+ type Executor interface

+ Exec func(n *proto.Node, path string, cmd ...string) error

+ type Handler interface

+ Client func(node *proto.Node) (interface{}, error)

+ EvaluatePlan func(plan *proto.Plan) error

+ Reconcile func(executor Executor, e *proto.Cluster, node *proto.Node, plan *proto.Plan) error

+ Spec func() *Spec

+ type HandlerFactory func() Handler

+ type Nodetype struct

+ Image string

+ Ports []*Port

+ Version string

+ Volumes []*Volume

+ type Port struct

+ Description string

+ Name string

+ Port uint64

+ type Provider interface

+ CreateResource func(*proto.Node) (*proto.Node, error)

+ DeleteResource func(*proto.Node) (*proto.Node, error)

+ Exec func(handler string, path string, args ...string) error

+ FinalizeTask func(uuid string) error

+ GetTask func() (*proto.Task, error)

+ LoadCluster func(name string) (*proto.Cluster, error)

+ Setup func() error

+ Start func() error

+ UpdateNodeStatus func(*proto.Node) (*proto.Node, error)

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

+ type Resource interface

+ Delete func(conn interface{}) error

+ GetName func() string

+ Reconcile func(conn interface{}) error

+ type Server struct

+ Provider Provider

+ func NewServer(logger hclog.Logger, config *Config) (*Server, error)

+ func TestOperator(t *testing.T, provider Provider, factory HandlerFactory) *Server

+ func (s *Server) Exec(n *proto.Node, path string, cmd ...string) error

+ func (s *Server) Stop()

+ type Spec struct

+ Name string

+ Nodetypes map[string]Nodetype

+ Resources []Resource

+ type Volume struct

+ Description string

+ Name string

+ Path string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL