bucket

Documentation

Overview

Package bucket provides helper functions for Autoscaler buckets. The buckets are used in Leader Election to support multiple Autoscaler pods.

Index

• func AutoscalerBucketName(ordinal, total uint32) string
• func AutoscalerBucketSet(total uint32) *hash.BucketSet
• func ExtractPodNameAndIP(id string) (string, string, error)
• func Identity() (string, error)
• func IsBucketHost(host string) bool
• func PodIP() (string, error)

Functions

func AutoscalerBucketName

func AutoscalerBucketName(ordinal, total uint32) string

AutoscalerBucketName returns the name of the Autoscaler bucket with given `ordinal` and `total` bucket count.

func AutoscalerBucketSet

func AutoscalerBucketSet(total uint32) *hash.BucketSet

AutoscalerBucketSet returns a hash.BucketSet consisting of Autoscaler buckets with the given `total` count.

func ExtractPodNameAndIP

func ExtractPodNameAndIP(id string) (string, string, error)

ExtractPodNameAndIP extracts the pod name and IP from the given Lease holder identity.

func Identity

func Identity() (string, error)

Identity returns a identify for this Autoscaler pod used as the Lease holder identity. It's in the format of <POD-NAME>_<POD-IP> whose information is ready from environment variables.

func IsBucketHost

func IsBucketHost(host string) bool

IsBucketHost returns true if the given host is a host of a K8S Service of a bucket.

func PodIP

func PodIP() (string, error)

PodIP returns the IP address of the current pod, or an error if it wasn't properly projected.