sharding

package

v1.8.0-alpha.1 Latest Latest Go to latest Published: Jan 31, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/oam-dev/kubevela

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddFlags(fs *pflag.FlagSet)
func BuildCache(scheme *runtime.Scheme, 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
- func NewDynamicDiscoveryScheduler(name string, resyncPeriod time.Duration) Scheduler
- func NewStaticScheduler(shards []string) Scheduler

Constants ¶

View Source

const (
	// LabelKubeVelaShardID label key for identify the shard id for the controller
	LabelKubeVelaShardID = "controller.core.oam.dev/shard-id"
	// LabelKubeVelaScheduledShardID label key for identify the scheduled shard id for the resource
	LabelKubeVelaScheduledShardID = "controller.core.oam.dev/scheduled-shard-id"
	// MasterShardID the master shard id
	MasterShardID = "master"
)

Variables ¶

View Source

var (
	// ShardID the id of the shard
	ShardID = MasterShardID
	// EnableSharding whether enable sharding
	EnableSharding bool
	// SchedulableShards the shards for schedule
	SchedulableShards []string
	// DynamicDiscoverySchedulerResyncPeriod resync period for default dynamic discovery scheduler
	DynamicDiscoverySchedulerResyncPeriod = 5 * time.Minute
)

View Source

var DefaultApplicationScheduler = singleton.NewSingleton[Scheduler](func() Scheduler {
	SchedulableShards = velaslices.Filter(SchedulableShards, func(s string) bool { return len(s) > 0 })
	if len(SchedulableShards) > 0 {
		klog.Infof("staticScheduler initialized")
		return NewStaticScheduler(SchedulableShards)
	}
	klog.Infof("dynamicDiscoveryScheduler initialized")
	return NewDynamicDiscoveryScheduler(types.VelaCoreName, DynamicDiscoverySchedulerResyncPeriod)
})

DefaultApplicationScheduler default application scheduler

Functions ¶

func AddFlags ¶

func AddFlags(fs *pflag.FlagSet)

AddFlags add sharding flags

func BuildCache ¶

func BuildCache(scheme *runtime.Scheme, shardingObjects ...client.Object) cache.NewCacheFunc

BuildCache add shard-id label selector for given typed object

func DelScheduledShardID ¶

func DelScheduledShardID(o client.Object)

DelScheduledShardID delete shard-id from target object

func GetScheduledShardID ¶

func GetScheduledShardID(o client.Object) (string, bool)

GetScheduledShardID return the scheduled shard-id of the object and if it is scheduled

func GetShardIDSuffix ¶

func GetShardIDSuffix() string

GetShardIDSuffix return suffix for shard id if enabled

func IsMaster ¶

func IsMaster() bool

IsMaster check if current instance is master

func PropagateScheduledShardIDLabel ¶

func PropagateScheduledShardIDLabel(from client.Object, to client.Object)

PropagateScheduledShardIDLabel copy the shard-id from source obj to target obj, remove if not exist

func SetScheduledShardID ¶

func SetScheduledShardID(o client.Object, id string)

SetScheduledShardID set shard-id to target object

Types ¶

type Scheduler ¶

type Scheduler interface {
	Start(context.Context)
	Schedule(client.Object) bool
}

Scheduler schedule shard-id for object

func NewDynamicDiscoveryScheduler ¶

func NewDynamicDiscoveryScheduler(name string, resyncPeriod time.Duration) Scheduler

NewDynamicDiscoveryScheduler create a scheduler that allow dynamic discovery for available shards

func NewStaticScheduler ¶

func NewStaticScheduler(shards []string) Scheduler

NewStaticScheduler create a scheduler that do not make update but only use predefined shards for allocate

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL