nodes

package

v0.2.0 Latest Latest Go to latest Published: Apr 16, 2021 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

NodeOperator defines a node operations interface.

func NewOperator(memory memory.Manager) (nop *NodeOperator, err error)

NewOperator initializes a k8s based kafka node operator with in cluster configuration

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 (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 (no *NodeOperator) GetAllNodes() []meta.Node

GetAllNodes returns a list of all the active nodes in the deployment, if there are any

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

GetNode returns the node with the given name, if it exists. Otherwise, returns an error

func (no *NodeOperator) Nodes() operators.NodeOperatorInterface

Nodes is a NodeOperatorInterface that provides methods for node manipulation

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.