management

Documentation

Index

• Constants
• type ClusterDriver
• type KubernetesManagerDriver
  • func NewKubernetesManagerDriver(opts ...KubernetesManagerDriverOption) (*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) Name() string
  • func (d *KubernetesManagerDriver) NewOpensearchClientForCluster(ctx context.Context) *opensearch.Client
  • func (d *KubernetesManagerDriver) UpgradeAvailable(ctx context.Context, opniVersion string) (bool, error)
• type KubernetesManagerDriverOption
  • func WithOpensearchCluster(opensearchCluster *opnimeta.OpensearchClusterRef) KubernetesManagerDriverOption
  • func WithRestConfig(restconfig *rest.Config) KubernetesManagerDriverOption
• type KubernetesManagerDriverOptions
• type MockDriver
  • func NewMockDriver(stateTracker *util.MockInstallState) *MockDriver
  • func (d *MockDriver) AdminPassword(_ context.Context) ([]byte, error)
  • func (d *MockDriver) CreateOrUpdateCluster(_ context.Context, cluster *loggingadmin.OpensearchClusterV2, _ string, ...) error
  • func (d *MockDriver) DeleteCluster(_ context.Context) error
  • func (d *MockDriver) DoUpgrade(_ context.Context, _ string) error
  • func (d *MockDriver) GetCluster(_ context.Context) (*loggingadmin.OpensearchClusterV2, error)
  • func (d *MockDriver) GetStorageClasses(context.Context) ([]string, error)
  • func (d *MockDriver) Name() string
  • func (d *MockDriver) NewOpensearchClientForCluster(context.Context) *opensearch.Client
  • func (d *MockDriver) UpgradeAvailable(_ context.Context, _ string) (bool, error)

Constants

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

Types

type ClusterDriver

type ClusterDriver interface {
	Name() string
	AdminPassword(context.Context) ([]byte, error)
	NewOpensearchClientForCluster(context.Context) *opensearch.Client
	GetCluster(context.Context) (*loggingadmin.OpensearchClusterV2, error)
	DeleteCluster(context.Context) error
	CreateOrUpdateCluster(ctx context.Context, cluster *loggingadmin.OpensearchClusterV2, opniVersion string, natsName string) error
	UpgradeAvailable(ctx context.Context, opniVersion string) (bool, error)
	DoUpgrade(ctx context.Context, opniVersion string) error
	GetStorageClasses(context.Context) ([]string, error)
}

type KubernetesManagerDriver

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

func NewKubernetesManagerDriver

func NewKubernetesManagerDriver(opts ...KubernetesManagerDriverOption) (*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) Name

func (d *KubernetesManagerDriver) Name() string

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 KubernetesManagerDriverOption

type KubernetesManagerDriverOption func(*KubernetesManagerDriverOptions)

func WithOpensearchCluster

func WithOpensearchCluster(opensearchCluster *opnimeta.OpensearchClusterRef) KubernetesManagerDriverOption

func WithRestConfig

func WithRestConfig(restconfig *rest.Config) KubernetesManagerDriverOption

type KubernetesManagerDriverOptions

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

type MockDriver

type MockDriver struct {
	// contains filtered or unexported fields
}

func NewMockDriver

func NewMockDriver(stateTracker *util.MockInstallState) *MockDriver

func (*MockDriver) AdminPassword

func (d *MockDriver) AdminPassword(_ context.Context) ([]byte, error)

func (*MockDriver) CreateOrUpdateCluster

func (d *MockDriver) CreateOrUpdateCluster(
	_ context.Context,
	cluster *loggingadmin.OpensearchClusterV2,
	_ string,
	_ string,
) error

func (*MockDriver) DeleteCluster

func (d *MockDriver) DeleteCluster(_ context.Context) error

func (*MockDriver) DoUpgrade

func (d *MockDriver) DoUpgrade(_ context.Context, _ string) error

func (*MockDriver) GetCluster

func (d *MockDriver) GetCluster(_ context.Context) (*loggingadmin.OpensearchClusterV2, error)

func (*MockDriver) GetStorageClasses

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

func (*MockDriver) Name

func (d *MockDriver) Name() string

func (*MockDriver) NewOpensearchClientForCluster

func (d *MockDriver) NewOpensearchClientForCluster(context.Context) *opensearch.Client

func (*MockDriver) UpgradeAvailable

func (d *MockDriver) UpgradeAvailable(_ context.Context, _ string) (bool, error)