▽

Package remotesampler

Constants

const (
    DefaultMaxConcurrentRequestsPerInstance = 50
    DefaultPercentageOfClustersToSample     = 33
)

const (
    PluginName = "RemoteNodesSampler"
)

func NewRemoteNodesSamplerPlugin ¶

func NewRemoteNodesSamplerPlugin(pluginConfig config.PluginConfig, scheduler pipeline.PolarisScheduler) (pipeline.Plugin, error)

type RemoteNodesSamplerPlugin ¶

This SampleNodesPlugin contacts a remote sampling services to get the nodes sample.

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

func (*RemoteNodesSamplerPlugin) Name ¶

func (rs *RemoteNodesSamplerPlugin) Name() string

func (*RemoteNodesSamplerPlugin) SampleNodes ¶

func (rs *RemoteNodesSamplerPlugin) SampleNodes(ctx pipeline.SchedulingContext, podInfo *pipeline.PodInfo) ([]*pipeline.NodeInfo, pipeline.Status)

type RemoteNodesSamplerPluginConfig ¶

Configuration data for the RemoteNodesSamplerPlugin.

The remoteClusters configured in the SchedulerConfig are used as sampling targets.

type RemoteNodesSamplerPluginConfig struct {

    // The sampling strategy that should be used.
    // This endpoint must be supported by all remove samplers.
    SamplingStrategy string `json:"samplingStrategy" yaml:"samplingStrategy"`

    // The maximum number of concurrent requests to remote samplers that a single instance of the plugin may make.
    //
    // Default: 50
    MaxConcurrentRequestsPerInstance int32 `json:"maxConcurrentRequestsPerInstance" yaml:"maxConcurrentRequestsPerInstance"`

    // Defines the percentage (from 1-100) of all clusters that should be sampled for a pod.
    //
    // Default: 33
    PercentageOfClustersToSample int32 `json:"percentageOfClustersToSample" yaml:"percentageOfClustersToSample"`
}