unversioned

package

Go to main page

Versions in this module

v1

v1.3.2

Jan 7, 2017

v1.3.1

Sep 22, 2016

v1.3.0

Sep 19, 2016

Changes in this version

+ var ErrPodCompleted = fmt.Errorf("pod ran to completion")

+ func PodCompleted(event watch.Event) (bool, error)

+ func PodContainerRunning(containerName string) watch.ConditionFunc

+ func PodNotPending(event watch.Event) (bool, error)

+ func PodRunning(event watch.Event) (bool, error)

+ func PodRunningAndReady(event watch.Event) (bool, error)

+ func ServiceAccountHasSecrets(event watch.Event) (bool, error)

+ type AppsClient struct

+ func NewApps(c *restclient.Config) (*AppsClient, error)

+ func NewAppsOrDie(c *restclient.Config) *AppsClient

+ func (c *AppsClient) PetSets(namespace string) PetSetInterface

+ type AppsInterface interface

type BatchClient

+ func NewBatchV2Alpha1(c *restclient.Config) (*BatchClient, error)

+ func (c *BatchClient) ScheduledJobs(namespace string) ScheduledJobInterface

type Client

+ func (c *Client) Apps() AppsInterface

+ func (c *Client) Rbac() RbacInterface

+ type ClusterRoleBindingInterface interface

+ Create func(clusterRoleBinding *rbac.ClusterRoleBinding) (*rbac.ClusterRoleBinding, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*rbac.ClusterRoleBinding, error)

+ List func(opts api.ListOptions) (*rbac.ClusterRoleBindingList, error)

