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 NoopClusterDriver
  • func (d *NoopClusterDriver) Name() string
  • func (d *NoopClusterDriver) ShouldDisableNode(*corev1.Reference) error
• type OpniManager
  • func NewOpniManagerClusterDriver(opts ...OpniManagerClusterDriverOption) (*OpniManager, error)
  • func (k *OpniManager) ConfigureCluster(ctx context.Context, conf *cortexops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (k *OpniManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*cortexops.ClusterConfiguration, error)
  • func (k *OpniManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*cortexops.InstallStatus, error)
  • func (k *OpniManager) Name() string
  • func (k *OpniManager) ShouldDisableNode(_ *corev1.Reference) error
  • func (k *OpniManager) UninstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
• type OpniManagerClusterDriverOption
  • func WithGatewayRef(gatewayRef types.NamespacedName) OpniManagerClusterDriverOption
  • func WithK8sClient(k8sClient client.Client) OpniManagerClusterDriverOption
  • func WithMonitoringCluster(namespacedName types.NamespacedName) OpniManagerClusterDriverOption
• type OpniManagerClusterDriverOptions

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 {
	cortexops.CortexOpsServer
	// Unique name of the driver
	Name() string
	// ShouldDisableNode is called during node sync for nodes which otherwise
	// have this capability enabled. If this function returns an error, the
	// node will be set to disabled instead, and the error will be logged.
	ShouldDisableNode(*corev1.Reference) error
}

func GetClusterDriver

func GetClusterDriver(name string) (ClusterDriver, error)

type NoopClusterDriver

type NoopClusterDriver struct {
	cortexops.UnimplementedCortexOpsServer
}

func (*NoopClusterDriver) Name

func (d *NoopClusterDriver) Name() string

func (*NoopClusterDriver) ShouldDisableNode

func (d *NoopClusterDriver) ShouldDisableNode(*corev1.Reference) error

type OpniManager

type OpniManager struct {
	OpniManagerClusterDriverOptions
	cortexops.UnsafeCortexOpsServer
}

func NewOpniManagerClusterDriver

func NewOpniManagerClusterDriver(opts ...OpniManagerClusterDriverOption) (*OpniManager, error)

func (*OpniManager) ConfigureCluster

func (k *OpniManager) ConfigureCluster(ctx context.Context, conf *cortexops.ClusterConfiguration) (*emptypb.Empty, error)

func (*OpniManager) GetClusterConfiguration

func (k *OpniManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*cortexops.ClusterConfiguration, error)

func (*OpniManager) GetClusterStatus

func (k *OpniManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*cortexops.InstallStatus, error)

func (*OpniManager) Name

func (k *OpniManager) Name() string

func (*OpniManager) ShouldDisableNode

func (k *OpniManager) ShouldDisableNode(_ *corev1.Reference) error

func (*OpniManager) UninstallCluster

func (k *OpniManager) UninstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

type OpniManagerClusterDriverOption

type OpniManagerClusterDriverOption func(*OpniManagerClusterDriverOptions)

func WithGatewayRef

func WithGatewayRef(gatewayRef types.NamespacedName) OpniManagerClusterDriverOption

func WithK8sClient

func WithK8sClient(k8sClient client.Client) OpniManagerClusterDriverOption

func WithMonitoringCluster

func WithMonitoringCluster(namespacedName types.NamespacedName) OpniManagerClusterDriverOption

type OpniManagerClusterDriverOptions

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