Versions in this module Expand all Collapse all v1 v1.4.0 Oct 17, 2016 Changes in this version + const DefaultBurst + const DefaultQPS + func DefaultKubernetesUserAgent() string + func DefaultServerURL(host, apiPath string, groupVersion unversioned.GroupVersion, defaultTLS bool) (*url.URL, string, error) + func HTTPWrappersForConfig(config *Config, rt http.RoundTripper) (http.RoundTripper, error) + func IsConfigTransportTLS(config Config) bool + func LoadTLSFiles(c *Config) error + func RegisterAuthProviderPlugin(name string, plugin Factory) error + func ServerAPIVersions(c *Config) (groupVersions []string, err error) + func SetKubernetesDefaults(config *Config) error + func TLSConfigFor(config *Config) (*tls.Config, error) + func TransportFor(config *Config) (http.RoundTripper, error) + type AuthProvider interface + Login func() error + WrapTransport func(http.RoundTripper) http.RoundTripper + func GetAuthProvider(clusterAddress string, apc *clientcmdapi.AuthProviderConfig, ...) (AuthProvider, error) + type AuthProviderConfigPersister interface + Persist func(map[string]string) error + type BackoffManager interface + CalculateBackoff func(actualUrl *url.URL) time.Duration + Sleep func(d time.Duration) + UpdateBackoff func(actualUrl *url.URL, err error, responseCode int) + type Config struct + APIPath string + AuthConfigPersister AuthProviderConfigPersister + AuthProvider *clientcmdapi.AuthProviderConfig + BearerToken string + Burst int + Host string + Impersonate string + Insecure bool + Password string + Prefix string + QPS float32 + RateLimiter flowcontrol.RateLimiter + Transport http.RoundTripper + UserAgent string + Username string + WrapTransport func(rt http.RoundTripper) http.RoundTripper + func AddUserAgent(config *Config, userAgent string) *Config + func InClusterConfig() (*Config, error) + type ContentConfig struct + AcceptContentTypes string + ContentType string + GroupVersion *unversioned.GroupVersion + NegotiatedSerializer runtime.NegotiatedSerializer + type Factory func(clusterAddress string, config map[string]string, ...) (AuthProvider, error) + type HTTPClient interface + Do func(req *http.Request) (*http.Response, error) + type NoBackoff struct + func (n *NoBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration + func (n *NoBackoff) Sleep(d time.Duration) + func (n *NoBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int) + type RESTClient struct + Client *http.Client + Throttle flowcontrol.RateLimiter + func NewRESTClient(baseURL *url.URL, versionedAPIPath string, config ContentConfig, ...) (*RESTClient, error) + func RESTClientFor(config *Config) (*RESTClient, error) + func UnversionedRESTClientFor(config *Config) (*RESTClient, error) + func (c *RESTClient) APIVersion() unversioned.GroupVersion + func (c *RESTClient) Delete() *Request + func (c *RESTClient) Get() *Request + func (c *RESTClient) GetRateLimiter() flowcontrol.RateLimiter + 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 Request struct + func NewRequest(client HTTPClient, verb string, baseURL *url.URL, versionedAPIPath 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) VersionedParams(obj runtime.Object, codec runtime.ParameterCodec) *Request + func (r *Request) Watch() (watch.Interface, error) + type RequestConstructionError struct + Err error + func (r *RequestConstructionError) Error() string + 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 Serializers struct + Decoder runtime.Decoder + Encoder runtime.Encoder + Framer runtime.Framer + RenegotiatedDecoder func(contentType string, params map[string]string) (runtime.Decoder, error) + StreamingSerializer runtime.Serializer + type TLSClientConfig struct + CAData []byte + CAFile string + CertData []byte + CertFile string + KeyData []byte + KeyFile string + type URLBackoff struct + Backoff *flowcontrol.Backoff + func (b *URLBackoff) CalculateBackoff(actualUrl *url.URL) time.Duration + func (b *URLBackoff) Disable() + func (b *URLBackoff) Sleep(d time.Duration) + func (b *URLBackoff) UpdateBackoff(actualUrl *url.URL, err error, responseCode int)
Go to main page