embeddedcluster

package
v1.122.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SeaweedfsNamespace = "seaweedfs"
	SeaweedfsS3SVCName = "ec-seaweedfs-s3"
)
View Source 
const DEFAULT_CONTROLLER_ROLE_NAME = "controller"

Variables

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

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

Functions

func ClusterConfig added in v1.104.2 

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 added in v1.104.2 

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 added in v1.108.1 

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 added in v1.104.5 

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

GetCurrentInstallation returns the most recent installation object from the cluster.

func GetEndpointsToCheck added in v1.121.2 

func GetEndpointsToCheck(ctx context.Context, client kbclient.Client, roles []string) ([]string, error)

GetendpointsToCheck returns the list of endpoints that should be checked by a node joining the cluster based on the array of roles the node will have

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 GetPreviousInstallation added in v1.121.2 

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

GetCurrentInstallation returns the second most recent installation object from the cluster.

func GetRoles added in v1.104.2 

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

GetRoles will get a list of role names

func GetSeaweedFSS3ServiceIP added in v1.109.12 

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

func InstallationFailed added in v1.112.0 

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

func InstallationSucceeded added in v1.112.0 

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

func IsHA 

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

func IsValidRFC1123 added in v1.108.1 

func IsValidRFC1123(value string) bool

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

func ListInstallations added in v1.108.0 

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

func NotifyUpgradeFailed added in v1.121.2 

func NotifyUpgradeFailed(ctx context.Context, baseURL string, ins, prev *embeddedclusterv1beta1.Installation, reason string) error

NotifyUpgradeFailed notifies the metrics server that an upgrade has failed.

func NotifyUpgradeStarted added in v1.121.2 

func NotifyUpgradeStarted(ctx context.Context, baseURL string, ins, prev *embeddedclusterv1beta1.Installation, versionLabel string) error

NotifyUpgradeStarted notifies the metrics server that an upgrade has started.

func NotifyUpgradeSucceeded added in v1.121.2 

func NotifyUpgradeSucceeded(ctx context.Context, baseURL string, ins, prev *embeddedclusterv1beta1.Installation) error

NotifyUpgradeSucceeded notifies the metrics server that an upgrade has succeeded.

func RequiresClusterUpgrade added in v1.112.0 

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 added in v1.104.5 

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 added in v1.104.2 

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

sort roles by name, but put controller first

func StartClusterUpgrade added in v1.112.0 

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.

Types

type UpgradeFailedEvent added in v1.121.2 

type UpgradeFailedEvent struct {
	ClusterID      string `json:"clusterID"`
	TargetVersion  string `json:"targetVersion"`
	InitialVersion string `json:"initialVersion"`
	Reason         string `json:"reason"`
}

UpgradeFailedEvent is send back home when the upgrade fails.

type UpgradeStartedEvent added in v1.121.2 

type UpgradeStartedEvent struct {
	ClusterID      string `json:"clusterID"`
	TargetVersion  string `json:"targetVersion"`
	InitialVersion string `json:"initialVersion"`
	AppVersion     string `json:"appVersion"`
}

UpgradeStartedEvent is send back home when the upgrade starts.

type UpgradeSucceededEvent added in v1.121.2 

type UpgradeSucceededEvent struct {
	ClusterID      string `json:"clusterID"`
	TargetVersion  string `json:"targetVersion"`
	InitialVersion string `json:"initialVersion"`
}

UpgradeSucceededEvent event is send back home when the upgrade succeeds.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.