kubernetes_manager

Documentation

Index

• Constants
• type DefaultIndices
  • func (d DefaultIndices) RemoveFromSlice(in []string) []string
  • func (d DefaultIndices) Slice() []string
• 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) CreateOrUpdateSnapshot(ctx context.Context, snapshot *loggingadmin.Snapshot) error
  • func (d *KubernetesManagerDriver) DeleteCluster(ctx context.Context) error
  • func (d *KubernetesManagerDriver) DeleteSnapshot(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) GetRecurringSnapshot(ctx context.Context, ref *loggingadmin.SnapshotReference) (*loggingadmin.Snapshot, error)
  • func (d *KubernetesManagerDriver) GetStorageClasses(ctx context.Context) ([]string, error)
  • func (d *KubernetesManagerDriver) ListAllSnapshots(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 DefaultIndices

type DefaultIndices map[string]bool

func (DefaultIndices) RemoveFromSlice

func (d DefaultIndices) RemoveFromSlice(in []string) []string

func (DefaultIndices) Slice

func (d DefaultIndices) Slice() []string

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) CreateOrUpdateSnapshot

func (d *KubernetesManagerDriver) CreateOrUpdateSnapshot(ctx context.Context, snapshot *loggingadmin.Snapshot) error

func (*KubernetesManagerDriver) DeleteCluster

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

func (*KubernetesManagerDriver) DeleteSnapshot

func (d *KubernetesManagerDriver) DeleteSnapshot(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) GetRecurringSnapshot

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

func (*KubernetesManagerDriver) GetStorageClasses

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

func (*KubernetesManagerDriver) ListAllSnapshots

func (d *KubernetesManagerDriver) ListAllSnapshots(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            *zap.SugaredLogger
}