kubernetes

package

v0.6.0 Latest Latest Go to latest Published: Aug 29, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateNamespaceIfNotExists(client client.Client, namespace string) error

func GetAllKubernetesNodeIPAddresses(ctx context.Context, cli client.Client) (map[string]string, error)

GetAllKubernetesNodeIPAddresses returns a mapping of IPAddress -> node_name

func GetClient(restConfig *rest.Config) (client.Client, error)

GetClient returns a controller-runtime client with cass-operator API defined

func NewResourceLock(namespace, lockName string, restConfig *rest.Config) (resourcelock.Interface, error)

func RunLeaderElection(ctx context.Context, wg *sync.WaitGroup, lock resourcelock.Interface)

func WaitForLock(ctx context.Context, namespace string, lockName string, client *NamespacedClient) error

type NamespacedClient struct {
	client.Client
	Config    *rest.Config
	Namespace string
}

NamespacedClient encapsulates namespacedClient with public namespace and restConfig

func GetClientInNamespace(restConfig *rest.Config, namespace string) (NamespacedClient, error)