drivers

Documentation

Index

• func ListNodeDrivers() []string
• func LogNodeDriverFailure(name string, err error)
• func NewListenerFunc(ctx context.Context, fn func(cfg *node.MetricsCapabilityConfig)) chan<- *node.MetricsCapabilityConfig
• func RegisterNodeDriver(driver MetricsNodeDriver)
• func ResetNodeDrivers()
• type EmbeddedManagerNodeDriver
  • func NewEmbeddedManagerNodeDriver(logger *zap.SugaredLogger, opts ...EmbeddedManagerNodeDriverOption) (*EmbeddedManagerNodeDriver, error)
  • func (d *EmbeddedManagerNodeDriver) ConfigureNode(_ *node.MetricsCapabilityConfig)
  • func (d *EmbeddedManagerNodeDriver) DiscoverPrometheuses(_ context.Context, _ string) ([]*remoteread.DiscoveryEntry, error)
  • func (d *EmbeddedManagerNodeDriver) Name() string
• type EmbeddedManagerNodeDriverOption
  • func WithRestConfig(restConfig *rest.Config) EmbeddedManagerNodeDriverOption
• type EmbeddedManagerNodeDriverOptions
• type ExternalPromOperatorDriver
  • func NewExternalPromOperatorDriver(logger *zap.SugaredLogger, opts ...ExternalPromOperatorDriverOption) (*ExternalPromOperatorDriver, error)
  • func (d *ExternalPromOperatorDriver) ConfigureNode(conf *node.MetricsCapabilityConfig)
  • func (d *ExternalPromOperatorDriver) DiscoverPrometheuses(ctx context.Context, namespace string) ([]*remoteread.DiscoveryEntry, error)
  • func (*ExternalPromOperatorDriver) Name() string
• type ExternalPromOperatorDriverOption
  • func WithK8sClient(k8sClient client.Client) ExternalPromOperatorDriverOption
• type ExternalPromOperatorDriverOptions
• type MetricsNodeDriver
  • func GetNodeDriver(name string) (MetricsNodeDriver, error)

Functions

func ListNodeDrivers

func ListNodeDrivers() []string

func LogNodeDriverFailure

func LogNodeDriverFailure(name string, err error)

func NewListenerFunc

func NewListenerFunc(ctx context.Context, fn func(cfg *node.MetricsCapabilityConfig)) chan<- *node.MetricsCapabilityConfig

func RegisterNodeDriver

func RegisterNodeDriver(driver MetricsNodeDriver)

func ResetNodeDrivers

func ResetNodeDrivers()

Types

type EmbeddedManagerNodeDriver

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

func NewEmbeddedManagerNodeDriver

func NewEmbeddedManagerNodeDriver(
	logger *zap.SugaredLogger,
	opts ...EmbeddedManagerNodeDriverOption,
) (*EmbeddedManagerNodeDriver, error)

func (*EmbeddedManagerNodeDriver) ConfigureNode

func (d *EmbeddedManagerNodeDriver) ConfigureNode(_ *node.MetricsCapabilityConfig)

func (*EmbeddedManagerNodeDriver) DiscoverPrometheuses

func (d *EmbeddedManagerNodeDriver) DiscoverPrometheuses(_ context.Context, _ string) ([]*remoteread.DiscoveryEntry, error)

func (*EmbeddedManagerNodeDriver) Name

func (d *EmbeddedManagerNodeDriver) Name() string

type EmbeddedManagerNodeDriverOption

type EmbeddedManagerNodeDriverOption func(*EmbeddedManagerNodeDriverOptions)

func WithRestConfig

func WithRestConfig(restConfig *rest.Config) EmbeddedManagerNodeDriverOption

type EmbeddedManagerNodeDriverOptions

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

type ExternalPromOperatorDriver

type ExternalPromOperatorDriver struct {
	ExternalPromOperatorDriverOptions
	// contains filtered or unexported fields
}

func NewExternalPromOperatorDriver

func NewExternalPromOperatorDriver(
	logger *zap.SugaredLogger,
	opts ...ExternalPromOperatorDriverOption,
) (*ExternalPromOperatorDriver, error)

func (*ExternalPromOperatorDriver) ConfigureNode

func (d *ExternalPromOperatorDriver) ConfigureNode(conf *node.MetricsCapabilityConfig)

func (*ExternalPromOperatorDriver) DiscoverPrometheuses

func (d *ExternalPromOperatorDriver) DiscoverPrometheuses(ctx context.Context, namespace string) ([]*remoteread.DiscoveryEntry, error)

func (*ExternalPromOperatorDriver) Name

func (*ExternalPromOperatorDriver) Name() string

type ExternalPromOperatorDriverOption

type ExternalPromOperatorDriverOption func(*ExternalPromOperatorDriverOptions)

func WithK8sClient

func WithK8sClient(k8sClient client.Client) ExternalPromOperatorDriverOption

type ExternalPromOperatorDriverOptions

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

type MetricsNodeDriver

type MetricsNodeDriver interface {
	Name() string
	ConfigureNode(*node.MetricsCapabilityConfig)
	DiscoverPrometheuses(context.Context, string) ([]*remoteread.DiscoveryEntry, error)
}

func GetNodeDriver

func GetNodeDriver(name string) (MetricsNodeDriver, error)