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) DeleteCluster(ctx context.Context) error
  • func (d *KubernetesManagerDriver) DoUpgrade(ctx context.Context, opniVersion string) error
  • func (d *KubernetesManagerDriver) GetCluster(ctx context.Context) (*loggingadmin.OpensearchClusterV2, error)
  • func (d *KubernetesManagerDriver) GetStorageClasses(ctx context.Context) ([]string, 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) DeleteCluster

func (d *KubernetesManagerDriver) DeleteCluster(ctx context.Context) 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) GetStorageClasses

func (d *KubernetesManagerDriver) GetStorageClasses(ctx context.Context) ([]string, 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"`
}