cluster

Documentation

Index

• Constants
• Variables
• func GetID(ctx context.Context, client v1.CoreV1Interface, namespace string) (string, error)
• type Info
  • func NewInfo(ctx context.Context) Info
• type PodLister

Constants

const IDZero = "00000000-0000-0000-0000-000000000000"

Variables

var GetIDFunc = GetID //nolint:gochecknoglobals // extension point

Functions

func GetID

func GetID(ctx context.Context, client v1.CoreV1Interface, namespace string) (string, error)

Types

type Info

type Info interface {
	// Watch changes of an ClusterInfo and write them on the given stream
	Watch(context.Context, rpc.Manager_WatchClusterInfoServer) error

	// ID of the cluster
	ID() string

	// GetTrafficManagerPods acquires all pods that have `traffic-manager` in
	// their name
	GetTrafficManagerPods(context.Context) ([]*corev1.Pod, error)

	// GetTrafficAgentPods acquires all pods that have a `traffic-agent`
	// container in their spec
	GetTrafficAgentPods(context.Context, string) ([]*corev1.Pod, error)
}

func NewInfo

func NewInfo(ctx context.Context) Info

type PodLister

type PodLister interface {
	// List lists all Pods in the indexer.
	// Objects returned here must be treated as read-only.
	List(selector labels.Selector) (ret []*corev1.Pod, err error)
}

PodLister helps list Pods. All objects returned here must be treated as read-only.