utils

Documentation

Index

• func BuildPeerInformer(stopper chan struct{}, peerRing *ShardHelper, ringConfig consistent.Config, ...) cache.SharedIndexInformer
• func Jitter(t time.Duration, maxJitterPercent int) (time.Duration, error)
• func JitterRequeue(defaultDuration time.Duration, maxJitterPercent int, log logr.Logger) reconcile.Result
• func SliceContains(s []string, value string) bool
• type ShardHelper
  • func BuildPeerHashRing(consistentCfg consistent.Config, podIP string, serviceName string, ...) *ShardHelper
  • func (r *ShardHelper) GetShardOwner(input string) string
  • func (r *ShardHelper) MemberCount() int
  • func (r *ShardHelper) SetMembers(newMembers map[string]struct{})
  • func (r *ShardHelper) SetMembersFromLists(lists ...[]string)
  • func (r *ShardHelper) ShouldOwn(input string) bool

Functions

func BuildPeerInformer

func BuildPeerInformer(stopper chan struct{}, peerRing *ShardHelper, ringConfig consistent.Config, log logr.Logger) cache.SharedIndexInformer

func Jitter

func Jitter(t time.Duration, maxJitterPercent int) (time.Duration, error)

Jitter accepts a Duration and maximum percentage to jitter (as an int), and returns a random Duration in the range t +/- maxJitterPercent.

func JitterRequeue

func JitterRequeue(defaultDuration time.Duration, maxJitterPercent int, log logr.Logger) reconcile.Result

JitterRequeue accepts a default requeue time, a maximum percentage to jitter, and a logger, and returns a Result containing a requeue time which has been randomized with jitter.

func SliceContains

func SliceContains(s []string, value string) bool

Types

type ShardHelper

type ShardHelper struct {
	PodIP            string
	ServiceName      string
	ServiceNamespace string
	// contains filtered or unexported fields
}

func BuildPeerHashRing

func BuildPeerHashRing(consistentCfg consistent.Config, podIP string, serviceName string, serviceNamespace string) *ShardHelper

func (*ShardHelper) GetShardOwner

func (r *ShardHelper) GetShardOwner(input string) string

Returns the name (IP) of the shard which should own a provided object name.

func (*ShardHelper) MemberCount

func (r *ShardHelper) MemberCount() int

Returns the number of members/peers currently in the hash ring.

func (*ShardHelper) SetMembers

func (r *ShardHelper) SetMembers(newMembers map[string]struct{})

SetMembers accepts a map where the keys are member IPs and uses those IPs as the members for sharding.

func (*ShardHelper) SetMembersFromLists

func (r *ShardHelper) SetMembersFromLists(lists ...[]string)

SetMembersFromLists is a wrapper around SetMember which accepts slices instead of a map.

func (*ShardHelper) ShouldOwn

func (r *ShardHelper) ShouldOwn(input string) bool

Returns whether the current shard should own the object with the provided name.