kubegroup

May 23, 2024

Changes in this version

+ func FindMyAddress() (string, error)

type Options

+ Peers PeerSet

+ type PeerSet interface

+ SetPeers func(ctx context.Context, peers []peer.Info) error

Mar 9, 2024

Changes in this version

type Options

+ Client *kubernetes.Clientset

+ ForceNamespaceDefault bool

+ LabelSelector string

+ Logf func(format string, v ...any)

Feb 16, 2024

Changes in this version

type Options

+ ListerInterval time.Duration

Feb 16, 2024

Changes in this version

type Options

+ MetricsGatherer prometheus.Gatherer

+ MetricsNamespace string

+ MetricsRegisterer prometheus.Registerer

Jan 17, 2024

Changes in this version

+ type KubeMockCluster struct

+ func NewKubeMockCluster(myAddr string, addresses []string) *KubeMockCluster

Jan 2, 2024

Changes in this version

+ var DefaultEngine = NewKubeReal()

+ type Group struct

+ func (g *Group) Close()

+ type KubeBogus struct

+ func NewKubeBogus() *KubeBogus

+ type KubeEngine interface

+ type KubeReal struct

+ func NewKubeReal() *KubeReal

type Options

+ Engine KubeEngine

+ type PeerGroup interface

+ Set func(peers ...string)

Nov 14, 2023

Changes in this version

type Options

+ Cooldown time.Duration

+ Debug bool

+ Debugf func(format string, v ...any)

+ Errorf func(format string, v ...any)

+ Fatalf func(format string, v ...any)

Nov 13, 2023

Changes in this version

+ type Options struct

+ GroupCachePort string

+ PodLabelKey string

+ PodLabelValue string

+ Pool *groupcache.HTTPPool

May 21, 2023

Changes in this version

+ func FindMyURL(groupcachePort string) (string, error)

+ func UpdatePeers(pool *groupcache.HTTPPool, groupcachePort string)