k8s

Documentation

Index

• func CheckResourceStatus(clientset kubernetes.Interface, namespace string, ...) bool
• func GenerateMetadatas(source *models.Source, clientset kubernetes.Interface) ([]models.Metadata, error)
• func GetCurrentVersion(source *models.Source, clientset kubernetes.Interface) (*models.Version, error)
• func IsDeployment(kind string) bool
• func IsStatefulSet(kind string) bool
• func NewClientConfig(source *models.Source) clientcmd.ClientConfig
• func NewClientSet(source *models.Source) (kubernetes.Interface, clientcmd.ClientConfig)
• func NewConcourseRESTClientGetter(restConfig *rest.Config, discoveryClient discovery.CachedDiscoveryInterface, ...) genericclioptions.RESTClientGetter
• type ConcourseRESTClientGetter
  • func (f *ConcourseRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
  • func (f *ConcourseRESTClientGetter) ToRESTConfig() (*rest.Config, error)
  • func (f *ConcourseRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)
  • func (f *ConcourseRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig
• type DeploymentReader
  • func NewDeploymentReader(clientset kubernetes.Interface, namespace string, name string) (*DeploymentReader, error)
  • func (r *DeploymentReader) GetObjectMeta() *metav1.ObjectMeta
  • func (r *DeploymentReader) GetRevision() (int64, error)
• type MetadataReader
• type StatefulSetReader
  • func NewStatefulSetReader(clientset kubernetes.Interface, namespace string, name string) (*StatefulSetReader, error)
  • func (r *StatefulSetReader) GetObjectMeta() *metav1.ObjectMeta
  • func (r *StatefulSetReader) GetRevision() (int64, error)

Functions

func CheckResourceStatus

func CheckResourceStatus(clientset kubernetes.Interface, namespace string, resources []models.WatchResource, waitseconds int32) bool

func GenerateMetadatas

func GenerateMetadatas(source *models.Source, clientset kubernetes.Interface) ([]models.Metadata, error)

func GetCurrentVersion

func GetCurrentVersion(source *models.Source, clientset kubernetes.Interface) (*models.Version, error)

func IsDeployment

func IsDeployment(kind string) bool

func IsStatefulSet

func IsStatefulSet(kind string) bool

func NewClientConfig

func NewClientConfig(source *models.Source) clientcmd.ClientConfig

func NewClientSet

func NewClientSet(source *models.Source) (kubernetes.Interface, clientcmd.ClientConfig)

func NewConcourseRESTClientGetter

func NewConcourseRESTClientGetter(restConfig *rest.Config, discoveryClient discovery.CachedDiscoveryInterface,
	clientConfig clientcmd.ClientConfig) genericclioptions.RESTClientGetter

Types

type ConcourseRESTClientGetter

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

func (*ConcourseRESTClientGetter) ToDiscoveryClient

func (f *ConcourseRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

ToDiscoveryClient returns discovery client

func (*ConcourseRESTClientGetter) ToRESTConfig

func (f *ConcourseRESTClientGetter) ToRESTConfig() (*rest.Config, error)

func (*ConcourseRESTClientGetter) ToRESTMapper

func (f *ConcourseRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)

ToRESTMapper returns a restmapper

func (*ConcourseRESTClientGetter) ToRawKubeConfigLoader

func (f *ConcourseRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig

ToRawKubeConfigLoader return kubeconfig loader as-is

type DeploymentReader

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

func NewDeploymentReader

func NewDeploymentReader(clientset kubernetes.Interface, namespace string, name string) (*DeploymentReader, error)

func (*DeploymentReader) GetObjectMeta

func (r *DeploymentReader) GetObjectMeta() *metav1.ObjectMeta

func (*DeploymentReader) GetRevision

func (r *DeploymentReader) GetRevision() (int64, error)

type MetadataReader

type MetadataReader interface {
	GetObjectMeta() *metav1.ObjectMeta
	GetRevision() (int64, error)
}

type StatefulSetReader

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

func NewStatefulSetReader

func NewStatefulSetReader(clientset kubernetes.Interface, namespace string, name string) (*StatefulSetReader, error)

func (*StatefulSetReader) GetObjectMeta

func (r *StatefulSetReader) GetObjectMeta() *metav1.ObjectMeta

func (*StatefulSetReader) GetRevision

func (r *StatefulSetReader) GetRevision() (int64, error)