+ Update func(clusterRoleBinding *rbac.ClusterRoleBinding) (*rbac.ClusterRoleBinding, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ClusterRoleBindings interface

+ ClusterRoleBindings func() ClusterRoleBindingInterface

+ type ClusterRoleInterface interface

+ Create func(clusterRole *rbac.ClusterRole) (*rbac.ClusterRole, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*rbac.ClusterRole, error)

+ List func(opts api.ListOptions) (*rbac.ClusterRoleList, error)

+ Update func(clusterRole *rbac.ClusterRole) (*rbac.ClusterRole, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ClusterRoles interface

+ ClusterRoles func() ClusterRoleInterface

type ExtensionsClient

+ func (c *ExtensionsClient) NetworkPolicies(namespace string) NetworkPolicyInterface

type Interface

+ Rbac func() RbacInterface

+ type NetworkPolicies struct

+ func (c *NetworkPolicies) Create(networkPolicy *extensions.NetworkPolicy) (result *extensions.NetworkPolicy, err error)

+ func (c *NetworkPolicies) Delete(name string, options *api.DeleteOptions) (err error)

+ func (c *NetworkPolicies) Get(name string) (result *extensions.NetworkPolicy, err error)

+ func (c *NetworkPolicies) List(opts api.ListOptions) (result *extensions.NetworkPolicyList, err error)

+ func (c *NetworkPolicies) Update(networkPolicy *extensions.NetworkPolicy) (result *extensions.NetworkPolicy, err error)

+ func (c *NetworkPolicies) Watch(opts api.ListOptions) (watch.Interface, error)

+ type NetworkPolicyInterface interface

+ Create func(networkPolicy *extensions.NetworkPolicy) (*extensions.NetworkPolicy, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*extensions.NetworkPolicy, error)

+ List func(opts api.ListOptions) (*extensions.NetworkPolicyList, error)

+ Update func(networkPolicy *extensions.NetworkPolicy) (*extensions.NetworkPolicy, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type NetworkPolicyNamespacer interface

+ NetworkPolicies func(namespace string) NetworkPolicyInterface

+ type PetSetInterface interface

+ Create func(petSet *apps.PetSet) (*apps.PetSet, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*apps.PetSet, error)

+ List func(opts api.ListOptions) (*apps.PetSetList, error)

+ Update func(petSet *apps.PetSet) (*apps.PetSet, error)

+ UpdateStatus func(petSet *apps.PetSet) (*apps.PetSet, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type PetSetNamespacer interface

+ PetSets func(namespace string) PetSetInterface

+ type PodDisruptionBudgetInterface interface

+ Create func(podDisruptionBudget *policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*policy.PodDisruptionBudget, error)

+ List func(opts api.ListOptions) (*policy.PodDisruptionBudgetList, error)

+ Update func(podDisruptionBudget *policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error)

+ UpdateStatus func(podDisruptionBudget *policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type PodDisruptionBudgetNamespacer interface

+ PodDisruptionBudgets func(namespace string) PodDisruptionBudgetInterface

+ type PolicyClient struct

+ func NewPolicy(c *restclient.Config) (*PolicyClient, error)

+ func NewPolicyOrDie(c *restclient.Config) *PolicyClient

+ func (c *PolicyClient) PodDisruptionBudgets(namespace string) PodDisruptionBudgetInterface

+ type PolicyInterface interface

+ type RbacClient struct

+ func NewRbac(c *restclient.Config) (*RbacClient, error)

+ func NewRbacOrDie(c *restclient.Config) *RbacClient

+ func (c *RbacClient) ClusterRoleBindings() ClusterRoleBindingInterface

+ func (c *RbacClient) ClusterRoles() ClusterRoleInterface

+ func (c *RbacClient) RoleBindings(namespace string) RoleBindingInterface

+ func (c *RbacClient) Roles(namespace string) RoleInterface

+ type RbacInterface interface

+ type RoleBindingInterface interface

+ Create func(roleBinding *rbac.RoleBinding) (*rbac.RoleBinding, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*rbac.RoleBinding, error)

+ List func(opts api.ListOptions) (*rbac.RoleBindingList, error)

+ Update func(roleBinding *rbac.RoleBinding) (*rbac.RoleBinding, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type RoleBindingsNamespacer interface

+ RoleBindings func(namespace string) RoleBindingInterface

+ type RoleInterface interface

+ Create func(role *rbac.Role) (*rbac.Role, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*rbac.Role, error)

+ List func(opts api.ListOptions) (*rbac.RoleList, error)

+ Update func(role *rbac.Role) (*rbac.Role, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type RolesNamespacer interface

+ Roles func(namespace string) RoleInterface

+ type ScheduledJobInterface interface

+ Create func(scheduledJob *batch.ScheduledJob) (*batch.ScheduledJob, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*batch.ScheduledJob, error)

+ List func(opts api.ListOptions) (*batch.ScheduledJobList, error)

+ Update func(scheduledJob *batch.ScheduledJob) (*batch.ScheduledJob, error)

+ UpdateStatus func(scheduledJob *batch.ScheduledJob) (*batch.ScheduledJob, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ScheduledJobsNamespacer interface

+ ScheduledJobs func(namespace string) ScheduledJobInterface

v1.2.0

Jun 23, 2016

v0

v0.4.0

Jun 23, 2016

Changes in this version

+ var DefaultBackoff = wait.Backoff

+ var DefaultRetry = wait.Backoff

+ func ReplicaSetHasDesiredReplicas(c ExtensionsInterface, replicaSet *extensions.ReplicaSet) wait.ConditionFunc

+ func RetryOnConflict(backoff wait.Backoff, fn func() error) error

+ type AutoscalingClient struct

+ func NewAutoscaling(c *restclient.Config) (*AutoscalingClient, error)

+ func NewAutoscalingOrDie(c *restclient.Config) *AutoscalingClient

+ func (c *AutoscalingClient) HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerInterface

+ type AutoscalingInterface interface

+ type BatchClient struct

+ func NewBatch(c *restclient.Config) (*BatchClient, error)

+ func NewBatchOrDie(c *restclient.Config) *BatchClient

+ func (c *BatchClient) Jobs(namespace string) JobInterface

+ type BatchInterface interface

type Client

+ func (c *Client) Autoscaling() AutoscalingInterface

+ func (c *Client) Batch() BatchInterface

+ func (c *Client) ConfigMaps(namespace string) ConfigMapsInterface

type DeploymentInterface

+ Rollback func(*extensions.DeploymentRollback) error

type ExtensionsClient

+ func (c *ExtensionsClient) PodSecurityPolicies() PodSecurityPolicyInterface

+ func (c *ExtensionsClient) ReplicaSets(namespace string) ReplicaSetInterface

type Interface

+ Autoscaling func() AutoscalingInterface

+ Batch func() BatchInterface

+ type PodSecurityPoliciesInterface interface

+ PodSecurityPolicies func() PodSecurityPolicyInterface

+ type PodSecurityPolicyInterface interface

+ Create func(scc *extensions.PodSecurityPolicy) (*extensions.PodSecurityPolicy, error)

+ Delete func(name string) error

+ Get func(name string) (result *extensions.PodSecurityPolicy, err error)

+ List func(opts api.ListOptions) (*extensions.PodSecurityPolicyList, error)

+ Update func(*extensions.PodSecurityPolicy) (*extensions.PodSecurityPolicy, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ReplicaSetInterface interface

+ Create func(ctrl *extensions.ReplicaSet) (*extensions.ReplicaSet, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*extensions.ReplicaSet, error)

+ List func(opts api.ListOptions) (*extensions.ReplicaSetList, error)

+ Update func(ctrl *extensions.ReplicaSet) (*extensions.ReplicaSet, error)

+ UpdateStatus func(ctrl *extensions.ReplicaSet) (*extensions.ReplicaSet, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ReplicaSetsNamespacer interface

+ ReplicaSets func(namespace string) ReplicaSetInterface

type ServiceInterface

+ UpdateStatus func(srv *api.Service) (*api.Service, error)

v0.3.0

Mar 16, 2016

Changes in this version

+ const ConfigMapResourceName

+ const EventType

+ func DeploymentHasDesiredReplicas(c ExtensionsInterface, deployment *extensions.Deployment) wait.ConditionFunc

+ func ExtractGroupVersions(l *unversioned.APIGroupList) []string

+ func GetInvolvedObjectNameFieldLabel(version string) string

+ func ServerAPIVersions(c *Config) (groupVersions []string, err error)

+ type BackoffManager interface

+ CalculateBackoff func(actualUrl *url.URL) time.Duration

+ UpdateBackoff func(actualUrl *url.URL, err error, responseCode int)

type Client

+ func (c *Client) Discovery() DiscoveryInterface

+ func (c *Client) Extensions() ExtensionsInterface

type Config

+ GroupVersion *unversioned.GroupVersion

+ type ConfigMaps struct

+ func (c *ConfigMaps) Create(cfg *extensions.ConfigMap) (*extensions.ConfigMap, error)

+ func (c *ConfigMaps) Delete(name string) error

+ func (c *ConfigMaps) Get(name string) (*extensions.ConfigMap, error)

+ func (c *ConfigMaps) List(opts api.ListOptions) (*extensions.ConfigMapList, error)

+ func (c *ConfigMaps) Update(cfg *extensions.ConfigMap) (*extensions.ConfigMap, error)

+ func (c *ConfigMaps) Watch(opts api.ListOptions) (watch.Interface, error)

+ type ConfigMapsInterface interface

+ Create func(*extensions.ConfigMap) (*extensions.ConfigMap, error)

+ Delete func(string) error

+ Get func(string) (*extensions.ConfigMap, error)

+ List func(opts api.ListOptions) (*extensions.ConfigMapList, error)

+ Update func(*extensions.ConfigMap) (*extensions.ConfigMap, error)

+ Watch func(api.ListOptions) (watch.Interface, error)

+ type ConfigMapsNamespacer interface

+ ConfigMaps func(namespace string) ConfigMapsInterface

type DeploymentInterface

+ UpdateStatus func(*extensions.Deployment) (*extensions.Deployment, error)

+ type DiscoveryClient struct

+ func NewDiscoveryClient(c *Config) (*DiscoveryClient, error)

+ func (d *DiscoveryClient) ServerGroups() (apiGroupList *unversioned.APIGroupList, err error)

+ func (d *DiscoveryClient) ServerResources() (map[string]*unversioned.APIResourceList, error)

+ func (d *DiscoveryClient) ServerResourcesForGroupVersion(groupVersion string) (resources *unversioned.APIResourceList, err error)

+ type DiscoveryInterface interface

type EventInterface

+ DeleteCollection func(options *api.DeleteOptions, listOptions api.ListOptions) error

+ Patch func(event *api.Event, data []byte) (*api.Event, error)

+ type ExtensionsClient struct

+ func NewExtensions(c *Config) (*ExtensionsClient, error)

+ func NewExtensionsOrDie(c *Config) *ExtensionsClient

+ func (c *ExtensionsClient) ConfigMaps(namespace string) ConfigMapsInterface

+ func (c *ExtensionsClient) DaemonSets(namespace string) DaemonSetInterface

+ func (c *ExtensionsClient) Deployments(namespace string) DeploymentInterface

+ func (c *ExtensionsClient) HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerInterface

+ func (c *ExtensionsClient) Ingress(namespace string) IngressInterface

+ func (c *ExtensionsClient) Jobs(namespace string) JobInterface

+ func (c *ExtensionsClient) Scales(namespace string) ScaleInterface

+ func (c *ExtensionsClient) ServerVersion() (*version.Info, error)

+ func (c *ExtensionsClient) ThirdPartyResources(namespace string) ThirdPartyResourceInterface

+ type ExtensionsInterface interface

type HorizontalPodAutoscalerInterface

+ UpdateStatus func(horizontalPodAutoscaler *extensions.HorizontalPodAutoscaler) (*extensions.HorizontalPodAutoscaler, error)

type Interface

+ Discovery func() DiscoveryInterface

+ Extensions func() ExtensionsInterface

+ type NoBackoff struct

+ func (n *NoBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration

+ func (n *NoBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int)

type PodInterface

+ GetLogs func(name string, opts *api.PodLogOptions) *Request

type RESTClient

+ func UnversionedRESTClientFor(config *Config) (*RESTClient, error)

type ReplicationControllerInterface

+ UpdateStatus func(ctrl *api.ReplicationController) (*api.ReplicationController, error)

type Request

+ func (r *Request) VersionedParams(obj runtime.Object, convertor runtime.ObjectConvertor) *Request

+ type ServerGroupsInterface interface

+ ServerGroups func() (*unversioned.APIGroupList, error)

+ type ServerResourcesInterface interface

+ ServerResources func() (map[string]*unversioned.APIResourceList, error)

+ ServerResourcesForGroupVersion func(groupVersion string) (*unversioned.APIResourceList, error)

+ type ThirdPartyResourceInterface interface

+ Create func(ctrl *extensions.ThirdPartyResource) (*extensions.ThirdPartyResource, error)

+ Delete func(name string) error

+ Get func(name string) (*extensions.ThirdPartyResource, error)

+ List func(opts api.ListOptions) (*extensions.ThirdPartyResourceList, error)

+ Update func(ctrl *extensions.ThirdPartyResource) (*extensions.ThirdPartyResource, error)

+ UpdateStatus func(ctrl *extensions.ThirdPartyResource) (*extensions.ThirdPartyResource, error)

+ Watch func(opts api.ListOptions) (watch.Interface, error)

+ type ThirdPartyResourceNamespacer interface

+ ThirdPartyResources func(namespace string) ThirdPartyResourceInterface

+ type URLBackoff struct

+ Backoff *util.Backoff

+ func (b *URLBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration

+ func (b *URLBackoff) Disable()

+ func (b *URLBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int)

v0.1.0

Oct 25, 2015

Changes in this version

+ const CurlCommand

+ const EventInvolvedAPIVersion

+ const EventInvolvedFieldPath

+ const EventInvolvedKind

+ const EventInvolvedName

+ const EventInvolvedNamespace

+ const EventInvolvedResourceVersion

+ const EventInvolvedUID

+ const EventReason

+ const EventSource

+ const JustURL

+ const NodeUnschedulable

+ const ObjectNameField

+ const PodHost

+ const PodStatus

+ const RequestHeaders

+ const ResponseHeaders

+ const ResponseStatus

+ const SecretType

+ const URLTiming

+ func ControllerHasDesiredReplicas(c Interface, controller *api.ReplicationController) wait.ConditionFunc

+ func DefaultKubernetesUserAgent() string

+ func DefaultServerURL(host, prefix, version string, defaultTLS bool) (*url.URL, error)

+ func HTTPWrappersForConfig(config *Config, rt http.RoundTripper) (http.RoundTripper, error)

+ func IsConfigTransportTLS(config Config) bool

+ func IsTimeout(err error) bool

+ func JobHasDesiredParallelism(c Interface, job *experimental.Job) wait.ConditionFunc

+ func LoadTLSFiles(config *Config) error

+ func MakeTransport(config *KubeletConfig) (http.RoundTripper, error)

+ func MatchesServerVersion(client *Client, c *Config) error

+ func NegotiateVersion(client *Client, c *Config, version string, clientRegisteredVersions []string) (string, error)

+ func NewBasicAuthRoundTripper(username, password string, rt http.RoundTripper) http.RoundTripper

+ func NewBearerAuthRoundTripper(bearer string, rt http.RoundTripper) http.RoundTripper

+ func NewClientCertTLSConfig(certData, keyData, caData []byte) (*tls.Config, error)

+ func NewTLSConfig(caData []byte) (*tls.Config, error)

+ func NewUnsafeTLSConfig() *tls.Config

+ func NewUserAgentRoundTripper(agent string, rt http.RoundTripper) http.RoundTripper

+ func SetKubernetesDefaults(config *Config) error

+ func TLSConfigFor(config *Config) (*tls.Config, error)

+ func TransportFor(config *Config) (http.RoundTripper, error)

+ type APIStatus interface

+ Status func() unversioned.Status

+ type Client struct

+ func New(c *Config) (*Client, error)

+ func NewInCluster() (*Client, error)

+ func NewOrDie(c *Config) *Client

+ func (c *Client) ComponentStatuses() ComponentStatusInterface

+ func (c *Client) Endpoints(namespace string) EndpointsInterface

+ func (c *Client) Events(namespace string) EventInterface

+ func (c *Client) Experimental() ExperimentalInterface

+ func (c *Client) LimitRanges(namespace string) LimitRangeInterface

+ func (c *Client) Namespaces() NamespaceInterface

+ func (c *Client) Networks() NetworkInterface

+ func (c *Client) Nodes() NodeInterface

+ func (c *Client) PersistentVolumeClaims(namespace string) PersistentVolumeClaimInterface

+ func (c *Client) PersistentVolumes() PersistentVolumeInterface

+ func (c *Client) PodTemplates(namespace string) PodTemplateInterface

+ func (c *Client) Pods(namespace string) PodInterface

+ func (c *Client) ReplicationControllers(namespace string) ReplicationControllerInterface

+ func (c *Client) ResourceQuotas(namespace string) ResourceQuotaInterface

+ func (c *Client) Secrets(namespace string) SecretsInterface

+ func (c *Client) ServerAPIVersions() (*api.APIVersions, error)

+ func (c *Client) ServerVersion() (*version.Info, error)

+ func (c *Client) ServiceAccounts(namespace string) ServiceAccountsInterface

+ func (c *Client) Services(namespace string) ServiceInterface

+ func (c *Client) SwaggerSchema(version string) (*swagger.ApiDeclaration, error)

+ func (c *Client) Tenants() TenantInterface

+ func (c *Client) ValidateComponents() (*api.ComponentStatusList, error)

+ type ComponentStatusInterface interface

+ Get func(name string) (*api.ComponentStatus, error)

+ List func(label labels.Selector, field fields.Selector) (*api.ComponentStatusList, error)

+ type ComponentStatusesInterface interface

+ ComponentStatuses func() ComponentStatusInterface

+ type ComponentValidatorInterface interface

+ ValidateComponents func() (*api.ComponentStatusList, error)

+ type Config struct

+ BearerToken string

+ Burst int

+ Codec runtime.Codec

+ Host string

+ Insecure bool

+ Password string

+ Prefix string

+ QPS float32

+ Transport http.RoundTripper

+ UserAgent string

+ Username string

+ Version string

+ WrapTransport func(rt http.RoundTripper) http.RoundTripper

+ func InClusterConfig() (*Config, error)

+ type ConnectionInfoGetter interface

+ GetConnectionInfo func(host string) (scheme string, port uint, transport http.RoundTripper, err error)

+ type ContainerInfoGetter interface

+ GetContainerInfo func(host, podID, containerID string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ GetMachineInfo func(host string) (*cadvisorApi.MachineInfo, error)

+ GetRootInfo func(host string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ type DaemonSetInterface interface

+ Create func(ctrl *experimental.DaemonSet) (*experimental.DaemonSet, error)

+ Delete func(name string) error

+ Get func(name string) (*experimental.DaemonSet, error)

+ List func(selector labels.Selector) (*experimental.DaemonSetList, error)

+ Update func(ctrl *experimental.DaemonSet) (*experimental.DaemonSet, error)

+ UpdateStatus func(ctrl *experimental.DaemonSet) (*experimental.DaemonSet, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type DaemonSetsNamespacer interface

+ DaemonSets func(namespace string) DaemonSetInterface

+ type DebuggingRoundTripper struct

+ Levels sets.String

+ func NewDebuggingRoundTripper(rt http.RoundTripper, levels ...string) *DebuggingRoundTripper

+ func (rt *DebuggingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

+ type DeploymentInterface interface

+ Create func(Deployment *experimental.Deployment) (*experimental.Deployment, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*experimental.Deployment, error)

+ List func(label labels.Selector, field fields.Selector) (*experimental.DeploymentList, error)

+ Update func(Deployment *experimental.Deployment) (*experimental.Deployment, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type DeploymentsNamespacer interface

+ Deployments func(namespace string) DeploymentInterface

+ type EndpointsInterface interface

+ Create func(endpoints *api.Endpoints) (*api.Endpoints, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Endpoints, error)

+ List func(selector labels.Selector) (*api.EndpointsList, error)

+ Update func(endpoints *api.Endpoints) (*api.Endpoints, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type EndpointsNamespacer interface

+ Endpoints func(namespace string) EndpointsInterface

+ type EventInterface interface

+ Create func(event *api.Event) (*api.Event, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Event, error)

+ GetFieldSelector func(involvedObjectName, involvedObjectNamespace, involvedObjectKind, ... *string) fields.Selector

+ List func(label labels.Selector, field fields.Selector) (*api.EventList, error)

+ Search func(objOrRef runtime.Object) (*api.EventList, error)

+ Update func(event *api.Event) (*api.Event, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type EventNamespacer interface

+ Events func(namespace string) EventInterface

+ type ExperimentalClient struct

+ func NewExperimental(c *Config) (*ExperimentalClient, error)

+ func NewExperimentalOrDie(c *Config) *ExperimentalClient

+ func (c *ExperimentalClient) DaemonSets(namespace string) DaemonSetInterface

+ func (c *ExperimentalClient) Deployments(namespace string) DeploymentInterface

+ func (c *ExperimentalClient) HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerInterface

+ func (c *ExperimentalClient) Ingress(namespace string) IngressInterface

+ func (c *ExperimentalClient) Jobs(namespace string) JobInterface

+ func (c *ExperimentalClient) Scales(namespace string) ScaleInterface

+ func (c *ExperimentalClient) ServerAPIVersions() (*api.APIVersions, error)

+ func (c *ExperimentalClient) ServerVersion() (*version.Info, error)

+ type ExperimentalInterface interface

+ type FakeKubeletClient struct

+ func (c FakeKubeletClient) GetConnectionInfo(host string) (string, uint, http.RoundTripper, error)

+ type FlagSet interface

+ BoolVar func(p *bool, name string, value bool, usage string)

+ DurationVar func(p *time.Duration, name string, value time.Duration, usage string)

+ IntVar func(p *int, name string, value int, usage string)

+ StringVar func(p *string, name, value, usage string)

+ UintVar func(p *uint, name string, value uint, usage string)

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type HTTPContainerInfoGetter struct

+ Client *http.Client

+ Port int

+ func (self *HTTPContainerInfoGetter) GetContainerInfo(host, podID, containerID string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ func (self *HTTPContainerInfoGetter) GetMachineInfo(host string) (*cadvisorApi.MachineInfo, error)

+ func (self *HTTPContainerInfoGetter) GetRootInfo(host string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ type HTTPKubeletClient struct

+ Client *http.Client

+ Config *KubeletConfig

+ func (c *HTTPKubeletClient) GetConnectionInfo(host string) (string, uint, http.RoundTripper, error)

+ type HorizontalPodAutoscalerInterface interface

+ Create func(horizontalPodAutoscaler *experimental.HorizontalPodAutoscaler) (*experimental.HorizontalPodAutoscaler, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*experimental.HorizontalPodAutoscaler, error)

+ List func(label labels.Selector, field fields.Selector) (*experimental.HorizontalPodAutoscalerList, error)

+ Update func(horizontalPodAutoscaler *experimental.HorizontalPodAutoscaler) (*experimental.HorizontalPodAutoscaler, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type HorizontalPodAutoscalersNamespacer interface

+ HorizontalPodAutoscalers func(namespace string) HorizontalPodAutoscalerInterface

+ type IngressInterface interface

+ Create func(ingress *experimental.Ingress) (*experimental.Ingress, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*experimental.Ingress, error)

+ List func(label labels.Selector, field fields.Selector) (*experimental.IngressList, error)

+ Update func(ingress *experimental.Ingress) (*experimental.Ingress, error)

+ UpdateStatus func(ingress *experimental.Ingress) (*experimental.Ingress, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type IngressNamespacer interface

+ Ingress func(namespace string) IngressInterface

+ type Interface interface

+ Experimental func() ExperimentalInterface

+ type JobInterface interface

+ Create func(job *experimental.Job) (*experimental.Job, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*experimental.Job, error)

+ List func(label labels.Selector, field fields.Selector) (*experimental.JobList, error)

+ Update func(job *experimental.Job) (*experimental.Job, error)

+ UpdateStatus func(job *experimental.Job) (*experimental.Job, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type JobsNamespacer interface

+ Jobs func(namespace string) JobInterface

+ type KubeletClient interface

+ func NewKubeletClient(config *KubeletConfig) (KubeletClient, error)

+ type KubeletConfig struct

+ BearerToken string

+ Dial func(net, addr string) (net.Conn, error)

+ EnableHttps bool

+ HTTPTimeout time.Duration

+ Port uint

+ type LimitRangeInterface interface

+ Create func(limitRange *api.LimitRange) (*api.LimitRange, error)

+ Delete func(name string) error

+ Get func(name string) (*api.LimitRange, error)

+ List func(selector labels.Selector) (*api.LimitRangeList, error)

+ Update func(limitRange *api.LimitRange) (*api.LimitRange, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type LimitRangesNamespacer interface

+ LimitRanges func(namespace string) LimitRangeInterface

+ type NamespaceInterface interface

+ Create func(item *api.Namespace) (*api.Namespace, error)

+ Delete func(name string) error

+ Finalize func(item *api.Namespace) (*api.Namespace, error)

+ Get func(name string) (result *api.Namespace, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.NamespaceList, error)

+ Status func(item *api.Namespace) (*api.Namespace, error)

+ Update func(item *api.Namespace) (*api.Namespace, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type NamespacesInterface interface

+ Namespaces func() NamespaceInterface

+ type NetworkInterface interface

+ Create func(item *api.Network) (*api.Network, error)

+ Delete func(name string) error

+ Get func(name string) (result *api.Network, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.NetworkList, error)

+ Status func(item *api.Network) (*api.Network, error)

+ Update func(item *api.Network) (*api.Network, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type NetworksInterface interface

+ Networks func() NetworkInterface

+ type NodeInterface interface

+ Create func(node *api.Node) (*api.Node, error)

+ Delete func(name string) error

+ Get func(name string) (result *api.Node, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.NodeList, error)

+ Update func(*api.Node) (*api.Node, error)

+ UpdateStatus func(*api.Node) (*api.Node, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type NodesInterface interface

+ Nodes func() NodeInterface

+ type PersistentVolumeClaimInterface interface

+ Create func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ Delete func(name string) error

+ Get func(name string) (*api.PersistentVolumeClaim, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PersistentVolumeClaimList, error)

+ Update func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ UpdateStatus func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PersistentVolumeClaimsNamespacer interface

+ PersistentVolumeClaims func(namespace string) PersistentVolumeClaimInterface

+ type PersistentVolumeInterface interface

+ Create func(volume *api.PersistentVolume) (*api.PersistentVolume, error)

+ Delete func(name string) error

+ Get func(name string) (*api.PersistentVolume, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PersistentVolumeList, error)

+ Update func(volume *api.PersistentVolume) (*api.PersistentVolume, error)

+ UpdateStatus func(persistentVolume *api.PersistentVolume) (*api.PersistentVolume, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PersistentVolumesInterface interface

+ PersistentVolumes func() PersistentVolumeInterface

+ type PodInterface interface

+ Bind func(binding *api.Binding) error

+ Create func(pod *api.Pod) (*api.Pod, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*api.Pod, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PodList, error)

+ Update func(pod *api.Pod) (*api.Pod, error)

+ UpdateStatus func(pod *api.Pod) (*api.Pod, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PodTemplateInterface interface

+ Create func(podTemplate *api.PodTemplate) (*api.PodTemplate, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*api.PodTemplate, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PodTemplateList, error)

+ Update func(podTemplate *api.PodTemplate) (*api.PodTemplate, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PodTemplatesNamespacer interface

+ PodTemplates func(namespace string) PodTemplateInterface

+ type PodsNamespacer interface

+ Pods func(namespace string) PodInterface

+ type RESTClient struct

+ Client HTTPClient

+ Codec runtime.Codec

+ Throttle util.RateLimiter

+ Timeout time.Duration

+ func NewRESTClient(baseURL *url.URL, apiVersion string, c runtime.Codec, maxQPS float32, ...) *RESTClient

+ func RESTClientFor(config *Config) (*RESTClient, error)

+ func (c *RESTClient) APIVersion() string

+ func (c *RESTClient) Delete() *Request

+ func (c *RESTClient) Get() *Request

+ func (c *RESTClient) Patch(pt api.PatchType) *Request

+ func (c *RESTClient) Post() *Request

+ func (c *RESTClient) Put() *Request

+ func (c *RESTClient) Verb(verb string) *Request

+ type ReplicationControllerInterface interface

+ Create func(ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ReplicationController, error)

+ List func(selector labels.Selector) (*api.ReplicationControllerList, error)

+ Update func(ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ReplicationControllersNamespacer interface

+ ReplicationControllers func(namespace string) ReplicationControllerInterface

+ type Request struct

+ func NewRequest(client HTTPClient, verb string, baseURL *url.URL, apiVersion string, ...) *Request

+ func (r *Request) AbsPath(segments ...string) *Request

+ func (r *Request) Body(obj interface{}) *Request

+ func (r *Request) Do() Result

+ func (r *Request) DoRaw() ([]byte, error)

+ func (r *Request) FieldsSelectorParam(s fields.Selector) *Request

+ func (r *Request) LabelsSelectorParam(s labels.Selector) *Request

+ func (r *Request) Name(resourceName string) *Request

+ func (r *Request) Namespace(namespace string) *Request

+ func (r *Request) NamespaceIfScoped(namespace string, scoped bool) *Request

+ func (r *Request) Param(paramName, s string) *Request

+ func (r *Request) Prefix(segments ...string) *Request

+ func (r *Request) RequestURI(uri string) *Request

+ func (r *Request) Resource(resource string) *Request

+ func (r *Request) SetHeader(key, value string) *Request

+ func (r *Request) Stream() (io.ReadCloser, error)

+ func (r *Request) SubResource(subresources ...string) *Request

+ func (r *Request) Suffix(segments ...string) *Request

+ func (r *Request) Timeout(d time.Duration) *Request

+ func (r *Request) URL() *url.URL

+ func (r *Request) UintParam(paramName string, u uint64) *Request

+ func (r *Request) UnversionedPath(segments ...string) *Request

+ func (r *Request) Upgrade(config *Config, ...) (httpstream.Connection, error)

+ func (r *Request) Watch() (watch.Interface, error)

+ type RequestConstructionError struct

+ Err error

+ func (r *RequestConstructionError) Error() string

+ type RequestInfo struct

+ Duration time.Duration

+ RequestHeaders http.Header

+ RequestURL string

+ RequestVerb string

+ ResponseErr error

+ ResponseHeaders http.Header

+ ResponseStatus string

+ func NewRequestInfo(req *http.Request) *RequestInfo

+ func (r *RequestInfo) Complete(response *http.Response, err error)

+ func (r RequestInfo) ToCurl() string

+ type ResourceQuotaInterface interface

+ Create func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ResourceQuota, error)

+ List func(selector labels.Selector) (*api.ResourceQuotaList, error)

+ Update func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ UpdateStatus func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ResourceQuotasNamespacer interface

+ ResourceQuotas func(namespace string) ResourceQuotaInterface

+ type ResponseWrapper interface

+ DoRaw func() ([]byte, error)

+ Stream func() (io.ReadCloser, error)

+ type Result struct

+ func (r Result) Error() error

+ func (r Result) Get() (runtime.Object, error)

+ func (r Result) Into(obj runtime.Object) error

+ func (r Result) Raw() ([]byte, error)

+ func (r Result) StatusCode(statusCode *int) Result

+ func (r Result) WasCreated(wasCreated *bool) Result

+ type ScaleInterface interface

+ Get func(string, string) (*experimental.Scale, error)

+ Update func(string, *experimental.Scale) (*experimental.Scale, error)

+ type ScaleNamespacer interface

+ Scales func(namespace string) ScaleInterface

+ type SecretsInterface interface

+ Create func(secret *api.Secret) (*api.Secret, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Secret, error)

+ List func(label labels.Selector, field fields.Selector) (*api.SecretList, error)

+ Update func(secret *api.Secret) (*api.Secret, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type SecretsNamespacer interface

+ Secrets func(namespace string) SecretsInterface

+ type ServiceAccountsInterface interface

+ Create func(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ServiceAccount, error)

+ List func(label labels.Selector, field fields.Selector) (*api.ServiceAccountList, error)

+ Update func(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ServiceAccountsNamespacer interface

+ ServiceAccounts func(namespace string) ServiceAccountsInterface

+ type ServiceInterface interface

+ Create func(srv *api.Service) (*api.Service, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Service, error)

+ List func(selector labels.Selector) (*api.ServiceList, error)

+ ProxyGet func(name, path string, params map[string]string) ResponseWrapper

+ Update func(srv *api.Service) (*api.Service, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ServicesNamespacer interface

+ Services func(namespace string) ServiceInterface

+ type SwaggerSchemaInterface interface

+ SwaggerSchema func(version string) (*swagger.ApiDeclaration, error)

+ type TLSClientConfig struct

+ CAData []byte

+ CAFile string

+ CertData []byte

+ CertFile string

+ KeyData []byte

+ KeyFile string

+ type TenantInterface interface

+ Create func(item *api.Tenant) (*api.Tenant, error)

+ Delete func(name string) error

+ Finalize func(item *api.Tenant) (*api.Tenant, error)

+ Get func(name string) (result *api.Tenant, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.TenantList, error)

+ Status func(item *api.Tenant) (*api.Tenant, error)

+ Update func(item *api.Tenant) (*api.Tenant, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type TenantsInterface interface

+ Tenants func() TenantInterface

+ type VersionInterface interface

+ ServerAPIVersions func() (*api.APIVersions, error)

+ ServerVersion func() (*version.Info, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL