machinepool

Documentation

Index

• Variables
• func AllWaiter(kubeConf *rest.Config, namespace string, clusterName string, ...) error
• func Flush()
• func ListAll(kubeConf *rest.Config) ([]clusterapiExp.MachinePool, error)
• func NoTableAllWaiter(kubeConf *rest.Config, namespace string, clusterName string) error
• func Ready(mp *clusterapiExp.MachinePool) bool
• func SilentWait(kubeConf *rest.Config, namespace string, name string) error
• func Wait(kubeConf *rest.Config, namespace string, name string) error
• func WaitAll(kubeConf *rest.Config, namespace string, clusterName string) error
• func Waiter(kubeConf *rest.Config, namespace string, name string, ...) error
• func WatchNamespace(ctx context.Context, client MachinePoolInterface, listOps metav1.ListOptions) (watch.Interface, error)
• type MachinePoolInterface
• type MachinePoolV1Beta1Client
  • func NewForConfig(c *rest.Config) (*MachinePoolV1Beta1Client, error)
  • func (c *MachinePoolV1Beta1Client) MachinePools(namespace string) MachinePoolInterface
• type MachinePoolV1Beta1Interface
• type MachinePoolWaiter

Variables

var AddToScheme = localSchemeBuilder.AddToScheme

AddToScheme adds all types of this clientset into the given scheme. This allows composition of clientsets, like in:

import (
  "k8s.io/client-go/kubernetes"
  clientsetscheme "k8s.io/client-go/kubernetes/scheme"
  aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme"
)

kclientset, _ := kubernetes.NewForConfig(c)
_ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme)

After this, RawExtensions in Kubernetes types will serialize kube-aggregator types correctly.

var Codecs = serializer.NewCodecFactory(Scheme)

var ParameterCodec = runtime.NewParameterCodec(Scheme)

var Scheme = runtime.NewScheme()

Functions

func AllWaiter

func AllWaiter(kubeConf *rest.Config, namespace string, clusterName string, timeout func() error) error

func Flush

func Flush()

func ListAll

func ListAll(kubeConf *rest.Config) ([]clusterapiExp.MachinePool, error)

func NoTableAllWaiter

func NoTableAllWaiter(kubeConf *rest.Config, namespace string, clusterName string) error

func Ready

func Ready(mp *clusterapiExp.MachinePool) bool

func SilentWait

func SilentWait(kubeConf *rest.Config, namespace string, name string) error

func Wait

func Wait(kubeConf *rest.Config, namespace string, name string) error

func WaitAll

func WaitAll(kubeConf *rest.Config, namespace string, clusterName string) error

func Waiter

func Waiter(kubeConf *rest.Config, namespace string, name string, mpFunc func(mp *clusterapiExp.MachinePool) (bool, error), timeout func() error) error

func WatchNamespace

func WatchNamespace(ctx context.Context, client MachinePoolInterface, listOps metav1.ListOptions) (watch.Interface, error)

Types

type MachinePoolInterface

type MachinePoolInterface interface {
	List(ctx context.Context, opts metav1.ListOptions) (*clusterapiExp.MachinePoolList, error)
	Get(ctx context.Context, name string, options metav1.GetOptions) (*clusterapiExp.MachinePool, error)
	Create(ctx context.Context, mp *clusterapiExp.MachinePool) (*clusterapiExp.MachinePool, error)
	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
	Update(ctx context.Context, mp *clusterapiExp.MachinePool) (*clusterapiExp.MachinePool, error)
}

type MachinePoolV1Beta1Client

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

func NewForConfig

func NewForConfig(c *rest.Config) (*MachinePoolV1Beta1Client, error)

func (*MachinePoolV1Beta1Client) MachinePools

func (c *MachinePoolV1Beta1Client) MachinePools(namespace string) MachinePoolInterface

type MachinePoolV1Beta1Interface

type MachinePoolV1Beta1Interface interface {
	MachinePools(namespace string) MachinePoolInterface
}

type MachinePoolWaiter

type MachinePoolWaiter interface {
	Init()
	Check(mp *clusterapiExp.MachinePool) bool
}