drivers

Documentation

Index

• func LogClusterDriverFailure(name string, err error)
• func RegisterClusterDriver(driver ClusterDriver)
• func RegisterPersistentClusterDriver(driverFunc func() ClusterDriver)
• func ResetClusterDrivers()
• type ClusterDriver
  • func GetClusterDriver(name string) (ClusterDriver, error)
• type InstallState
• type KubernetesManagerDriver
  • func NewKubernetesManagerDriver(opts ...KubernetesManagerDriverOption) (*KubernetesManagerDriver, error)
  • func (d *KubernetesManagerDriver) CreateCredentials(ctx context.Context, req *opnicorev1.Reference) error
  • func (d *KubernetesManagerDriver) GetClusterStatus(ctx context.Context, id string) (*capabilityv1.NodeCapabilityStatus, error)
  • func (d *KubernetesManagerDriver) GetCredentials(ctx context.Context, id string) (username string, password string)
  • func (d *KubernetesManagerDriver) GetExternalURL(ctx context.Context) string
  • func (d *KubernetesManagerDriver) GetInstallStatus(ctx context.Context) InstallState
  • func (d *KubernetesManagerDriver) Name() string
  • func (d *KubernetesManagerDriver) SetClusterStatus(ctx context.Context, id string, enabled bool) error
• type KubernetesManagerDriverOption
  • func WithK8sClient(k8sClient client.Client) KubernetesManagerDriverOption
  • func WithLogger(logger zap.SugaredLogger) KubernetesManagerDriverOption
  • func WithNamespace(namespace string) KubernetesManagerDriverOption
  • func WithOpensearchCluster(opensearchCluster *opnimeta.OpensearchClusterRef) KubernetesManagerDriverOption
• type KubernetesManagerDriverOptions

Functions

func LogClusterDriverFailure

func LogClusterDriverFailure(name string, err error)

func RegisterClusterDriver

func RegisterClusterDriver(driver ClusterDriver)

func RegisterPersistentClusterDriver

func RegisterPersistentClusterDriver(driverFunc func() ClusterDriver)

func ResetClusterDrivers

func ResetClusterDrivers()

Types

type ClusterDriver

type ClusterDriver interface {
	Name() string
	CreateCredentials(context.Context, *corev1.Reference) error
	GetCredentials(context.Context, string) (username string, password string)
	GetExternalURL(context.Context) string
	GetInstallStatus(context.Context) InstallState
	SetClusterStatus(context.Context, string, bool) error
	GetClusterStatus(context.Context, string) (*capabilityv1.NodeCapabilityStatus, error)
}

func GetClusterDriver

func GetClusterDriver(name string) (ClusterDriver, error)

type InstallState

type InstallState int

const (
	Pending InstallState = iota
	Installed
	Absent
	Error
)

type KubernetesManagerDriver

type KubernetesManagerDriver struct {
	KubernetesManagerDriverOptions
}

func NewKubernetesManagerDriver

func NewKubernetesManagerDriver(opts ...KubernetesManagerDriverOption) (*KubernetesManagerDriver, error)

func (*KubernetesManagerDriver) CreateCredentials

func (d *KubernetesManagerDriver) CreateCredentials(ctx context.Context, req *opnicorev1.Reference) error

func (*KubernetesManagerDriver) GetClusterStatus

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

func (*KubernetesManagerDriver) GetCredentials

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

func (*KubernetesManagerDriver) GetExternalURL

func (d *KubernetesManagerDriver) GetExternalURL(ctx context.Context) string

func (*KubernetesManagerDriver) GetInstallStatus

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

func (*KubernetesManagerDriver) Name

func (d *KubernetesManagerDriver) Name() string

func (*KubernetesManagerDriver) SetClusterStatus

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

type KubernetesManagerDriverOption

type KubernetesManagerDriverOption func(*KubernetesManagerDriverOptions)

func WithK8sClient

func WithK8sClient(k8sClient client.Client) KubernetesManagerDriverOption

func WithLogger

func WithLogger(logger zap.SugaredLogger) KubernetesManagerDriverOption

func WithNamespace

func WithNamespace(namespace string) KubernetesManagerDriverOption

func WithOpensearchCluster

func WithOpensearchCluster(opensearchCluster *opnimeta.OpensearchClusterRef) KubernetesManagerDriverOption

type KubernetesManagerDriverOptions

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