Versions in this module Expand all Collapse all v1 v1.0.6 Sep 13, 2015 Changes in this version type RollingUpdaterConfig + MaxSurge util.IntOrString + MaxUnavailable util.IntOrString v1.0.5 Aug 24, 2015 Changes in this version + const DefaultHostAcceptRE + const DefaultMethodRejectRE + const DefaultPathAcceptRE + const DefaultPathRejectRE + const Interval + const MaxRetries + const Timeout + var ReverseProxyFlushInterval = 100 * time.Millisecond + func AbortRollingUpdate(c *RollingUpdaterConfig) + func AddBoundJsonFilenameFlag(cmd *cobra.Command, value *[]string, usage string) + func AddDeploymentKeyToReplicationController(oldRc *api.ReplicationController, client client.Interface, ...) (*api.ReplicationController, error) + func AddJsonFilenameFlag(cmd *cobra.Command, 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 DescribeLimitRanges(limitRanges *api.LimitRangeList, w io.Writer) + func DescribeResourceQuotas(quotas *api.ResourceQuotaList, w io.Writer) + func FindSourceController(r RollingUpdaterClient, namespace, name string) (*api.ReplicationController, error) + func GetApiVersions(w io.Writer, kubeClient client.Interface) + func GetBool(params map[string]string, key string, defValue bool) (bool, error) + 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 MakeRegexpArray(str string) ([]*regexp.Regexp, error) + func MakeRegexpArrayOrDie(str string) []*regexp.Regexp + 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 AlwaysAccept struct + func (a *AlwaysAccept) Accept(*api.ReplicationController) error + type BasicPod struct + func (BasicPod) Generate(params map[string]string) (runtime.Object, error) + func (BasicPod) ParamNames() []GeneratorParam + 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 FilterServer struct + AcceptHosts []*regexp.Regexp + AcceptPaths []*regexp.Regexp + RejectMethods []*regexp.Regexp + RejectPaths []*regexp.Regexp + func (f *FilterServer) HandlerFor(delegate http.Handler) *FilterServer + func (f *FilterServer) ServeHTTP(rw http.ResponseWriter, req *http.Request) + 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, wide bool, columnLabels []string) *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 NamespaceDescriber struct + func (d *NamespaceDescriber) 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) Listen(port int) (net.Listener, error) + func (s *ProxyServer) ListenUnix(path string) (net.Listener, error) + func (s *ProxyServer) ServeOnListener(l net.Listener) error + type RESTClient interface + Delete func() *client.Request + Get func() *client.Request + Patch func(api.PatchType) *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, client 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 + UpdateAcceptor UpdateAcceptor + UpdatePercent *int + 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 ServiceGeneratorV1 struct + func (ServiceGeneratorV1) Generate(params map[string]string) (runtime.Object, error) + func (ServiceGeneratorV1) ParamNames() []GeneratorParam + type ServiceGeneratorV2 struct + func (ServiceGeneratorV2) Generate(params map[string]string) (runtime.Object, error) + func (ServiceGeneratorV2) 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 UpdateAcceptor interface + Accept func(*api.ReplicationController) error + var DefaultUpdateAcceptor UpdateAcceptor = &AlwaysAccept{} + 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