kubernetes_manager

Documentation

Index

• type KubernetesManagerDriver
  • func NewKubernetesManagerDriver(options KubernetesManagerDriverOptions) (*KubernetesManagerDriver, error)
  • func (d *KubernetesManagerDriver) DeleteCluster(ctx context.Context, id string) error
  • func (d *KubernetesManagerDriver) GetClusterStatus(ctx context.Context, id string) (*capabilityv1.NodeCapabilityStatus, error)
  • func (d *KubernetesManagerDriver) GetInstallStatus(ctx context.Context) backend.InstallState
  • func (d *KubernetesManagerDriver) SetClusterStatus(ctx context.Context, id string, enabled bool) error
  • func (d *KubernetesManagerDriver) SetSyncTime()
  • func (d *KubernetesManagerDriver) StoreCluster(ctx context.Context, req *corev1.Reference, friendlyName string) error
  • func (d *KubernetesManagerDriver) StoreClusterMetadata(ctx context.Context, id, name string) error
  • func (d *KubernetesManagerDriver) StoreClusterReadUser(ctx context.Context, username, password, id string) error
• type KubernetesManagerDriverOptions

Types

type KubernetesManagerDriver

type KubernetesManagerDriver struct {
	KubernetesManagerDriverOptions
	// contains filtered or unexported fields
}

func NewKubernetesManagerDriver

func NewKubernetesManagerDriver(options KubernetesManagerDriverOptions) (*KubernetesManagerDriver, error)

func (*KubernetesManagerDriver) DeleteCluster

func (d *KubernetesManagerDriver) DeleteCluster(ctx context.Context, id string) error

func (*KubernetesManagerDriver) GetClusterStatus

func (d *KubernetesManagerDriver) GetClusterStatus(ctx context.Context, id string) (*capabilityv1.NodeCapabilityStatus, error)

func (*KubernetesManagerDriver) GetInstallStatus

func (d *KubernetesManagerDriver) GetInstallStatus(ctx context.Context) backend.InstallState

func (*KubernetesManagerDriver) SetClusterStatus

func (d *KubernetesManagerDriver) SetClusterStatus(ctx context.Context, id string, enabled bool) error

func (*KubernetesManagerDriver) SetSyncTime

func (d *KubernetesManagerDriver) SetSyncTime()

func (*KubernetesManagerDriver) StoreCluster

func (d *KubernetesManagerDriver) StoreCluster(ctx context.Context, req *corev1.Reference, friendlyName string) error

func (*KubernetesManagerDriver) StoreClusterMetadata

func (d *KubernetesManagerDriver) StoreClusterMetadata(ctx context.Context, id, name string) error

func (*KubernetesManagerDriver) StoreClusterReadUser

func (d *KubernetesManagerDriver) StoreClusterReadUser(ctx context.Context, username, password, id string) error

type KubernetesManagerDriverOptions

type KubernetesManagerDriverOptions struct {
	K8sClient         client.Client                  `option:"k8sClient"`
	Namespace         string                         `option:"namespace"`
	OpensearchCluster *opnimeta.OpensearchClusterRef `option:"opensearchCluster"`
	Logger            *slog.Logger                   `option:"logger"`
}