Documentation ¶
Index ¶
- func LogClusterDriverFailure(name string, err error)
- func RegisterClusterDriver(driver ClusterDriver)
- func RegisterPersistentClusterDriver(driverFunc func() ClusterDriver)
- func ResetClusterDrivers()
- type ClusterDriver
- type InstallState
- type KubernetesManagerDriver
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LogClusterDriverFailure ¶
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 (*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 (*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
}
Click to show internal directories.
Click to hide internal directories.