k8s

package
v1.9.3 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildManager added in v1.8.2 

func BuildManager(initCfg *Config) (manager.Manager, error)

func CreateCertificateX509 

func CreateCertificateX509(ctx context.Context, k8sClient client.Client, name, ns string) error

func CreateDefaultSecret 

func CreateDefaultSecret(ctx context.Context, k8sClient client.Client, name, ns string)

func CreateNamespace 

func CreateNamespace(ctx context.Context, k8sClient client.Client, ns string) error

func CreateNewClient 

func CreateNewClient() (client.Client, error)

func CreateRandomUserSecret 

func CreateRandomUserSecret(ctx context.Context, k8sClient client.Client, name, ns string) error

func CreateSecret 

func CreateSecret(ctx context.Context, k8sClient client.Client, publicKey, privateKey, name, ns string) error

func CreateUserSecret 

func CreateUserSecret(ctx context.Context, k8sClient client.Client, secret, name, ns string) error

func DeleteDeployment 

func DeleteDeployment(ctx context.Context, k8sClient client.Client, ns, name string) error

func DeleteKey 

func DeleteKey(ctx context.Context, k8sClient client.Client, keyName, ns string) error

func DeleteNamespace 

func DeleteNamespace(ctx context.Context, k8sClient client.Client, ns string) error

func DeploymentListYml added in v1.5.0 

func DeploymentListYml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)

func GetAllDeploymentPods added in v1.7.0 

func GetAllDeploymentPods(deploymentName, deploymentNS string) ([]corev1.Pod, error)

func GetDBUserStatusCondition 

func GetDBUserStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ns string, name string) (string, error)

func GetDeployment added in v1.7.0 

func GetDeployment(deploymentName, deploymentNS string) (*appsv1.Deployment, error)

func GetDeploymentObservedGeneration 

func GetDeploymentObservedGeneration(ctx context.Context, k8sClient client.Client, ns, resourceName string) (int, error)

func GetDeploymentResource 

func GetDeploymentResource(ctx context.Context, k8sClient client.Client, namespace, rName string) (*v1.AtlasDeployment, error)

func GetDeploymentStatusCondition 

func GetDeploymentStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ns string, name string) (string, error)

func GetK8sDeploymentStateName 

func GetK8sDeploymentStateName(ctx context.Context, k8sClient client.Client, ns, rName string) (string, error)

func GetPodLogs added in v1.7.0 

func GetPodLogs(options corev1.PodLogOptions, ns string, podName string) ([]byte, error)

func GetPodLogsByDeployment added in v1.7.0 

func GetPodLogsByDeployment(deploymentName, deploymentNS string, options corev1.PodLogOptions) ([]byte, error)

func GetPodStatus 

func GetPodStatus(ctx context.Context, k8sClient client.Client, ns string) (string, error)

GetPodStatus status.phase

func GetPodStatusPhaseByLabel 

func GetPodStatusPhaseByLabel(ctx context.Context, k8sClient client.Client, ns, labelKey, labelValue string) (string, error)

func GetProjectObservedGeneration 

func GetProjectObservedGeneration(ctx context.Context, k8sClient client.Client, ns, resourceName string) (int, error)

func GetProjectStatusCondition 

func GetProjectStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ns string, name string) (string, error)

func ProjectListYaml 

func ProjectListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)

func TeamListYaml added in v1.6.0 

func TeamListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)

func UserListYaml added in v1.6.0 

func UserListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)

Types

type Config added in v1.6.0 

type Config struct {
	AtlasDomain                 string
	EnableLeaderElection        bool
	MetricsAddr                 string
	Namespace                   string
	WatchedNamespaces           map[string]bool
	ProbeAddr                   string
	GlobalAPISecret             client.ObjectKey
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
}

type ManagerConfig added in v1.8.2 

type ManagerConfig func(config *Config)

func WithAtlasDomain added in v1.9.0 

func WithAtlasDomain(domain string) ManagerConfig

func WithGlobalKey added in v1.8.2 

func WithGlobalKey(key client.ObjectKey) ManagerConfig

func WithNamespaces added in v1.8.2 

func WithNamespaces(namespaces ...string) ManagerConfig

func WithObjectDeletionProtection added in v1.8.2 

func WithObjectDeletionProtection(flag bool) ManagerConfig

func WithSubObjectDeletionProtection added in v1.8.2 

func WithSubObjectDeletionProtection(flag bool) ManagerConfig

type ManagerStart added in v1.8.2 

type ManagerStart func(ctx context.Context) error

func RunManager added in v1.8.2 

func RunManager(withConfigs ...ManagerConfig) (ManagerStart, error)

Source Files

View all Source files

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.