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
- type ExternalPromOperatorDriverOption
- type ExternalPromOperatorDriverOptions
- type MetricsNodeDriver
- type MetricsNodeDriverBuilder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ListNodeDrivers ¶ added in v0.6.2
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 ¶ added in v0.9.2
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 ¶ added in v0.8.2
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)
Click to show internal directories.
Click to hide internal directories.