Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const Domain + const Project + func ComputeKeyRange(keyspaceSize, podCount, podIndex int) (int, int) + type EnvironmentShardStrategy struct + EnvType environmentType + PerShardIDs [][]string + func (e *EnvironmentShardStrategy) GetPodCount() int + func (e *EnvironmentShardStrategy) HashCode() (uint32, error) + func (e *EnvironmentShardStrategy) UpdatePodSpec(pod *v1.PodSpec, containerName string, podIndex int) error + type HashShardStrategy struct + ShardCount int + func (h *HashShardStrategy) GetPodCount() int + func (h *HashShardStrategy) HashCode() (uint32, error) + func (h *HashShardStrategy) UpdatePodSpec(pod *v1.PodSpec, containerName string, podIndex int) error + type ShardStrategy interface + GetPodCount func() int + HashCode func() (uint32, error) + UpdatePodSpec func(pod *v1.PodSpec, containerName string, podIndex int) error + func NewShardStrategy(ctx context.Context, shardConfig config.ShardConfig) (ShardStrategy, error)