sharding

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: May 6, 2026 License: Apache-2.0 Imports: 9 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsShardAMatch

func IsShardAMatch(shardKey string, cluster client.Object) bool

IsShardAMatch returns true if a cluster is a shard match.

func RegisterClusterShard

func RegisterClusterShard(ctx context.Context, c client.Client, component libsveltosv1beta1.Component,
	feature, shard, clusterNamespace, clusterName string, clusterType libsveltosv1beta1.ClusterType) (bool, error)

RegisterClusterShard register a cluster,shard pair. feature is a string representing the entity requesting the tracking. component indicates the sveltos component requesting it. returns a bool indicating whether the cluster:shard pair has changed and an error if any occurred

func UnregisterClusterShard added in v1.9.0

func UnregisterClusterShard(ctx context.Context, c client.Client, component libsveltosv1beta1.Component,
	feature, clusterNamespace, clusterName string, clusterType libsveltosv1beta1.ClusterType) error

UnregisterClusterShard removes the cluster entry from the shard-tracking ConfigMap. Call this when a cluster is fully deleted so stale entries do not accumulate.

Types

This section is empty.

Jump to

Keyboard shortcuts

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