The highest tagged major version is v2.

k8s

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mongodb/mongodb-atlas-kubernetes

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildManager(initCfg *Config) (manager.Manager, error)
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 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
type ManagerConfig
- func WithAtlasDomain(domain string) ManagerConfig
- func WithGlobalKey(key client.ObjectKey) ManagerConfig
- func WithNamespaces(namespaces ...string) ManagerConfig
- func WithObjectDeletionProtection(flag bool) ManagerConfig
- func WithSubObjectDeletionProtection(flag bool) ManagerConfig
type ManagerStart
- func RunManager(withConfigs ...ManagerConfig) (ManagerStart, error)

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL