kubeclient

Documentation

Index

• Constants
• Variables
• func KubeClient(scheme *runtime.Scheme, cfg *rest.Config) (k8sClient client.Client, err error)
• func RuntimeKubeClient(scheme *runtime.Scheme, token *oidc.Token, useToken bool, ...) (cli client.Client, err error)
• type Client
• type ImpersonateClient
• type KubeRuntimeClients
  • func (c *KubeRuntimeClients) Get(uid string) (client client.Client, ok bool)
  • func (c *KubeRuntimeClients) Set(uid string, client client.Client)
• type Properties
• type RuntimeClient
• type TokenizeClient

Constants

const (
	Profile = "kubeclient"
)

const (
	Subject = "subject"
)

Variables

var (
	ErrNilKubeClient = errors.New("kube client is nil, please check if API Server is available")
)

Functions

func KubeClient

func KubeClient(scheme *runtime.Scheme, cfg *rest.Config) (k8sClient client.Client, err error)

KubeClient new kube client

func RuntimeKubeClient

func RuntimeKubeClient(scheme *runtime.Scheme, token *oidc.Token, useToken bool, properties *Properties, cfg *rest.Config) (cli client.Client, err error)

RuntimeKubeClient new runtime kube client

Types

type Client

type Client struct {
	client.Client
}

Client is the encapsulation of the default kube client

type ImpersonateClient

type ImpersonateClient struct {
	at.ContextAware

	client.Client

	Context context.Context `json:"context"`
}

ImpersonateClient is the client impersonate kube client

type KubeRuntimeClients

type KubeRuntimeClients struct {
	// contains filtered or unexported fields
}

func (*KubeRuntimeClients) Get

func (c *KubeRuntimeClients) Get(uid string) (client client.Client, ok bool)

func (*KubeRuntimeClients) Set

func (c *KubeRuntimeClients) Set(uid string, client client.Client)

type Properties

type Properties struct {
	at.ConfigurationProperties `value:"kubeclient"`
	at.AutoWired

	// use DefaultInCluster as default
	DefaultInCluster *bool `json:"defaultInCluster"`

	//OIDC Scope Impersonate
	OIDCScope string `json:"oidcScope"`

	QPS float32 `json:"qps"`

	// Maximum burst for throttle.
	// If it's zero, the created RESTClient will use DefaultBurst: 10.
	Burst int `json:"burst"`

	// The maximum length of time to wait before giving up on a server request. A value of zero means no timeout.
	Timeout time.Duration `json:"timeout"`
}

Properties the operator properties

type RuntimeClient

type RuntimeClient struct {
	at.ContextAware

	client.Client

	Context context.Context `json:"context"`
}

RuntimeClient is the client the runtime kube client

type TokenizeClient

type TokenizeClient struct {
	at.ContextAware

	client.Client

	Context context.Context `json:"context"`
}

TokenizeClient is the client tokenize kube client