client

Documentation

Index

• Variables
• func IsInclusterClient(c *k8s.Clientset) bool
• func LoadExistingConfiguration(kubeConfig, contextName string) (clientcmd.ClientConfig, error)
• func MakeGroupVersionBasedClient(ctx context.Context, original *rest.Config, gv schema.GroupVersion) (rest.Interface, error)
• func MakeGroupVersionBasedClientAndConfig(ctx context.Context, original *rest.Config, gv schema.GroupVersion) (*rest.Config, rest.Interface, error)
• func NewDiscoveryClient(config *rest.Config, ephemeral bool) (discovery.CachedDiscoveryInterface, error)
• func NewRESTMapper(config *rest.Config, ephemeral bool) (*restmapper.DeferredDiscoveryRESTMapper, error)
• func PollImmediateWithContext(ctx context.Context, interval, timeout time.Duration, ...) error
• func RegisterConfigurationProvider(name string, p ProviderFunc)
• type ClusterConfiguration
  • func (conf ClusterConfiguration) AsResult() *configResult
• type DeferredProvider
• type HostEnv
  • func CheckGetHostEnv(cfg cfg.Configuration) (*HostEnv, error)
  • func NewLocalHostEnv(contextName string, env cfg.Context) *HostEnv
  • func (*HostEnv) Descriptor() ([]byte, []int)
  • func (x *HostEnv) GetBearerTokenProvider() string
  • func (x *HostEnv) GetContext() string
  • func (x *HostEnv) GetIncluster() bool
  • func (x *HostEnv) GetIngressClass() string
  • func (x *HostEnv) GetKubeconfig() string
  • func (x *HostEnv) GetProvider() string
  • func (x *HostEnv) GetStaticConfig() *kubeclient.StaticConfig
  • func (*HostEnv) ProtoMessage()
  • func (x *HostEnv) ProtoReflect() protoreflect.Message
  • func (x *HostEnv) Reset()
  • func (x *HostEnv) String() string
• type Prepared
  • func NewClient(ctx context.Context, cfg cfg.Configuration) (*Prepared, error)
  • func NewClientFromResult(ctx context.Context, hostEnv *HostEnv, computed *configResult) (*Prepared, error)
• type ProviderFunc
• type TokenProviderFunc

Variables

var File_internal_runtime_kubernetes_client_clientconfig_proto protoreflect.FileDescriptor

Functions

func IsInclusterClient

func IsInclusterClient(c *k8s.Clientset) bool

func LoadExistingConfiguration

func LoadExistingConfiguration(kubeConfig, contextName string) (clientcmd.ClientConfig, error)

func MakeGroupVersionBasedClient

func MakeGroupVersionBasedClient(ctx context.Context, original *rest.Config, gv schema.GroupVersion) (rest.Interface, error)

func MakeGroupVersionBasedClientAndConfig

func MakeGroupVersionBasedClientAndConfig(ctx context.Context, original *rest.Config, gv schema.GroupVersion) (*rest.Config, rest.Interface, error)

func NewDiscoveryClient

func NewDiscoveryClient(config *rest.Config, ephemeral bool) (discovery.CachedDiscoveryInterface, error)

func NewRESTMapper

func NewRESTMapper(config *rest.Config, ephemeral bool) (*restmapper.DeferredDiscoveryRESTMapper, error)

func PollImmediateWithContext

func PollImmediateWithContext(ctx context.Context, interval, timeout time.Duration, condition wait.ConditionWithContextFunc) error

func RegisterConfigurationProvider

func RegisterConfigurationProvider(name string, p ProviderFunc)

Types

type ClusterConfiguration

type ClusterConfiguration struct {
	Config                  clientcmdapi.Config
	TokenProvider           TokenProviderFunc
	Ephemeral               bool // Set to true if thie target cluster is ephemeral.
	ProviderSpecific        any  // Up to an implementation to attach state if needed.
	Labels                  []*fnschema.Label
	SupportedIngressClasses []string
}

func (ClusterConfiguration) AsResult

func (conf ClusterConfiguration) AsResult() *configResult

type DeferredProvider

type DeferredProvider struct{}

type HostEnv

type HostEnv struct {
	Kubeconfig          string                   `protobuf:"bytes,1,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	Context             string                   `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` // If empty, uses default context.
	Incluster           bool                     `protobuf:"varint,3,opt,name=incluster,proto3" json:"incluster,omitempty"`
	BearerTokenProvider string                   `protobuf:"bytes,4,opt,name=bearer_token_provider,json=bearerTokenProvider,proto3" json:"bearer_token_provider,omitempty"`
	Provider            string                   `protobuf:"bytes,5,opt,name=provider,proto3" json:"provider,omitempty"` // If set, relies on the specified provider to produce a kube config.
	StaticConfig        *kubeclient.StaticConfig `protobuf:"bytes,6,opt,name=static_config,json=staticConfig,proto3" json:"static_config,omitempty"`
	IngressClass        string                   `protobuf:"bytes,7,opt,name=ingress_class,json=ingressClass,proto3" json:"ingress_class,omitempty"`
	// contains filtered or unexported fields
}

func CheckGetHostEnv

func CheckGetHostEnv(cfg cfg.Configuration) (*HostEnv, error)

func NewLocalHostEnv

func NewLocalHostEnv(contextName string, env cfg.Context) *HostEnv

func (*HostEnv) Descriptor

func (*HostEnv) Descriptor() ([]byte, []int)

Deprecated: Use HostEnv.ProtoReflect.Descriptor instead.

func (*HostEnv) GetBearerTokenProvider

func (x *HostEnv) GetBearerTokenProvider() string

func (*HostEnv) GetContext

func (x *HostEnv) GetContext() string

func (*HostEnv) GetIncluster

func (x *HostEnv) GetIncluster() bool

func (*HostEnv) GetIngressClass

func (x *HostEnv) GetIngressClass() string

func (*HostEnv) GetKubeconfig

func (x *HostEnv) GetKubeconfig() string

func (*HostEnv) GetProvider

func (x *HostEnv) GetProvider() string

func (*HostEnv) GetStaticConfig

func (x *HostEnv) GetStaticConfig() *kubeclient.StaticConfig

func (*HostEnv) ProtoMessage

func (*HostEnv) ProtoMessage()

func (*HostEnv) ProtoReflect

func (x *HostEnv) ProtoReflect() protoreflect.Message

func (*HostEnv) Reset

func (x *HostEnv) Reset()

func (*HostEnv) String

func (x *HostEnv) String() string

type Prepared

type Prepared struct {
	Clientset     *k8s.Clientset
	RESTConfig    *rest.Config
	ClientConfig  clientcmd.ClientConfig
	HostEnv       *HostEnv
	Configuration ClusterConfiguration
}

func NewClient

func NewClient(ctx context.Context, cfg cfg.Configuration) (*Prepared, error)

func NewClientFromResult

func NewClientFromResult(ctx context.Context, hostEnv *HostEnv, computed *configResult) (*Prepared, error)

type ProviderFunc

type ProviderFunc func(context.Context, cfg.Configuration) (ClusterConfiguration, error)

type TokenProviderFunc

type TokenProviderFunc func(context.Context) (string, error)