Versions in this module Expand all Collapse all v0 v0.0.1 Jul 2, 2024 Changes in this version + const LabelKubeVelaScheduledShardID + const LabelKubeVelaShardID + const MasterShardID + var DefaultScheduler = singleton.NewSingleton[Scheduler](func() Scheduler { ... }) + var DynamicDiscoverySchedulerResyncPeriod = 5 * time.Minute + var EnableSharding bool + var SchedulableShards []string + var ShardID = MasterShardID + func AddControllerFlags(fs *pflag.FlagSet) + func AddFlags(fs *pflag.FlagSet) + func AddSchedulerFlags(fs *pflag.FlagSet) + func BuildCache(scheme *runtime.Scheme, shardingObjects ...client.Object) cache.NewCacheFunc + func BuildCacheWithOptions(opts cache.Options, shardingObjects ...client.Object) cache.NewCacheFunc + func DelScheduledShardID(o client.Object) + func GetScheduledShardID(o client.Object) (string, bool) + func GetShardIDSuffix() string + func IsMaster() bool + func PropagateScheduledShardIDLabel(from client.Object, to client.Object) + func SetScheduledShardID(o client.Object, id string) + type Scheduler interface + Schedule func(client.Object) bool + Start func(context.Context) + func NewDynamicDiscoveryScheduler(name string, resyncPeriod time.Duration) Scheduler + func NewStaticScheduler(shards []string) Scheduler
Go to main page