k8s

Documentation

Index

• func NewClient(instance *types.Instance, proxyHost string) (*kubernetes.Clientset, error)
• func NewLocalCachedFactory(s storage.StorageApi) *localCachedFactory
• type FactoryApi
• type FactoryMock
  • func (m *FactoryMock) GetForInstance(instance *types.Instance) (*kubernetes.Clientset, error)
  • func (m *FactoryMock) GetKubeletForInstance(i *types.Instance) (*KubeletClient, error)
• type KubeletClient
  • func NewKubeletClient(instance *types.Instance, proxyHost string) (*KubeletClient, error)
  • func (c *KubeletClient) Get(path string) (*http.Response, error)
  • func (c *KubeletClient) IsManager() (bool, error)

Functions

func NewClient

func NewClient(instance *types.Instance, proxyHost string) (*kubernetes.Clientset, error)

func NewLocalCachedFactory

func NewLocalCachedFactory(s storage.StorageApi) *localCachedFactory

Types

type FactoryApi

type FactoryApi interface {
	GetForInstance(instance *types.Instance) (*kubernetes.Clientset, error)
	GetKubeletForInstance(instance *types.Instance) (*KubeletClient, error)
}

type FactoryMock

type FactoryMock struct {
	mock.Mock
}

func (*FactoryMock) GetForInstance

func (m *FactoryMock) GetForInstance(instance *types.Instance) (*kubernetes.Clientset, error)

func (*FactoryMock) GetKubeletForInstance

func (m *FactoryMock) GetKubeletForInstance(i *types.Instance) (*KubeletClient, error)

type KubeletClient

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

func NewKubeletClient

func NewKubeletClient(instance *types.Instance, proxyHost string) (*KubeletClient, error)

func (*KubeletClient) Get

func (c *KubeletClient) Get(path string) (*http.Response, error)

func (*KubeletClient) IsManager

func (c *KubeletClient) IsManager() (bool, error)