cluster

Documentation

Index

• Constants
• Variables
• func GetNamespaceID(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 GetInstallIDFunc = GetNamespaceID //nolint:gochecknoglobals // extension point

Functions

func GetNamespaceID

func GetNamespaceID(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 installed ns
	ID() string

	// clusterID of the cluster
	ClusterID() 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)

	// SetAdditionalAlsoProxy assigns a slice that will be added to the Routing.AlsoProxySubnets slice
	// when notifications are sent.
	SetAdditionalAlsoProxy(ctx context.Context, subnets []*rpc.IPNet)
}

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.