v1beta1

package
v0.0.0-...-e2cac0c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 7, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultSchedulerName               = "godel-scheduler"
	DefaultClientConnectionContentType = "application/vnd.kubernetes.protobuf"
	DefaultClientConnectionQPS         = 10000.0
	DefaultClientConnectionBurst       = 10000
	DefaultInsecureBinderPort          = 10451
	// VolumeBindingTimeoutSeconds defines the default bind timeout
	VolumeBindingTimeoutSeconds = 100

	DefaultReservationTimeOutSeconds = 60

	BinderDefaultLockObjectName = "godel-binder"
)
View Source 
const GroupName = "godelbinder.config.kubewharf.io"

GroupName is the group name used in this package

Variables

View Source 
var (

	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1beta1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Convert_config_GodelBinderConfiguration_To_v1beta1_GodelBinderConfiguration 

func Convert_config_GodelBinderConfiguration_To_v1beta1_GodelBinderConfiguration(in *config.GodelBinderConfiguration, out *GodelBinderConfiguration, s conversion.Scope) error

Convert_config_GodelBinderConfiguration_To_v1beta1_GodelBinderConfiguration is an autogenerated conversion function.

func Convert_config_GodelBinderProfile_To_v1beta1_GodelBinderProfile 

func Convert_config_GodelBinderProfile_To_v1beta1_GodelBinderProfile(in *config.GodelBinderProfile, out *GodelBinderProfile, s conversion.Scope) error

Convert_config_GodelBinderProfile_To_v1beta1_GodelBinderProfile is an autogenerated conversion function.

func Convert_config_PluginConfig_To_v1beta1_PluginConfig 

func Convert_config_PluginConfig_To_v1beta1_PluginConfig(in *config.PluginConfig, out *PluginConfig, s conversion.Scope) error

Convert_config_PluginConfig_To_v1beta1_PluginConfig is an autogenerated conversion function.

func Convert_config_Plugin_To_v1beta1_Plugin 

func Convert_config_Plugin_To_v1beta1_Plugin(in *config.Plugin, out *Plugin, s conversion.Scope) error

Convert_config_Plugin_To_v1beta1_Plugin is an autogenerated conversion function.

func Convert_config_Plugins_To_v1beta1_Plugins 

func Convert_config_Plugins_To_v1beta1_Plugins(in *config.Plugins, out *Plugins, s conversion.Scope) error

Convert_config_Plugins_To_v1beta1_Plugins is an autogenerated conversion function.

func Convert_config_VictimCheckingPluginCollection_To_v1beta1_VictimCheckingPluginCollection 

func Convert_config_VictimCheckingPluginCollection_To_v1beta1_VictimCheckingPluginCollection(in *config.VictimCheckingPluginCollection, out *VictimCheckingPluginCollection, s conversion.Scope) error

Convert_config_VictimCheckingPluginCollection_To_v1beta1_VictimCheckingPluginCollection is an autogenerated conversion function.

func Convert_config_VictimCheckingPluginSet_To_v1beta1_VictimCheckingPluginSet 

func Convert_config_VictimCheckingPluginSet_To_v1beta1_VictimCheckingPluginSet(in *config.VictimCheckingPluginSet, out *VictimCheckingPluginSet, s conversion.Scope) error

Convert_config_VictimCheckingPluginSet_To_v1beta1_VictimCheckingPluginSet is an autogenerated conversion function.

func Convert_v1beta1_GodelBinderConfiguration_To_config_GodelBinderConfiguration 

func Convert_v1beta1_GodelBinderConfiguration_To_config_GodelBinderConfiguration(in *GodelBinderConfiguration, out *config.GodelBinderConfiguration, s conversion.Scope) error

Convert_v1beta1_GodelBinderConfiguration_To_config_GodelBinderConfiguration is an autogenerated conversion function.

func Convert_v1beta1_GodelBinderProfile_To_config_GodelBinderProfile 

func Convert_v1beta1_GodelBinderProfile_To_config_GodelBinderProfile(in *GodelBinderProfile, out *config.GodelBinderProfile, s conversion.Scope) error

Convert_v1beta1_GodelBinderProfile_To_config_GodelBinderProfile is an autogenerated conversion function.

func Convert_v1beta1_PluginConfig_To_config_PluginConfig 

func Convert_v1beta1_PluginConfig_To_config_PluginConfig(in *PluginConfig, out *config.PluginConfig, s conversion.Scope) error

Convert_v1beta1_PluginConfig_To_config_PluginConfig is an autogenerated conversion function.

func Convert_v1beta1_Plugin_To_config_Plugin 

func Convert_v1beta1_Plugin_To_config_Plugin(in *Plugin, out *config.Plugin, s conversion.Scope) error

Convert_v1beta1_Plugin_To_config_Plugin is an autogenerated conversion function.

func Convert_v1beta1_Plugins_To_config_Plugins 

func Convert_v1beta1_Plugins_To_config_Plugins(in *Plugins, out *config.Plugins, s conversion.Scope) error

Convert_v1beta1_Plugins_To_config_Plugins is an autogenerated conversion function.

func Convert_v1beta1_VictimCheckingPluginCollection_To_config_VictimCheckingPluginCollection 

func Convert_v1beta1_VictimCheckingPluginCollection_To_config_VictimCheckingPluginCollection(in *VictimCheckingPluginCollection, out *config.VictimCheckingPluginCollection, s conversion.Scope) error

Convert_v1beta1_VictimCheckingPluginCollection_To_config_VictimCheckingPluginCollection is an autogenerated conversion function.

func Convert_v1beta1_VictimCheckingPluginSet_To_config_VictimCheckingPluginSet 

func Convert_v1beta1_VictimCheckingPluginSet_To_config_VictimCheckingPluginSet(in *VictimCheckingPluginSet, out *config.VictimCheckingPluginSet, s conversion.Scope) error

Convert_v1beta1_VictimCheckingPluginSet_To_config_VictimCheckingPluginSet is an autogenerated conversion function.

func RegisterConversions 

func RegisterConversions(s *runtime.Scheme) error

RegisterConversions adds conversion functions to the given scheme. Public to allow building arbitrary schemes.

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

func SetDefaults_GodelBinderConfiguration 

func SetDefaults_GodelBinderConfiguration(cfg *GodelBinderConfiguration)

func SetObjectDefaults_GodelBinderConfiguration 

func SetObjectDefaults_GodelBinderConfiguration(in *GodelBinderConfiguration)

Types

type GodelBinderConfiguration 

type GodelBinderConfiguration struct {
	metav1.TypeMeta `json:",inline"`

	// DebuggingConfiguration holds configuration for Debugging related features
	// TODO: We might wanna make this a substruct like Debugging componentbaseconfig.DebuggingConfiguration
	componentbaseconfig.DebuggingConfiguration `json:"debugging"`

	// ClientConnection specifies the kubeconfig file and client connection
	// settings for the proxy server to use when communicating with the apiserver.
	ClientConnection componentbaseconfig.ClientConnectionConfiguration `json:"clientconnection"`

	// SchedulerName specifies a scheduling system, scheduling components(godel-dispatcher,
	// godel-scheduler, godel-binder) will not accept a pod, unless pod.Spec.SchedulerName == SchedulerName
	SchedulerName *string `json:"schedulerName,omitempty"`

	// LeaderElection defines the configuration of leader election client.
	LeaderElection componentbaseconfig.LeaderElectionConfiguration `json:"leaderElection"`

	// HealthzBindAddress is the IP address and port for the health check server to serve on,
	// defaulting to 0.0.0.0:10451
	HealthzBindAddress string `json:"healthzBindAddress,omitempty"`

	// MetricsBindAddress is the IP address and port for the metrics server to
	// serve on, defaulting to 0.0.0.0:10451.
	MetricsBindAddress string `json:"metricsBindAddress,omitempty"`

	VolumeBindingTimeoutSeconds int64

	// Tracer defines the configuration of tracer
	Tracer *tracing.TracerConfiguration

	// reserved resources will be released after a period of time.
	ReservationTimeOutSeconds int64 `json:"reservationTimeOutSeconds,omitempty"`

	Profile *GodelBinderProfile `json:"profile"`
}

GodelBinderConfiguration configures a godel binder.

func (*GodelBinderConfiguration) DecodeNestedObjects 

func (in *GodelBinderConfiguration) DecodeNestedObjects(d runtime.Decoder) error

DecodeNestedObjects decodes plugin args for known types.

func (*GodelBinderConfiguration) DeepCopy 

func (in *GodelBinderConfiguration) DeepCopy() *GodelBinderConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GodelBinderConfiguration.

func (*GodelBinderConfiguration) DeepCopyInto 

func (in *GodelBinderConfiguration) DeepCopyInto(out *GodelBinderConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GodelBinderConfiguration) DeepCopyObject 

func (in *GodelBinderConfiguration) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*GodelBinderConfiguration) EncodeNestedObjects 

func (in *GodelBinderConfiguration) EncodeNestedObjects(e runtime.Encoder) error

EncodeNestedObjects encodes plugin args.

type GodelBinderProfile 

type GodelBinderProfile struct {
	metav1.TypeMeta `json:",inline"`

	Plugins *Plugins `json:"plugins"`

	// PluginConfigs is an optional set of custom plugin arguments for each plugin.
	// Omitting config args for a plugin is equivalent to using the default config
	// for that plugin.
	PreemptionPluginConfigs []PluginConfig `json:"preemptionPluginConfigs,omitempty"`
	PluginConfigs           []PluginConfig `json:"pluginConfigs,omitempty"`
}

GodelBinderProfile is a scheduling profile.

func (*GodelBinderProfile) DeepCopy 

func (in *GodelBinderProfile) DeepCopy() *GodelBinderProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GodelBinderProfile.

func (*GodelBinderProfile) DeepCopyInto 

func (in *GodelBinderProfile) DeepCopyInto(out *GodelBinderProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GodelBinderProfile) DeepCopyObject 

func (in *GodelBinderProfile) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type Plugin 

type Plugin struct {
	// Name defines the name of plugin
	Name string `json:"name"`
	// Weight defines the weight of plugin, only used for Score plugins.
	Weight int64 `json:"weight,omitempty"`
}

