kubernetes_manager

Documentation

Index

• Constants
• type KubernetesManagerDriver
  • func NewKubernetesManagerDriver(options KubernetesManagerDriverOptions) (*KubernetesManagerDriver, error)
  • func (d *KubernetesManagerDriver) AdminPassword(ctx context.Context) (password []byte, retErr error)
  • func (d *KubernetesManagerDriver) CreateOrUpdateCluster(ctx context.Context, cluster *loggingadmin.OpensearchClusterV2, ...) error
  • func (d *KubernetesManagerDriver) CreateOrUpdateSnapshotSchedule(ctx context.Context, snapshot *loggingadmin.SnapshotSchedule, ...) error
  • func (d *KubernetesManagerDriver) DeleteCluster(ctx context.Context) error
  • func (d *KubernetesManagerDriver) DeleteSnapshotSchedule(ctx context.Context, ref *loggingadmin.SnapshotReference) error
  • func (d *KubernetesManagerDriver) DoUpgrade(ctx context.Context, opniVersion string) error
  • func (d *KubernetesManagerDriver) GetCluster(ctx context.Context) (*loggingadmin.OpensearchClusterV2, error)
  • func (d *KubernetesManagerDriver) GetSnapshotSchedule(ctx context.Context, ref *loggingadmin.SnapshotReference, ...) (*loggingadmin.SnapshotSchedule, error)
  • func (d *KubernetesManagerDriver) GetStorageClasses(ctx context.Context) ([]string, error)
  • func (d *KubernetesManagerDriver) ListAllSnapshotSchedules(ctx context.Context) (*loggingadmin.SnapshotStatusList, error)
  • func (d *KubernetesManagerDriver) NewOpensearchClientForCluster(ctx context.Context) *opensearch.Client
  • func (d *KubernetesManagerDriver) UpgradeAvailable(ctx context.Context, opniVersion string) (bool, error)
• type KubernetesManagerDriverOptions

Constants

const (
	LabelOpsterCluster  = "opster.io/opensearch-cluster"
	LabelOpsterNodePool = "opster.io/opensearch-nodepool"
	LabelOpniNodeGroup  = "opni.io/node-group"
	TopologyKeyK8sHost  = "kubernetes.io/hostname"
)

Types

type KubernetesManagerDriver

type KubernetesManagerDriver struct {
	KubernetesManagerDriverOptions
}

func NewKubernetesManagerDriver

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

func (*KubernetesManagerDriver) AdminPassword

func (d *KubernetesManagerDriver) AdminPassword(ctx context.Context) (password []byte, retErr error)

func (*KubernetesManagerDriver) CreateOrUpdateCluster

func (d *KubernetesManagerDriver) CreateOrUpdateCluster(
	ctx context.Context,
	cluster *loggingadmin.OpensearchClusterV2,
	opniVersion string,
	natName string,
) error

func (*KubernetesManagerDriver) CreateOrUpdateSnapshotSchedule

func (d *KubernetesManagerDriver) CreateOrUpdateSnapshotSchedule(
	ctx context.Context,
	snapshot *loggingadmin.SnapshotSchedule,
	defaultIndices []string,
) error

func (*KubernetesManagerDriver) DeleteCluster

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

func (*KubernetesManagerDriver) DeleteSnapshotSchedule

func (d *KubernetesManagerDriver) DeleteSnapshotSchedule(ctx context.Context, ref *loggingadmin.SnapshotReference) error

func (*KubernetesManagerDriver) DoUpgrade

func (d *KubernetesManagerDriver) DoUpgrade(ctx context.Context, opniVersion string) error

func (*KubernetesManagerDriver) GetCluster

func (d *KubernetesManagerDriver) GetCluster(ctx context.Context) (*loggingadmin.OpensearchClusterV2, error)

func (*KubernetesManagerDriver) GetSnapshotSchedule

func (d *KubernetesManagerDriver) GetSnapshotSchedule(
	ctx context.Context,
	ref *loggingadmin.SnapshotReference,
	defaultIndices []string,
) (*loggingadmin.SnapshotSchedule, error)

func (*KubernetesManagerDriver) GetStorageClasses

func (d *KubernetesManagerDriver) GetStorageClasses(ctx context.Context) ([]string, error)

func (*KubernetesManagerDriver) ListAllSnapshotSchedules

func (d *KubernetesManagerDriver) ListAllSnapshotSchedules(ctx context.Context) (*loggingadmin.SnapshotStatusList, error)

func (*KubernetesManagerDriver) NewOpensearchClientForCluster

func (d *KubernetesManagerDriver) NewOpensearchClientForCluster(ctx context.Context) *opensearch.Client

func (*KubernetesManagerDriver) UpgradeAvailable

func (d *KubernetesManagerDriver) UpgradeAvailable(ctx context.Context, opniVersion string) (bool, error)

type KubernetesManagerDriverOptions

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