Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + const Interval + const MaxRetries + const Timeout + func AbortRollingUpdate(c *RollingUpdaterConfig) + func AddDeploymentKeyToReplicationController(oldRc *api.ReplicationController, client client.Interface, ...) (*api.ReplicationController, error) + func AddJsonFilenameFlag(cmd *cobra.Command, value *util.StringList, usage string) + func CreateNewControllerFromCurrentController(c *client.Client, namespace, oldName, newName, image, deploymentKey string) (*api.ReplicationController, error) + func DescribableResources() []string + func DescribeEvents(el *api.EventList, w io.Writer) + func FindSourceController(r RollingUpdaterClient, namespace, name string) (*api.ReplicationController, error) + func GetApiVersions(w io.Writer, kubeClient client.Interface) + func GetClientVersion(w io.Writer) + func GetNextControllerAnnotation(rc *api.ReplicationController) (string, bool) + func GetVersion(w io.Writer, kubeClient client.Interface) + func IsNoSuchReaperError(err error) bool + func LoadExistingNextReplicationController(c *client.Client, namespace, newName string) (*api.ReplicationController, error) + func MakeLabels(labels map[string]string) string + func MakeParams(cmd *cobra.Command, params []GeneratorParam) map[string]string + func ParseLabels(labelString string) (map[string]string, error) + func Rename(c RollingUpdaterClient, rc *api.ReplicationController, newName string) error + func ScaleCondition(r Scaler, precondition *ScalePrecondition, namespace, name string, count uint) wait.ConditionFunc + func SetNextControllerAnnotation(rc *api.ReplicationController, name string) + func UpdateExistingReplicationController(c client.Interface, oldRc *api.ReplicationController, ...) (*api.ReplicationController, error) + func ValidateParams(paramSpec []GeneratorParam, params map[string]string) error + func WatchLoop(w watch.Interface, fn func(watch.Event) error) + type BasicReplicationController struct + func (BasicReplicationController) Generate(params map[string]string) (runtime.Object, error) + func (BasicReplicationController) ParamNames() []GeneratorParam + type ControllerScaleError struct + ActualError error + FailureType ControllerScaleErrorType + ResourceVersion string + func (c ControllerScaleError) Error() string + type ControllerScaleErrorType int + const ControllerScaleGetFailure + const ControllerScaleUpdateFailure + type Describer interface + Describe func(namespace, name string) (output string, err error) + func DescriberFor(kind string, c *client.Client) (Describer, bool) + type Describers struct + func (d *Describers) Add(fns ...interface{}) error + func (d *Describers) DescribeObject(exact interface{}, extra ...interface{}) (string, error) + type ErrNoDescriber struct + Types []string + func (e ErrNoDescriber) Error() string + type Generator interface + Generate func(params map[string]string) (runtime.Object, error) + ParamNames func() []GeneratorParam + type GeneratorParam struct + Name string + Required bool + type HumanReadablePrinter struct + func NewHumanReadablePrinter(noHeaders, withNamespace bool) *HumanReadablePrinter + func (h *HumanReadablePrinter) HandledResources() []string + func (h *HumanReadablePrinter) Handler(columns []string, printFunc interface{}) error + func (h *HumanReadablePrinter) PrintObj(obj runtime.Object, output io.Writer) error + type JSONPrinter struct + func (p *JSONPrinter) PrintObj(obj runtime.Object, w io.Writer) error + type LimitRangeDescriber struct + func (d *LimitRangeDescriber) Describe(namespace, name string) (string, error) + type NamespaceInfo struct + Namespace string + type NoSuchReaperError struct + func (n *NoSuchReaperError) Error() string + type NodeDescriber struct + func (d *NodeDescriber) Describe(namespace, name string) (string, error) + type ObjectDescriber interface + DescribeObject func(object interface{}, extra ...interface{}) (output string, err error) + var DefaultObjectDescriber ObjectDescriber + type OutputVersionMapper struct + OutputVersion string + func (m OutputVersionMapper) RESTMapping(kind string, versions ...string) (*meta.RESTMapping, error) + type PersistentVolumeClaimDescriber struct + func (d *PersistentVolumeClaimDescriber) Describe(namespace, name string) (string, error) + type PersistentVolumeDescriber struct + func (d *PersistentVolumeDescriber) Describe(namespace, name string) (string, error) + type PodDescriber struct + func (d *PodDescriber) Describe(namespace, name string) (string, error) + type PodReaper struct + func (reaper *PodReaper) Stop(namespace, name string, timeout time.Duration, gracePeriod *api.DeleteOptions) (string, error) + type PreconditionError struct + ActualValue string + ExpectedValue string + Precondition string + func (pe PreconditionError) Error() string + type ProxyServer struct + func NewProxyServer(filebase string, apiProxyPrefix string, staticPrefix string, ...) (*ProxyServer, error) + func (s *ProxyServer) Serve(port int) error + type RESTClient interface + Delete func() *client.Request + Get func() *client.Request + Post func() *client.Request + Put func() *client.Request + type Reaper interface + Stop func(namespace, name string, timeout time.Duration, gracePeriod *api.DeleteOptions) (string, error) + func ReaperFor(kind string, c client.Interface) (Reaper, error) + func ReaperForReplicationController(c client.Interface, timeout time.Duration) (Reaper, error) + type ReplicationControllerDescriber struct + func (d *ReplicationControllerDescriber) Describe(namespace, name string) (string, error) + type ReplicationControllerReaper struct + func (reaper *ReplicationControllerReaper) Stop(namespace, name string, timeout time.Duration, gracePeriod *api.DeleteOptions) (string, error) + type ReplicationControllerScaler struct + func (scaler *ReplicationControllerScaler) Scale(namespace, name string, newSize uint, preconditions *ScalePrecondition, ...) error + func (scaler *ReplicationControllerScaler) ScaleSimple(namespace, name string, preconditions *ScalePrecondition, newSize uint) (string, error) + type ResourcePrinter interface + PrintObj func(runtime.Object, io.Writer) error + func GetPrinter(format, formatArgument string) (ResourcePrinter, bool, error) + func NewVersionedPrinter(printer ResourcePrinter, convertor runtime.ObjectConvertor, version ...string) ResourcePrinter + type ResourcePrinterFunc func(runtime.Object, io.Writer) error + func (fn ResourcePrinterFunc) PrintObj(obj runtime.Object, w io.Writer) error + type ResourceQuotaDescriber struct + func (d *ResourceQuotaDescriber) Describe(namespace, name string) (string, error) + type RetryParams struct + Interval time.Duration + Timeout time.Duration + func NewRetryParams(interval, timeout time.Duration) *RetryParams + type RollingUpdater struct + func NewRollingUpdater(namespace string, c RollingUpdaterClient) *RollingUpdater + func (r *RollingUpdater) Update(config *RollingUpdaterConfig) error + type RollingUpdaterCleanupPolicy string + const DeleteRollingUpdateCleanupPolicy + const PreserveRollingUpdateCleanupPolicy + const RenameRollingUpdateCleanupPolicy + type RollingUpdaterClient interface + ControllerHasDesiredReplicas func(rc *api.ReplicationController) wait.ConditionFunc + CreateReplicationController func(namespace string, rc *api.ReplicationController) (*api.ReplicationController, error) + DeleteReplicationController func(namespace, name string) error + GetReplicationController func(namespace, name string) (*api.ReplicationController, error) + ListReplicationControllers func(namespace string, selector labels.Selector) (*api.ReplicationControllerList, error) + UpdateReplicationController func(namespace string, rc *api.ReplicationController) (*api.ReplicationController, error) + func NewRollingUpdaterClient(c client.Interface) RollingUpdaterClient + type RollingUpdaterConfig struct + CleanupPolicy RollingUpdaterCleanupPolicy + Interval time.Duration + NewRc *api.ReplicationController + OldRc *api.ReplicationController + Out io.Writer + Timeout time.Duration + UpdatePeriod time.Duration + type ScalePrecondition struct + ResourceVersion string + Size int + func (precondition *ScalePrecondition) Validate(controller *api.ReplicationController) error + type Scaler interface + Scale func(namespace, name string, newSize uint, preconditions *ScalePrecondition, ...) error + ScaleSimple func(namespace, name string, preconditions *ScalePrecondition, newSize uint) (string, error) + func ScalerFor(kind string, c ScalerClient) (Scaler, error) + type ScalerClient interface + ControllerHasDesiredReplicas func(rc *api.ReplicationController) wait.ConditionFunc + GetReplicationController func(namespace, name string) (*api.ReplicationController, error) + UpdateReplicationController func(namespace string, rc *api.ReplicationController) (*api.ReplicationController, error) + func NewScalerClient(c client.Interface) ScalerClient + type SecretDescriber struct + func (d *SecretDescriber) Describe(namespace, name string) (string, error) + type ServiceAccountDescriber struct + func (d *ServiceAccountDescriber) Describe(namespace, name string) (string, error) + type ServiceDescriber struct + func (d *ServiceDescriber) Describe(namespace, name string) (string, error) + type ServiceGenerator struct + func (ServiceGenerator) Generate(params map[string]string) (runtime.Object, error) + func (ServiceGenerator) ParamNames() []GeneratorParam + type ServiceReaper struct + func (reaper *ServiceReaper) Stop(namespace, name string, timeout time.Duration, gracePeriod *api.DeleteOptions) (string, error) + type ShortcutExpander struct + func (e ShortcutExpander) VersionAndKindForResource(resource string) (defaultVersion, kind string, err error) + type SortableEvents []api.Event + func (list SortableEvents) Len() int + func (list SortableEvents) Less(i, j int) bool + func (list SortableEvents) Swap(i, j int) + type SortableResourceNames []api.ResourceName + func (list SortableResourceNames) Len() int + func (list SortableResourceNames) Less(i, j int) bool + func (list SortableResourceNames) Swap(i, j int) + type TemplatePrinter struct + func NewTemplatePrinter(tmpl []byte) (*TemplatePrinter, error) + func (p *TemplatePrinter) PrintObj(obj runtime.Object, w io.Writer) error + type VersionedPrinter struct + func (p *VersionedPrinter) PrintObj(obj runtime.Object, w io.Writer) error + type YAMLPrinter struct + func (p *YAMLPrinter) PrintObj(obj runtime.Object, w io.Writer) error