k8s

Documentation

Index

• Constants
• func GetK8sClientConfig(kubeConfig []byte) (*rest.Config, error)
• func NewClientByContent(kubeConfig []byte, k8sWrapTransport WrapTransport) (*kubernetes.Clientset, error)
• func NewClientByFile(kubeConfigPath string, k8sWrapTransport WrapTransport) (*kubernetes.Clientset, error)
• type SKubeClusterManager
  • func NewKubeClusterManager(region string, interval time.Duration) *SKubeClusterManager
  • func (man *SKubeClusterManager) GetK8sClient() (*kubernetes.Clientset, error)
  • func (man *SKubeClusterManager) GetK8sConfig() string
  • func (man *SKubeClusterManager) Start()
• type WrapTransport

Constants

const (
	K8sWrapTransportTimeout = 30
)

Functions

func GetK8sClientConfig

func GetK8sClientConfig(kubeConfig []byte) (*rest.Config, error)

func NewClientByContent

func NewClientByContent(kubeConfig []byte, k8sWrapTransport WrapTransport) (*kubernetes.Clientset, error)

func NewClientByFile

func NewClientByFile(kubeConfigPath string, k8sWrapTransport WrapTransport) (*kubernetes.Clientset, error)

Types

type SKubeClusterManager

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

func NewKubeClusterManager

func NewKubeClusterManager(region string, interval time.Duration) *SKubeClusterManager

func (*SKubeClusterManager) GetK8sClient

func (man *SKubeClusterManager) GetK8sClient() (*kubernetes.Clientset, error)

func (*SKubeClusterManager) GetK8sConfig

func (man *SKubeClusterManager) GetK8sConfig() string

func (*SKubeClusterManager) Start

func (man *SKubeClusterManager) Start()

type WrapTransport

type WrapTransport func(rt http.RoundTripper) http.RoundTripper