drivers

Documentation

Index

• func ListNodeDrivers() []string
• func NewListenerFunc(ctx context.Context, fn func(nodeId string, cfg *node.MetricsCapabilityConfig)) chan<- ConfigureNodeArgs
• func RegisterNodeDriverBuilder(name string, fn MetricsNodeDriverBuilder)
• func UnregisterNodeDriverBuilder(name string)
• type ConfigureNodeArgs
• type ExternalPromOperatorDriver
  • func NewExternalPromOperatorDriver(logger *zap.SugaredLogger, opts ...ExternalPromOperatorDriverOption) (*ExternalPromOperatorDriver, error)
  • func (d *ExternalPromOperatorDriver) ConfigureNode(_ string, conf *node.MetricsCapabilityConfig)
  • func (d *ExternalPromOperatorDriver) DiscoverPrometheuses(ctx context.Context, namespace string) ([]*remoteread.DiscoveryEntry, error)
• type ExternalPromOperatorDriverOption
  • func WithK8sClient(k8sClient client.Client) ExternalPromOperatorDriverOption
• type ExternalPromOperatorDriverOptions
• type MetricsNodeDriver
• type MetricsNodeDriverBuilder
  • func GetNodeDriverBuilder(name string) (MetricsNodeDriverBuilder, bool)

Functions

func ListNodeDrivers

func ListNodeDrivers() []string

func NewListenerFunc

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

func RegisterNodeDriverBuilder

func RegisterNodeDriverBuilder(name string, fn MetricsNodeDriverBuilder)

func UnregisterNodeDriverBuilder

func UnregisterNodeDriverBuilder(name string)

Types

type ConfigureNodeArgs

type ConfigureNodeArgs struct {
	NodeId string
	Config *node.MetricsCapabilityConfig
}

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(_ string, conf *node.MetricsCapabilityConfig)

func (*ExternalPromOperatorDriver) DiscoverPrometheuses

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

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 {
	ConfigureNode(nodeId string, conf *node.MetricsCapabilityConfig)
	DiscoverPrometheuses(context.Context, string) ([]*remoteread.DiscoveryEntry, error)
}

type MetricsNodeDriverBuilder

type MetricsNodeDriverBuilder = func() (MetricsNodeDriver, error)

func GetNodeDriverBuilder

func GetNodeDriverBuilder(name string) (MetricsNodeDriverBuilder, bool)