nodes

Documentation

Index

• type NodeOperator
  • func NewNodeOperator(memory tree.Manager, authenticator auth.Auth, broker brokers.Manager) (nop *NodeOperator, err error)
  • func (no *NodeOperator) CreateNode(ctx context.Context, app *meta.App) (*meta.Node, error)
  • func (no *NodeOperator) DeleteNode(ctx context.Context, nodeContext string, nodeName string) error
  • func (no *NodeOperator) Deployments() v1.DeploymentInterface
  • func (no *NodeOperator) Secrets() cv1.SecretInterface
  • func (no *NodeOperator) Services() cv1.ServiceInterface
  • func (no *NodeOperator) UpdateNode(ctx context.Context, app *meta.App) (*meta.Node, error)

Types

type NodeOperator

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

NodeOperator defines a node operations interface.

func NewNodeOperator

func NewNodeOperator(memory tree.Manager, authenticator auth.Auth, broker brokers.Manager) (nop *NodeOperator, err error)

NewNodeOperator initializes a k8s based node operator with in cluster configuration

func (*NodeOperator) CreateNode

func (no *NodeOperator) CreateNode(ctx context.Context, app *meta.App) (*meta.Node, error)

CreateNode deploys a new node structure, if it's information is valid. Otherwise, returns an error

func (*NodeOperator) DeleteNode

func (no *NodeOperator) DeleteNode(ctx context.Context, nodeContext string, nodeName string) error

DeleteNode deletes node with given name, if it exists. Otherwise, returns an error

func (*NodeOperator) Deployments

func (no *NodeOperator) Deployments() v1.DeploymentInterface

Deployments returns the deployment interface for the k8s operator

func (*NodeOperator) Secrets

func (no *NodeOperator) Secrets() cv1.SecretInterface

Secrets returns the secret interface of the node operator

func (*NodeOperator) Services

func (no *NodeOperator) Services() cv1.ServiceInterface

Services returns the service interface for the node operator

func (*NodeOperator) UpdateNode

func (no *NodeOperator) UpdateNode(ctx context.Context, app *meta.App) (*meta.Node, error)

UpdateNode updates a node that already exists, if the new structure is valid. Otherwise, returns an error.