client

package
v0.0.102 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_internal_runtime_kubernetes_client_clientconfig_proto protoreflect.FileDescriptor

Functions

func IsInclusterClient

func IsInclusterClient(c *k8s.Clientset) bool

func LoadExistingConfiguration added in v0.0.90

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
}

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"`
	// 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 deprecated

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) 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)

type TokenProviderFunc

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL