k8s

Documentation

Index

• Variables
• func Is404(err error) bool
• func K8SClient(kr *mesh.KRun) *kubernetes.Clientset
• type K8S
  • func (kr *K8S) GetCM(ctx context.Context, ns string, name string) (map[string]string, error)
  • func (kr *K8S) GetSecret(ctx context.Context, ns string, name string) (map[string][]byte, error)
  • func (kr *K8S) GetToken(ctx context.Context, aud string) (string, error)
  • func (kr *K8S) K8SClient(ctx context.Context) error

Variables

var Debug = true

Functions

func Is404

func Is404(err error) bool

func K8SClient

func K8SClient(kr *mesh.KRun) *kubernetes.Clientset

Types

type K8S

type K8S struct {
	Mesh   *mesh.KRun
	Client *kubernetes.Clientset
}

func (*K8S) GetCM

func (kr *K8S) GetCM(ctx context.Context, ns string, name string) (map[string]string, error)

func (*K8S) GetSecret

func (kr *K8S) GetSecret(ctx context.Context, ns string, name string) (map[string][]byte, error)

func (*K8S) GetToken

func (kr *K8S) GetToken(ctx context.Context, aud string) (string, error)

GetToken returns a token with the given audience for the current KSA, using CreateToken request. Used by the STS token exchanger.

func (*K8S) K8SClient

func (kr *K8S) K8SClient(ctx context.Context) error

K8SClient will discover a K8S config cluster and return the client