drivers

Documentation

Index

• func ListClusterDrivers() []string
• 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
  • func (d *KubernetesManagerDriver) SetSyncTime()
• 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 ListClusterDrivers

func ListClusterDrivers() []string

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)
	SetSyncTime()
}

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
	// contains filtered or unexported fields
}

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

func (*KubernetesManagerDriver) SetSyncTime

func (d *KubernetesManagerDriver) SetSyncTime()

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
}