v1alpha1

Documentation

Index

• func ConvertSchedulingUnit(su *framework.SchedulingUnit) *schedwebhookv1a1.SchedulingUnit
• type HTTPClient
• type WebhookPlugin
  • func NewWebhookPlugin(name string, urlPrefix string, filterPath string, scorePath string, ...) *WebhookPlugin
  • func (p *WebhookPlugin) Filter(ctx context.Context, su *framework.SchedulingUnit, ...) *framework.Result
  • func (p *WebhookPlugin) Name() string
  • func (p *WebhookPlugin) NormalizeScore(ctx context.Context, scores framework.ClusterScoreList) *framework.Result
  • func (p *WebhookPlugin) Score(ctx context.Context, su *framework.SchedulingUnit, ...) (int64, *framework.Result)
  • func (p *WebhookPlugin) ScoreExtensions() framework.ScoreExtensions
  • func (p *WebhookPlugin) SelectClusters(ctx context.Context, su *framework.SchedulingUnit, ...) (framework.ClusterScoreList, *framework.Result)

Functions

func ConvertSchedulingUnit

func ConvertSchedulingUnit(su *framework.SchedulingUnit) *schedwebhookv1a1.SchedulingUnit

Types

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type WebhookPlugin

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

func NewWebhookPlugin

func NewWebhookPlugin(
	name string,
	urlPrefix string,
	filterPath string,
	scorePath string,
	selectPath string,
	client HTTPClient,
) *WebhookPlugin

func (*WebhookPlugin) Filter

func (p *WebhookPlugin) Filter(
	ctx context.Context,
	su *framework.SchedulingUnit,
	cluster *fedcorev1a1.FederatedCluster,
) *framework.Result

func (*WebhookPlugin) Name

func (p *WebhookPlugin) Name() string

func (*WebhookPlugin) NormalizeScore

func (p *WebhookPlugin) NormalizeScore(ctx context.Context, scores framework.ClusterScoreList) *framework.Result

func (*WebhookPlugin) Score

func (p *WebhookPlugin) Score(
	ctx context.Context,
	su *framework.SchedulingUnit,
	cluster *fedcorev1a1.FederatedCluster,
) (int64, *framework.Result)

func (*WebhookPlugin) ScoreExtensions

func (p *WebhookPlugin) ScoreExtensions() framework.ScoreExtensions

func (*WebhookPlugin) SelectClusters

func (p *WebhookPlugin) SelectClusters(
	ctx context.Context,
	su *framework.SchedulingUnit,
	clusterScores framework.ClusterScoreList,
) (framework.ClusterScoreList, *framework.Result)