embeddedcluster

Documentation

Index

• Constants
• Variables
• func ClusterConfig(ctx context.Context, kbClient kbclient.Client) (*embeddedclusterv1beta1.ConfigSpec, error)
• func ControllerRoleName(ctx context.Context, kbClient kbclient.Client) (string, error)
• func ConvertToRFC1123(value string, args ...int) string
• func DeleteNode(ctx context.Context, client kubernetes.Interface, restconfig *rest.Config, ...) error
• func DrainNode(ctx context.Context, client kubernetes.Interface, node *corev1.Node) error
• func GenerateAddNodeCommand(ctx context.Context, kbClient kbclient.Client, token string, isAirgap bool) (string, error)
• func GenerateAddNodeToken(ctx context.Context, client kbclient.Client, nodeRole string) (string, error)
• func GenerateK0sJoinCommand(ctx context.Context, kbClient kbclient.Client, roles []string) (string, error)
• func GetCurrentInstallation(ctx context.Context, kbClient kbclient.Client) (*embeddedclusterv1beta1.Installation, error)
• func GetNode(ctx context.Context, client kubernetes.Interface, nodeName string) (*types.Node, error)
• func GetNodes(ctx context.Context, client kubernetes.Interface) (*types.EmbeddedClusterNodes, error)
• func GetRoles(ctx context.Context, kbClient kbclient.Client) ([]string, error)
• func GetSeaweedFSS3ServiceIP(ctx context.Context, kbClient kbclient.Client) (string, error)
• func InstallationFailed(ctx context.Context, ins *embeddedclusterv1beta1.Installation) bool
• func InstallationSucceeded(ctx context.Context, ins *embeddedclusterv1beta1.Installation) bool
• func IsHA(clientset kubernetes.Interface) (bool, error)
• func IsValidRFC1123(value string) bool
• func ListInstallations(ctx context.Context, kbClient kbclient.Client) ([]embeddedclusterv1beta1.Installation, error)
• func RequiresClusterUpgrade(ctx context.Context, kbClient kbclient.Client, kotsKinds *kotsutil.KotsKinds) (bool, error)
• func RequiresUpgrade(ctx context.Context, kbClient kbclient.Client, ...) (bool, error)
• func SortRoles(controllerRole string, inputRoles []string) []string
• func StartClusterUpgrade(ctx context.Context, kotsKinds *kotsutil.KotsKinds, ...) error
• func SyncExec(coreClient corev1client.CoreV1Interface, clientConfig *rest.Config, ...) (int, string, string, error)

Constants

const (
	SeaweedfsNamespace = "seaweedfs"
	SeaweedfsS3SVCName = "ec-seaweedfs-s3"
)

const DEFAULT_CONTROLLER_ROLE_NAME = "controller"

Variables

var ErrNoInstallations = fmt.Errorf("no installations found")

ErrNoInstallations is returned when no installation object is found in the cluster.

Functions

func ClusterConfig

func ClusterConfig(ctx context.Context, kbClient kbclient.Client) (*embeddedclusterv1beta1.ConfigSpec, error)

ClusterConfig will extract the current cluster configuration from the latest installation object found in the cluster.

func ControllerRoleName

func ControllerRoleName(ctx context.Context, kbClient kbclient.Client) (string, error)

ControllerRoleName determines the name for the 'controller' role this might be part of the config, or it might be the default

func ConvertToRFC1123

func ConvertToRFC1123(value string, args ...int) string

func DeleteNode

func DeleteNode(ctx context.Context, client kubernetes.Interface, restconfig *rest.Config, node *corev1.Node) error

func DrainNode

func DrainNode(ctx context.Context, client kubernetes.Interface, node *corev1.Node) error

func GenerateAddNodeCommand

func GenerateAddNodeCommand(ctx context.Context, kbClient kbclient.Client, token string, isAirgap bool) (string, error)

GenerateAddNodeCommand returns the command a user should run to add a node with the provided token the command will be of the form 'embeddedcluster node join ip:port UUID'

func GenerateAddNodeToken

func GenerateAddNodeToken(ctx context.Context, client kbclient.Client, nodeRole string) (string, error)

GenerateAddNodeToken will generate the embedded cluster node add command for a node with the specified roles join commands will last for 24 hours, and will be cached for 1 hour after first generation

func GenerateK0sJoinCommand

func GenerateK0sJoinCommand(ctx context.Context, kbClient kbclient.Client, roles []string) (string, error)

GenerateK0sJoinCommand returns the k0s node join command, without the token but with all other required flags (including node labels generated from the roles etc)

func GetCurrentInstallation

func GetCurrentInstallation(ctx context.Context, kbClient kbclient.Client) (*embeddedclusterv1beta1.Installation, error)

GetCurrentInstallation returns the most recent installation object from the cluster.

func GetNode

func GetNode(ctx context.Context, client kubernetes.Interface, nodeName string) (*types.Node, error)

GetNode will get a node with stats and podlist

func GetNodes

func GetNodes(ctx context.Context, client kubernetes.Interface) (*types.EmbeddedClusterNodes, error)

GetNodes will get a list of nodes with stats

func GetRoles

func GetRoles(ctx context.Context, kbClient kbclient.Client) ([]string, error)

GetRoles will get a list of role names

func GetSeaweedFSS3ServiceIP

func GetSeaweedFSS3ServiceIP(ctx context.Context, kbClient kbclient.Client) (string, error)

func InstallationFailed

func InstallationFailed(ctx context.Context, ins *embeddedclusterv1beta1.Installation) bool

func InstallationSucceeded

func InstallationSucceeded(ctx context.Context, ins *embeddedclusterv1beta1.Installation) bool

func IsHA

func IsHA(clientset kubernetes.Interface) (bool, error)

func IsValidRFC1123

func IsValidRFC1123(value string) bool

IsValidRFC1123 tests for a string that conforms to the definition of a subdomain in DNS (RFC 1123).

func ListInstallations

func ListInstallations(ctx context.Context, kbClient kbclient.Client) ([]embeddedclusterv1beta1.Installation, error)

func RequiresClusterUpgrade

func RequiresClusterUpgrade(ctx context.Context, kbClient kbclient.Client, kotsKinds *kotsutil.KotsKinds) (bool, error)

RequiresClusterUpgrade returns true if the embedded cluster is in a state that requires an upgrade. This is determined by checking that: - The app has an embedded cluster configuration. - The app embedded cluster configuration differs from the current embedded cluster configuration. - The current cluster config (as part of the Installation object) already exists in the cluster.

func RequiresUpgrade

func RequiresUpgrade(ctx context.Context, kbClient kbclient.Client, newcfg embeddedclusterv1beta1.ConfigSpec) (bool, error)

RequiresUpgrade returns true if the provided configuration differs from the latest active configuration.

func SortRoles

func SortRoles(controllerRole string, inputRoles []string) []string

sort roles by name, but put controller first

func StartClusterUpgrade

func StartClusterUpgrade(ctx context.Context, kotsKinds *kotsutil.KotsKinds, registrySettings registrytypes.RegistrySettings) error

func SyncExec

func SyncExec(coreClient corev1client.CoreV1Interface, clientConfig *rest.Config, ns, pod, container string, command ...string) (int, string, string, error)

SyncExec returns exitcode, stdout, stderr. A non-zero exit code from the command is not considered an error.