mirror of
https://github.com/project-zot/zot.git
synced 2024-12-16 21:56:37 -05:00
767f81d4f5
This commit includes support for periodic repo sync in a scale-out cluster. Before this commit, all cluster members would sync all the repos as the config is shared. With this change, in periodic sync, the cluster member checks whether it manages the repo. If it does not manage the repo, it will skip the sync. This commit also includes a unit test to test on-demand sync too, but there are no logic changes for it as it is implicitly handled by the proxying logic. Signed-off-by: Vishwas Rajashekar <vrajashe@cisco.com>
17 lines
645 B
Go
17 lines
645 B
Go
package cluster
|
|
|
|
import "github.com/dchest/siphash"
|
|
|
|
// computes the target member using siphash and returns the index and the member
|
|
// siphash was chosen to prevent against hash attacks where an attacker
|
|
// can target all requests to one given instance instead of balancing across the cluster
|
|
// resulting in a Denial-of-Service (DOS).
|
|
// ref: https://en.wikipedia.org/wiki/SipHash
|
|
func ComputeTargetMember(hashKey string, members []string, repoName string) (uint64, string) {
|
|
h := siphash.New([]byte(hashKey))
|
|
h.Write([]byte(repoName))
|
|
sum64 := h.Sum64()
|
|
targetIdx := sum64 % uint64(len(members))
|
|
|
|
return targetIdx, members[targetIdx]
|
|
}
|