Plugin specifies a plugin name and its weight when applicable. Weight is used only for Score plugins.

func (*Plugin) DeepCopy 

func (in *Plugin) DeepCopy() *Plugin

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Plugin.

func (*Plugin) DeepCopyInto 

func (in *Plugin) DeepCopyInto(out *Plugin)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PluginConfig 

type PluginConfig struct {
	// Name defines the name of plugin being configured
	Name string `json:"name"`
	// Args defines the arguments passed to the plugins at the time of initialization. Args can have arbitrary structure.
	Args runtime.RawExtension `json:"args,omitempty"`
}

PluginConfig specifies arguments that should be passed to a plugin at the time of initialization. A plugin that is invoked at multiple extension points is initialized once. Args can have arbitrary structure. It is up to the plugin to process these Args.

func (*PluginConfig) DecodeNestedObjects 

func (c *PluginConfig) DecodeNestedObjects(d runtime.Decoder) error

func (*PluginConfig) DeepCopy 

func (in *PluginConfig) DeepCopy() *PluginConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PluginConfig.

func (*PluginConfig) DeepCopyInto 

func (in *PluginConfig) DeepCopyInto(out *PluginConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PluginConfig) EncodeNestedObjects 

func (c *PluginConfig) EncodeNestedObjects(e runtime.Encoder) error

type Plugins 

type Plugins struct {
	// Searching is a list of plugins that should be invoked in preemption phase
	VictimChecking *VictimCheckingPluginSet `json:"victimChecking,omitempty"`
}

func (*Plugins) DeepCopy 

func (in *Plugins) DeepCopy() *Plugins

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Plugins.

func (*Plugins) DeepCopyInto 

func (in *Plugins) DeepCopyInto(out *Plugins)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VictimCheckingPluginCollection 

type VictimCheckingPluginCollection struct {
	// if ForceQuickPass is true and result is PreemptionSucceed, return canBePreempted=true directly, no need to execute the rest of the preemption plugins
	ForceQuickPass bool `json:"forceQuickPass,omitempty"`
	// if EnableQuickPass is true and result is PreemptionSucceed, return canBePreempted=true, but need to execute the rest of the preemption plugins
	EnableQuickPass bool `json:"enableQuickPass,omitempty"`
	// PreemptionPlugins specifies preemption plugins in this collection
	Plugins []Plugin `json:"plugins,omitempty"`
}

func (*VictimCheckingPluginCollection) DeepCopy 

func (in *VictimCheckingPluginCollection) DeepCopy() *VictimCheckingPluginCollection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VictimCheckingPluginCollection.

func (*VictimCheckingPluginCollection) DeepCopyInto 

func (in *VictimCheckingPluginCollection) DeepCopyInto(out *VictimCheckingPluginCollection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VictimCheckingPluginSet 

type VictimCheckingPluginSet struct {
	// SearchingPlugins specifies preemption plugin collections that should be used.
	PluginCollections []VictimCheckingPluginCollection `json:"pluginCollections,omitempty"`
}

SearchingPluginSet specifies enabled and disabled plugins for an extension point. If an array is empty, missing, or nil, default plugins at that extension point will be used.

func (*VictimCheckingPluginSet) DeepCopy 

func (in *VictimCheckingPluginSet) DeepCopy() *VictimCheckingPluginSet

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VictimCheckingPluginSet.

func (*VictimCheckingPluginSet) DeepCopyInto 

func (in *VictimCheckingPluginSet) DeepCopyInto(out *VictimCheckingPluginSet)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.