k8sclient

Documentation

Index

• func GetRestConfig(clusterName string) (*rest.Config, error)
• type K8sClient
  • func New(clusterName string, ops ...Option) (*K8sClient, error)
  • func NewForInCluster(ops ...Option) (*K8sClient, error)
  • func NewForRestConfig(c *rest.Config, ops ...Option) (*K8sClient, error)
  • func NewWithTimeOut(clusterName string, timeout time.Duration) (*K8sClient, error)
• type Option
  • func WithPreferredToUseInClusterConfig() Option
  • func WithSchemes(schemes ...func(scheme *runtime.Scheme) error) Option
  • func WithTimeout(timeout time.Duration) Option

Functions

func GetRestConfig

func GetRestConfig(clusterName string) (*rest.Config, error)

GetRestConfig get rest config with clusterName

Types

type K8sClient

type K8sClient struct {

	// client for kubernetes
	ClientSet kubernetes.Interface
	CRClient  client.Client
	// contains filtered or unexported fields
}

func New

func New(clusterName string, ops ...Option) (*K8sClient, error)

New new K8sClient with clusterName.

func NewForInCluster

func NewForInCluster(ops ...Option) (*K8sClient, error)

NewForInCluster New client for in cluster

func NewForRestConfig

func NewForRestConfig(c *rest.Config, ops ...Option) (*K8sClient, error)

NewForRestConfig new K8sClient with rest.Config, you can register your custom runtime.Scheme.

func NewWithTimeOut

func NewWithTimeOut(clusterName string, timeout time.Duration) (*K8sClient, error)

NewWithTimeOut new k8sClient with timeout

type Option

type Option func(*K8sClient)

func WithPreferredToUseInClusterConfig

func WithPreferredToUseInClusterConfig() Option

WithPreferredToUseInClusterConfig set whether priority to use in cluster config if not set this option, we will get and use config set by cluster agent

func WithSchemes

func WithSchemes(schemes ...func(scheme *runtime.Scheme) error) Option

func WithTimeout

func WithTimeout(timeout time.Duration) Option