k8sclient

Documentation

Index

• func CanI(ctx context.Context, ra *v1.ResourceAttributes) (bool, error)
• func CanPortForward(ctx context.Context, namespace string) bool
• func CanWatchNamespaces(ctx context.Context) bool
• func ConnectToAgent(ctx context.Context, podName, namespace string, port uint16) (*grpc.ClientConn, agent.AgentClient, *manager.VersionInfo2, error)
• func ConnectToManager(ctx context.Context, namespace string) (*grpc.ClientConn, manager.ManagerClient, *manager.VersionInfo2, error)
• func GetK8sConfig(ctx context.Context) *rest.Config
• func WithK8sConfig(ctx context.Context, k8sConfig *rest.Config) context.Context

Functions

func CanI

func CanI(ctx context.Context, ra *v1.ResourceAttributes) (bool, error)

func CanPortForward

func CanPortForward(ctx context.Context, namespace string) bool

CanPortForward answers the question if this client has the RBAC permissions necessary to perform a port-forward to the connected namespace.

func CanWatchNamespaces

func CanWatchNamespaces(ctx context.Context) bool

CanWatchNamespaces answers the question if this client has the RBAC permissions necessary to watch namespaces. The answer is likely false when using a namespaces scoped installation.

func ConnectToAgent

func ConnectToAgent(
	ctx context.Context,
	podName, namespace string,
	port uint16,
) (*grpc.ClientConn, agent.AgentClient, *manager.VersionInfo2, error)

func ConnectToManager

func ConnectToManager(ctx context.Context, namespace string) (*grpc.ClientConn, manager.ManagerClient, *manager.VersionInfo2, error)

func GetK8sConfig

func GetK8sConfig(ctx context.Context) *rest.Config

func WithK8sConfig

func WithK8sConfig(ctx context.Context, k8sConfig *rest.Config) context.Context