Documentation ¶
Overview ¶
Package http provides an HTTP client for kubernetes
Index ¶
- func SetCA(cert []byte) func(*Client) error
- func SetCAFromFile(path string) func(*Client) error
- func SetClient(client *http.Client) func(*Client) error
- func SetClientCert(cert []byte) func(*Client) error
- func SetClientCertFromFile(path string) func(*Client) error
- func SetClientKey(key []byte) func(*Client) error
- func SetClientKeyFromFile(path string) func(*Client) error
- func SetInsecureSkipVerify(skip bool) func(*Client) error
- func SetPassword(password string) func(*Client) error
- func SetServer(server string) func(*Client) error
- func SetToken(token string) func(*Client) error
- func SetUsername(username string) func(*Client) error
- type Client
- func (c *Client) CreateConfigMap(namespace string, item *k8s.ConfigMap) (*k8s.ConfigMap, error)
- func (c *Client) CreateDaemonSet(namespace string, item *k8s.DaemonSet) (*k8s.DaemonSet, error)
- func (c *Client) CreateDeployment(namespace string, item *k8s.Deployment) (*k8s.Deployment, error)
- func (c *Client) CreateEndpoints(namespace string, item *k8s.Endpoints) (*k8s.Endpoints, error)
- func (c *Client) CreateHorizontalPodAutoscaler(namespace string, item *k8s.HorizontalPodAutoscaler) (*k8s.HorizontalPodAutoscaler, error)
- func (c *Client) CreateIngress(namespace string, item *k8s.Ingress) (*k8s.Ingress, error)
- func (c *Client) CreateJob(namespace string, item *k8s.Job) (*k8s.Job, error)
- func (c *Client) CreateNamespace(item *k8s.Namespace) (*k8s.Namespace, error)
- func (c *Client) CreateNode(item *k8s.Node) (*k8s.Node, error)
- func (c *Client) CreatePod(namespace string, item *k8s.Pod) (*k8s.Pod, error)
- func (c *Client) CreateReplicaSet(namespace string, item *k8s.ReplicaSet) (*k8s.ReplicaSet, error)
- func (c *Client) CreateSecret(namespace string, item *k8s.Secret) (*k8s.Secret, error)
- func (c *Client) CreateService(namespace string, item *k8s.Service) (*k8s.Service, error)
- func (c *Client) CreateServiceAccount(namespace string, item *k8s.ServiceAccount) (*k8s.ServiceAccount, error)
- func (c *Client) DeleteConfigMap(namespace, name string) error
- func (c *Client) DeleteDaemonSet(namespace, name string) error
- func (c *Client) DeleteDeployment(namespace, name string) error
- func (c *Client) DeleteEndpoints(namespace, name string) error
- func (c *Client) DeleteHorizontalPodAutoscaler(namespace, name string) error
- func (c *Client) DeleteIngress(namespace, name string) error
- func (c *Client) DeleteJob(namespace, name string) error
- func (c *Client) DeleteNamespace(name string) error
- func (c *Client) DeleteNode(name string) error
- func (c *Client) DeletePod(namespace, name string) error
- func (c *Client) DeleteReplicaSet(namespace, name string) error
- func (c *Client) DeleteSecret(namespace, name string) error
- func (c *Client) DeleteService(namespace, name string) error
- func (c *Client) DeleteServiceAccount(namespace, name string) error
- func (c *Client) GetConfigMap(namespace, name string) (*k8s.ConfigMap, error)
- func (c *Client) GetDaemonSet(namespace, name string) (*k8s.DaemonSet, error)
- func (c *Client) GetDeployment(namespace, name string) (*k8s.Deployment, error)
- func (c *Client) GetEndpoints(namespace, name string) (*k8s.Endpoints, error)
- func (c *Client) GetHorizontalPodAutoscaler(namespace, name string) (*k8s.HorizontalPodAutoscaler, error)
- func (c *Client) GetIngress(namespace, name string) (*k8s.Ingress, error)
- func (c *Client) GetJob(namespace, name string) (*k8s.Job, error)
- func (c *Client) GetNamespace(name string) (*k8s.Namespace, error)
- func (c *Client) GetNode(name string) (*k8s.Node, error)
- func (c *Client) GetPod(namespace, name string) (*k8s.Pod, error)
- func (c *Client) GetReplicaSet(namespace, name string) (*k8s.ReplicaSet, error)
- func (c *Client) GetSecret(namespace, name string) (*k8s.Secret, error)
- func (c *Client) GetService(namespace, name string) (*k8s.Service, error)
- func (c *Client) GetServiceAccount(namespace, name string) (*k8s.ServiceAccount, error)
- func (c *Client) ListConfigMaps(namespace string, opts *k8s.ListOptions) (*k8s.ConfigMapList, error)
- func (c *Client) ListDaemonSets(namespace string, opts *k8s.ListOptions) (*k8s.DaemonSetList, error)
- func (c *Client) ListDeployments(namespace string, opts *k8s.ListOptions) (*k8s.DeploymentList, error)
- func (c *Client) ListEndpoints(namespace string, opts *k8s.ListOptions) (*k8s.EndpointsList, error)
- func (c *Client) ListHorizontalPodAutoscalers(namespace string, opts *k8s.ListOptions) (*k8s.HorizontalPodAutoscalerList, error)
- func (c *Client) ListIngresses(namespace string, opts *k8s.ListOptions) (*k8s.IngressList, error)
- func (c *Client) ListJobs(namespace string, opts *k8s.ListOptions) (*k8s.JobList, error)
- func (c *Client) ListNamespaces(opts *k8s.ListOptions) (*k8s.NamespaceList, error)
- func (c *Client) ListNodes(opts *k8s.ListOptions) (*k8s.NodeList, error)
- func (c *Client) ListPods(namespace string, opts *k8s.ListOptions) (*k8s.PodList, error)
- func (c *Client) ListReplicaSets(namespace string, opts *k8s.ListOptions) (*k8s.ReplicaSetList, error)
- func (c *Client) ListSecrets(namespace string, opts *k8s.ListOptions) (*k8s.SecretList, error)
- func (c *Client) ListServiceAccounts(namespace string, opts *k8s.ListOptions) (*k8s.ServiceAccountList, error)
- func (c *Client) ListServices(namespace string, opts *k8s.ListOptions) (*k8s.ServiceList, error)
- func (c *Client) UpdateConfigMap(namespace string, item *k8s.ConfigMap) (*k8s.ConfigMap, error)
- func (c *Client) UpdateDaemonSet(namespace string, item *k8s.DaemonSet) (*k8s.DaemonSet, error)
- func (c *Client) UpdateDeployment(namespace string, item *k8s.Deployment) (*k8s.Deployment, error)
- func (c *Client) UpdateEndpoints(namespace string, item *k8s.Endpoints) (*k8s.Endpoints, error)
- func (c *Client) UpdateHorizontalPodAutoscaler(namespace string, item *k8s.HorizontalPodAutoscaler) (*k8s.HorizontalPodAutoscaler, error)
- func (c *Client) UpdateIngress(namespace string, item *k8s.Ingress) (*k8s.Ingress, error)
- func (c *Client) UpdateJob(namespace string, item *k8s.Job) (*k8s.Job, error)
- func (c *Client) UpdateNamespace(item *k8s.Namespace) (*k8s.Namespace, error)
- func (c *Client) UpdateNode(item *k8s.Node) (*k8s.Node, error)
- func (c *Client) UpdatePod(namespace string, item *k8s.Pod) (*k8s.Pod, error)
- func (c *Client) UpdateReplicaSet(namespace string, item *k8s.ReplicaSet) (*k8s.ReplicaSet, error)
- func (c *Client) UpdateSecret(namespace string, item *k8s.Secret) (*k8s.Secret, error)
- func (c *Client) UpdateService(namespace string, item *k8s.Service) (*k8s.Service, error)
- func (c *Client) UpdateServiceAccount(namespace string, item *k8s.ServiceAccount) (*k8s.ServiceAccount, error)
- func (c *Client) WatchConfigMaps(namespace string, opts *k8s.WatchOptions, events chan k8s.ConfigMapWatchEvent) error
- func (c *Client) WatchDaemonSets(namespace string, opts *k8s.WatchOptions, events chan k8s.DaemonSetWatchEvent) error
- func (c *Client) WatchDeployments(namespace string, opts *k8s.WatchOptions, events chan k8s.DeploymentWatchEvent) error
- func (c *Client) WatchEndpoints(namespace string, opts *k8s.WatchOptions, events chan k8s.EndpointsWatchEvent) error
- func (c *Client) WatchHorizontalPodAutoscalers(namespace string, opts *k8s.WatchOptions, ...) error
- func (c *Client) WatchIngresses(namespace string, opts *k8s.WatchOptions, events chan k8s.IngressWatchEvent) error
- func (c *Client) WatchJobs(namespace string, opts *k8s.WatchOptions, events chan k8s.JobWatchEvent) error
- func (c *Client) WatchNamespaces(opts *k8s.WatchOptions, events chan k8s.NamespaceWatchEvent) error
- func (c *Client) WatchNodes(opts *k8s.WatchOptions, events chan k8s.NodeWatchEvent) error
- func (c *Client) WatchPods(namespace string, opts *k8s.WatchOptions, events chan k8s.PodWatchEvent) error
- func (c *Client) WatchReplicaSets(namespace string, opts *k8s.WatchOptions, events chan k8s.ReplicaSetWatchEvent) error
- func (c *Client) WatchSecrets(namespace string, opts *k8s.WatchOptions, events chan k8s.SecretWatchEvent) error
- func (c *Client) WatchServiceAccounts(namespace string, opts *k8s.WatchOptions, ...) error
- func (c *Client) WatchServices(namespace string, opts *k8s.WatchOptions, events chan k8s.ServiceWatchEvent) error
- type OptionsFunc
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetCAFromFile ¶
SetCA sets a CA to verify the servers certificate from a file
func SetClientCert ¶
SetClientCert sets the certificate to be used for authentication.
func SetClientCertFromFile ¶
SetClientCertFromFile sets the certificate to be used for authentication from a file.
func SetClientKey ¶
SetClientKey sets the key to be used for authentication.
func SetClientKeyFromFile ¶
SetClientKeyFromFile sets the key to be used for authentication from a file.
func SetInsecureSkipVerify ¶
SetInsecureSkipVerify allows the caller to skip verification of the servers cert
func SetPassword ¶
SetPassword sets the password to be used for authentication.
func SetToken ¶
SetToken sets the token to be used for authentication. If this is set, it takes precedence.
func SetUsername ¶
SetUsername sets the username to be used for authentication.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is an http client for kubernetes
func New ¶
func New(options ...OptionsFunc) (*Client, error)
New creates a new client.
Example ¶
package main import ( "fmt" "os" "github.com/bakins/k8s-client/http" ) func main() { // get server from environment server := os.Getenv("K8S_SERVER") if server == "" { server = "http://127.0.0.1:8001" } opts := []http.OptionsFunc{ http.SetServer(server), } if caFile := os.Getenv("K8S_CAFILE"); caFile != "" { opts = append(opts, http.SetCAFromFile(caFile)) } if token := os.Getenv("K8S_TOKEN"); token != "" { opts = append(opts, http.SetToken(token)) } // create a new client using the options c, err := http.New(opts...) if err != nil { // handle the error } // get a list of all the name spaces list, err := c.ListNamespaces(nil) if err != nil { // handle the error } for _, v := range list.Items { fmt.Println(v.Name) } }
Output:
func NewInCluster ¶
NewInCluster creates a cluster suitable for use within the kubernetes cluster.
Example ¶
package main import ( "fmt" "github.com/bakins/k8s-client/http" ) func main() { // NewInCluster will use the environment and the service account files to create a new client c, err := http.NewInCluster() // get a list of all the name spaces list, err := c.ListNamespaces(nil) if err != nil { // handle the error } for _, v := range list.Items { fmt.Println(v.Name) } }
Output:
func (*Client) CreateConfigMap ¶
CreateConfigMap creates a new ConfigMap. This will fail if it already exists.
func (*Client) CreateDaemonSet ¶
CreateDaemonSet creates a new DaemonSet. This will fail if it already exists.
func (*Client) CreateDeployment ¶
func (c *Client) CreateDeployment(namespace string, item *k8s.Deployment) (*k8s.Deployment, error)
CreateDeployment creates a new Deployment. This will fail if it already exists.
func (*Client) CreateEndpoints ¶
CreateEndpoints creates a new Endpoints. This will fail if it already exists.
func (*Client) CreateHorizontalPodAutoscaler ¶
func (c *Client) CreateHorizontalPodAutoscaler(namespace string, item *k8s.HorizontalPodAutoscaler) (*k8s.HorizontalPodAutoscaler, error)
CreateHorizontalPodAutoscaler creates a new HorizontalPodAutoscaler. This will fail if it already exists.
func (*Client) CreateIngress ¶
CreateIngress creates a new Ingress. This will fail if it already exists.
func (*Client) CreateNamespace ¶
CreateNamespace creates a new namespace. It will fail if the namespace already exists.
func (*Client) CreateNode ¶
CreateNode creates a single node. It will fail if it already exists.
func (*Client) CreateReplicaSet ¶
func (c *Client) CreateReplicaSet(namespace string, item *k8s.ReplicaSet) (*k8s.ReplicaSet, error)
CreateReplicaSet creates a new ReplicaSet. This will fail if it already exists.
func (*Client) CreateSecret ¶
CreateSecret creates a new Secret. This will fail if it already exists.
func (*Client) CreateService ¶
CreateService creates a new Service. This will fail if it already exists.
func (*Client) CreateServiceAccount ¶
func (c *Client) CreateServiceAccount(namespace string, item *k8s.ServiceAccount) (*k8s.ServiceAccount, error)
CreateServiceAccount creates a new ServiceAccount. This will fail if it already exists.
func (*Client) DeleteConfigMap ¶
DeleteConfigMap deletes a single ConfigMap. It will error if the ConfigMap does not exist.
func (*Client) DeleteDaemonSet ¶
DeleteDaemonSet deletes a single DaemonSet. It will error if the DaemonSet does not exist.
func (*Client) DeleteDeployment ¶
DeleteDeployment deletes a single Deployment. It will error if the Deployment does not exist.
func (*Client) DeleteEndpoints ¶
DeleteEndpoints deletes a single Endpoints. It will error if the Endpoints does not exist.
func (*Client) DeleteHorizontalPodAutoscaler ¶
DeleteHorizontalPodAutoscaler deletes a single HorizontalPodAutoscaler. It will error if the HorizontalPodAutoscaler does not exist.
func (*Client) DeleteIngress ¶
DeleteIngress deletes a single Ingress. It will error if the Ingress does not exist.
func (*Client) DeleteNamespace ¶
DeleteNamespace deletes a single namespace. It will error it it does not exist.
func (*Client) DeleteNode ¶
DeleteNode removes a single node.
func (*Client) DeleteReplicaSet ¶
DeleteReplicaSet deletes a single ReplicaSet. It will error if the ReplicaSet does not exist.
func (*Client) DeleteSecret ¶
DeleteSecret deletes a single Secret. It will error if the Secret does not exist.
func (*Client) DeleteService ¶
DeleteService deletes a single Service. It will error if the Service does not exist.
func (*Client) DeleteServiceAccount ¶
DeleteServiceAccount deletes a single ServiceAccount. It will error if the ServiceAccount does not exist.
func (*Client) GetConfigMap ¶
GetConfigMap fetches a single ConfigMap
func (*Client) GetDaemonSet ¶
GetDaemonSet fetches a single DaemonSet
func (*Client) GetDeployment ¶
func (c *Client) GetDeployment(namespace, name string) (*k8s.Deployment, error)
GetDeployment fetches a single Deployment
func (*Client) GetEndpoints ¶
GetEndpoints fetches a single Endpoints
func (*Client) GetHorizontalPodAutoscaler ¶
func (c *Client) GetHorizontalPodAutoscaler(namespace, name string) (*k8s.HorizontalPodAutoscaler, error)
GetHorizontalPodAutoscaler fetches a single HorizontalPodAutoscaler
func (*Client) GetIngress ¶
GetIngress fetches a single Ingress
func (*Client) GetNamespace ¶
GetNamespace gets a namespace
func (*Client) GetReplicaSet ¶
func (c *Client) GetReplicaSet(namespace, name string) (*k8s.ReplicaSet, error)
GetReplicaSet fetches a single ReplicaSet
func (*Client) GetService ¶
GetService fetches a single Service
func (*Client) GetServiceAccount ¶
func (c *Client) GetServiceAccount(namespace, name string) (*k8s.ServiceAccount, error)
GetServiceAccount fetches a single ServiceAccount
func (*Client) ListConfigMaps ¶
func (c *Client) ListConfigMaps(namespace string, opts *k8s.ListOptions) (*k8s.ConfigMapList, error)
ListConfigMaps lists all ConfigMaps in a namespace
func (*Client) ListDaemonSets ¶
func (c *Client) ListDaemonSets(namespace string, opts *k8s.ListOptions) (*k8s.DaemonSetList, error)
ListDaemonSets lists all DaemonSets in a namespace
func (*Client) ListDeployments ¶
func (c *Client) ListDeployments(namespace string, opts *k8s.ListOptions) (*k8s.DeploymentList, error)
ListDeployments lists all Deployments in a namespace
func (*Client) ListEndpoints ¶
func (c *Client) ListEndpoints(namespace string, opts *k8s.ListOptions) (*k8s.EndpointsList, error)
ListEndpoints lists all Endpointss in a namespace
func (*Client) ListHorizontalPodAutoscalers ¶
func (c *Client) ListHorizontalPodAutoscalers(namespace string, opts *k8s.ListOptions) (*k8s.HorizontalPodAutoscalerList, error)
ListHorizontalPodAutoscalers lists all HorizontalPodAutoscalers in a namespace
func (*Client) ListIngresses ¶
func (c *Client) ListIngresses(namespace string, opts *k8s.ListOptions) (*k8s.IngressList, error)
ListIngresses lists all Ingresss in a namespace
func (*Client) ListNamespaces ¶
func (c *Client) ListNamespaces(opts *k8s.ListOptions) (*k8s.NamespaceList, error)
ListNamespaces list all namespaces, optionally filtering.
func (*Client) ListReplicaSets ¶
func (c *Client) ListReplicaSets(namespace string, opts *k8s.ListOptions) (*k8s.ReplicaSetList, error)
ListReplicaSets lists all ReplicaSets in a namespace
func (*Client) ListSecrets ¶
func (c *Client) ListSecrets(namespace string, opts *k8s.ListOptions) (*k8s.SecretList, error)
ListSecrets lists all Secrets in a namespace
func (*Client) ListServiceAccounts ¶
func (c *Client) ListServiceAccounts(namespace string, opts *k8s.ListOptions) (*k8s.ServiceAccountList, error)
ListServiceAccounts lists all ServiceAccounts in a namespace
func (*Client) ListServices ¶
func (c *Client) ListServices(namespace string, opts *k8s.ListOptions) (*k8s.ServiceList, error)
ListServices lists all Services in a namespace
func (*Client) UpdateConfigMap ¶
UpdateConfigMap will update in place a single ConfigMap. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateDaemonSet ¶
UpdateDaemonSet will update in place a single DaemonSet. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateDeployment ¶
func (c *Client) UpdateDeployment(namespace string, item *k8s.Deployment) (*k8s.Deployment, error)
UpdateDeployment will update in place a single Deployment. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateEndpoints ¶
UpdateEndpoints will update in place a single Endpoints. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateHorizontalPodAutoscaler ¶
func (c *Client) UpdateHorizontalPodAutoscaler(namespace string, item *k8s.HorizontalPodAutoscaler) (*k8s.HorizontalPodAutoscaler, error)
UpdateHorizontalPodAutoscaler will update in place a single HorizontalPodAutoscaler. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateIngress ¶
UpdateIngress will update in place a single Ingress. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateJob ¶
UpdateJob will update in place a single Job. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateNamespace ¶
UpdateNamespace updates a namespace.
func (*Client) UpdateNode ¶
UpdateNode updates s sinle node.
func (*Client) UpdatePod ¶
UpdatePod will update in place a single Pod. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateReplicaSet ¶
func (c *Client) UpdateReplicaSet(namespace string, item *k8s.ReplicaSet) (*k8s.ReplicaSet, error)
UpdateReplicaSet will update in place a single ReplicaSet. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateSecret ¶
UpdateSecret will update in place a single Secret. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateService ¶
UpdateService will update in place a single Service. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) UpdateServiceAccount ¶
func (c *Client) UpdateServiceAccount(namespace string, item *k8s.ServiceAccount) (*k8s.ServiceAccount, error)
UpdateServiceAccount will update in place a single ServiceAccount. Generally, you should call Get and then use that object for updates to ensure resource versions avoid update conflicts
func (*Client) WatchConfigMaps ¶
func (c *Client) WatchConfigMaps(namespace string, opts *k8s.WatchOptions, events chan k8s.ConfigMapWatchEvent) error
WatchConfigMaps watches all ConfigMap changes in a namespace
func (*Client) WatchDaemonSets ¶
func (c *Client) WatchDaemonSets(namespace string, opts *k8s.WatchOptions, events chan k8s.DaemonSetWatchEvent) error
WatchDaemonSets watches all DaemonSet changes in a namespace
func (*Client) WatchDeployments ¶
func (c *Client) WatchDeployments(namespace string, opts *k8s.WatchOptions, events chan k8s.DeploymentWatchEvent) error
WatchDeployments watches all Deployment changes in a namespace
func (*Client) WatchEndpoints ¶
func (c *Client) WatchEndpoints(namespace string, opts *k8s.WatchOptions, events chan k8s.EndpointsWatchEvent) error
WatchEndpoints watches all Endpoints changes in a namespace
func (*Client) WatchHorizontalPodAutoscalers ¶
func (c *Client) WatchHorizontalPodAutoscalers(namespace string, opts *k8s.WatchOptions, events chan k8s.HorizontalPodAutoscalerWatchEvent) error
WatchHorizontalPodAutoscalers watches all HorizontalPodAutoscaler changes in a namespace
func (*Client) WatchIngresses ¶
func (c *Client) WatchIngresses(namespace string, opts *k8s.WatchOptions, events chan k8s.IngressWatchEvent) error
WatchIngresses watches all Ingress changes in a namespace
func (*Client) WatchJobs ¶
func (c *Client) WatchJobs(namespace string, opts *k8s.WatchOptions, events chan k8s.JobWatchEvent) error
WatchJobs watches all Job changes in a namespace
func (*Client) WatchNamespaces ¶
func (c *Client) WatchNamespaces(opts *k8s.WatchOptions, events chan k8s.NamespaceWatchEvent) error
WatchNamespaces watches all Namespaces changes
func (*Client) WatchNodes ¶
func (c *Client) WatchNodes(opts *k8s.WatchOptions, events chan k8s.NodeWatchEvent) error
WatchNodes watches all Nodes changes
func (*Client) WatchPods ¶
func (c *Client) WatchPods(namespace string, opts *k8s.WatchOptions, events chan k8s.PodWatchEvent) error
WatchPods watches all Pod changes in a namespace
func (*Client) WatchReplicaSets ¶
func (c *Client) WatchReplicaSets(namespace string, opts *k8s.WatchOptions, events chan k8s.ReplicaSetWatchEvent) error
WatchReplicaSets watches all ReplicaSet changes in a namespace
func (*Client) WatchSecrets ¶
func (c *Client) WatchSecrets(namespace string, opts *k8s.WatchOptions, events chan k8s.SecretWatchEvent) error
WatchSecrets watches all Secret changes in a namespace
func (*Client) WatchServiceAccounts ¶
func (c *Client) WatchServiceAccounts(namespace string, opts *k8s.WatchOptions, events chan k8s.ServiceAccountWatchEvent) error
WatchServiceAccounts watches all ServiceAccount changes in a namespace
func (*Client) WatchServices ¶
func (c *Client) WatchServices(namespace string, opts *k8s.WatchOptions, events chan k8s.ServiceWatchEvent) error
WatchServices watches all Service changes in a namespace
type OptionsFunc ¶
OptionsFunc is a function passed to new for setting options on a new client.