k8s

Documentation

Index

• func CreateCertificateX509(ctx context.Context, k8sClient client.Client, name, ns string) error
• func CreateDefaultSecret(ctx context.Context, k8sClient client.Client, name, ns string)
• func CreateNamespace(ctx context.Context, k8sClient client.Client, ns string) error
• func CreateNewClient() (client.Client, error)
• func CreateRandomUserSecret(ctx context.Context, k8sClient client.Client, name, ns string) error
• func CreateSecret(ctx context.Context, k8sClient client.Client, ...) error
• func CreateUserSecret(ctx context.Context, k8sClient client.Client, secret, name, ns string) error
• func DeleteDeployment(ctx context.Context, k8sClient client.Client, ns, name string) error
• func DeleteKey(ctx context.Context, k8sClient client.Client, keyName, ns string) error
• func DeleteNamespace(ctx context.Context, k8sClient client.Client, ns string) error
• func DeploymentListYml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)
• func GetAllDeploymentPods(deploymentName, deploymentNS string) ([]corev1.Pod, error)
• func GetDBUserStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ...) (string, error)
• func GetDeployment(deploymentName, deploymentNS string) (*appsv1.Deployment, error)
• func GetDeploymentObservedGeneration(ctx context.Context, k8sClient client.Client, ns, resourceName string) (int, error)
• func GetDeploymentResource(ctx context.Context, k8sClient client.Client, namespace, rName string) (*v1.AtlasDeployment, error)
• func GetDeploymentStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ...) (string, error)
• func GetK8sDeploymentStateName(ctx context.Context, k8sClient client.Client, ns, rName string) (string, error)
• func GetPodLogs(options corev1.PodLogOptions, ns string, podName string) ([]byte, error)
• func GetPodLogsByDeployment(deploymentName, deploymentNS string, options corev1.PodLogOptions) ([]byte, error)
• func GetPodStatus(ctx context.Context, k8sClient client.Client, ns string) (string, error)
• func GetPodStatusPhaseByLabel(ctx context.Context, k8sClient client.Client, ns, labelKey, labelValue string) (string, error)
• func GetProjectObservedGeneration(ctx context.Context, k8sClient client.Client, ns, resourceName string) (int, error)
• func GetProjectStatusCondition(ctx context.Context, k8sClient client.Client, statusType status.ConditionType, ...) (string, error)
• func ProjectListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)
• func RunOperator(initCfg *Config) (manager.Manager, error)
• func TeamListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)
• func UserListYaml(ctx context.Context, k8sClient client.Client, ns string) ([]byte, error)
• type Config

Functions

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

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

func GetAllDeploymentPods

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

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

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

func GetPodLogsByDeployment

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 RunOperator

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

func TeamListYaml

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

func UserListYaml

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

Types

type Config

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