testclient

package
v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 7, 2017 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddObjectsFromPath

func AddObjectsFromPath(path string, o ObjectRetriever, decoder runtime.Decoder) error

AddObjectsFromPath loads the JSON or YAML file containing Kubernetes API resources and adds them to the provided ObjectRetriever.

Types

type Action

type Action interface {
	GetNamespace() string
	GetVerb() string
	GetResource() string
	GetSubresource() string
	Matches(verb, resource string) bool
}

type ActionImpl

type ActionImpl struct {
	Namespace   string
	Verb        string
	Resource    string
	Subresource string
}

func (ActionImpl) GetNamespace

func (a ActionImpl) GetNamespace() string

func (ActionImpl) GetResource

func (a ActionImpl) GetResource() string

func (ActionImpl) GetSubresource

func (a ActionImpl) GetSubresource() string

func (ActionImpl) GetVerb

func (a ActionImpl) GetVerb() string

func (ActionImpl) Matches

func (a ActionImpl) Matches(verb, resource string) bool

type CreateAction

type CreateAction interface {
	Action
	GetObject() runtime.Object
}

type CreateActionImpl

type CreateActionImpl struct {
	ActionImpl
	Object runtime.Object
}

func NewCreateAction

func NewCreateAction(resource, namespace string, object runtime.Object) CreateActionImpl

func NewRootCreateAction

func NewRootCreateAction(resource string, object runtime.Object) CreateActionImpl

func (CreateActionImpl) GetObject

func (a CreateActionImpl) GetObject() runtime.Object

type DeleteAction

type DeleteAction interface {
	Action
	GetName() string
}

type DeleteActionImpl

type DeleteActionImpl struct {
	ActionImpl
	Name string
}

func NewDeleteAction

func NewDeleteAction(resource, namespace, name string) DeleteActionImpl

func NewRootDeleteAction

func NewRootDeleteAction(resource, name string) DeleteActionImpl

func (DeleteActionImpl) GetName

func (a DeleteActionImpl) GetName() string

type DeleteCollectionActionImpl added in v0.3.0

type DeleteCollectionActionImpl struct {
	ActionImpl
	ListRestrictions ListRestrictions
}

func NewDeleteCollectionAction added in v0.3.0

func NewDeleteCollectionAction(resource, namespace string, opts api.ListOptions) DeleteCollectionActionImpl

func NewRootDeleteCollectionAction added in v0.3.0

func NewRootDeleteCollectionAction(resource string, opts api.ListOptions) DeleteCollectionActionImpl

func (DeleteCollectionActionImpl) GetListRestrictions added in v0.3.0

func (a DeleteCollectionActionImpl) GetListRestrictions() ListRestrictions

type Fake

type Fake struct {
	sync.RWMutex

	// ReactionChain is the list of reactors that will be attempted for every request in the order they are tried
	ReactionChain []Reactor
	// WatchReactionChain is the list of watch reactors that will be attempted for every request in the order they are tried
	WatchReactionChain []WatchReactor
	// ProxyReactionChain is the list of proxy reactors that will be attempted for every request in the order they are tried
	ProxyReactionChain []ProxyReactor

	Resources map[string]*unversioned.APIResourceList
	// contains filtered or unexported fields
}

Fake implements client.Interface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func NewSimpleFake

func NewSimpleFake(objects ...runtime.Object) *Fake

NewSimpleFake returns a client that will respond with the provided objects

func (*Fake) Actions

func (c *Fake) Actions() []Action

Actions returns a chronologically ordered slice fake actions called on the fake client

func (*Fake) AddProxyReactor

func (c *Fake) AddProxyReactor(resource string, reaction ProxyReactionFunc)

AddProxyReactor appends a reactor to the end of the chain

func (*Fake) AddReactor

func (c *Fake) AddReactor(verb, resource string, reaction ReactionFunc)

AddReactor appends a reactor to the end of the chain

func (*Fake) AddWatchReactor

func (c *Fake) AddWatchReactor(resource string, reaction WatchReactionFunc)

AddWatchReactor appends a reactor to the end of the chain

func (*Fake) Autoscaling added in v0.4.0

func (c *Fake) Autoscaling() client.AutoscalingInterface

func (*Fake) Batch added in v0.4.0

func (c *Fake) Batch() client.BatchInterface

func (*Fake) ClearActions

func (c *Fake) ClearActions()

ClearActions clears the history of actions called on the fake client

func (*Fake) ComponentStatuses

func (c *Fake) ComponentStatuses() client.ComponentStatusInterface

func (*Fake) ConfigMaps added in v0.4.0

func (c *Fake) ConfigMaps(namespace string) client.ConfigMapsInterface

func (*Fake) Discovery added in v0.3.0

func (c *Fake) Discovery() discovery.DiscoveryInterface

func (*Fake) Endpoints

func (c *Fake) Endpoints(namespace string) client.EndpointsInterface

func (*Fake) Events

func (c *Fake) Events(namespace string) client.EventInterface

func (*Fake) Extensions added in v0.3.0

func (c *Fake) Extensions() client.ExtensionsInterface

func (*Fake) Invokes

func (c *Fake) Invokes(action Action, defaultReturnObj runtime.Object) (runtime.Object, error)

Invokes records the provided Action and then invokes the ReactFn (if provided). defaultReturnObj is expected to be of the same type a normal call would return.

func (*Fake) InvokesProxy

func (c *Fake) InvokesProxy(action Action) restclient.ResponseWrapper

InvokesProxy records the provided Action and then invokes the ReactFn (if provided).

func (*Fake) InvokesWatch

func (c *Fake) InvokesWatch(action Action) (watch.Interface, error)

InvokesWatch records the provided Action and then invokes the ReactFn (if provided).

func (*Fake) LimitRanges

func (c *Fake) LimitRanges(namespace string) client.LimitRangeInterface

func (*Fake) Namespaces

func (c *Fake) Namespaces() client.NamespaceInterface

func (*Fake) Networks

func (c *Fake) Networks() client.NetworkInterface

func (*Fake) Nodes

func (c *Fake) Nodes() client.NodeInterface

func (*Fake) PersistentVolumeClaims

func (c *Fake) PersistentVolumeClaims(namespace string) client.PersistentVolumeClaimInterface

func (*Fake) PersistentVolumes

func (c *Fake) PersistentVolumes() client.PersistentVolumeInterface

func (*Fake) PodSecurityPolicies added in v0.4.0

func (c *Fake) PodSecurityPolicies() client.PodSecurityPolicyInterface

func (*Fake) PodTemplates

func (c *Fake) PodTemplates(namespace string) client.PodTemplateInterface

func (*Fake) Pods

func (c *Fake) Pods(namespace string) client.PodInterface

func (*Fake) PrependProxyReactor

func (c *Fake) PrependProxyReactor(resource string, reaction ProxyReactionFunc)

PrependProxyReactor adds a reactor to the beginning of the chain

func (*Fake) PrependReactor

func (c *Fake) PrependReactor(verb, resource string, reaction ReactionFunc)

PrependReactor adds a reactor to the beginning of the chain

func (*Fake) PrependWatchReactor

func (c *Fake) PrependWatchReactor(resource string, reaction WatchReactionFunc)

PrependWatchReactor adds a reactor to the beginning of the chain

func (*Fake) Rbac added in v1.3.0

func (c *Fake) Rbac() client.RbacInterface

func (*Fake) ReplicationControllers

func (c *Fake) ReplicationControllers(namespace string) client.ReplicationControllerInterface

func (*Fake) ResourceQuotas

func (c *Fake) ResourceQuotas(namespace string) client.ResourceQuotaInterface

func (*Fake) Secrets

func (c *Fake) Secrets(namespace string) client.SecretsInterface

func (*Fake) ServiceAccounts

func (c *Fake) ServiceAccounts(namespace string) client.ServiceAccountsInterface

func (*Fake) Services

func (c *Fake) Services(namespace string) client.ServiceInterface

func (*Fake) SwaggerSchema

func (c *Fake) SwaggerSchema(version unversioned.GroupVersion) (*swagger.ApiDeclaration, error)

SwaggerSchema returns an empty swagger.ApiDeclaration for testing

type FakeAutoscaling added in v0.4.0

type FakeAutoscaling struct {
	*Fake
}

func NewSimpleFakeAutoscaling added in v0.4.0

func NewSimpleFakeAutoscaling(objects ...runtime.Object) *FakeAutoscaling

NewSimpleFakeAutoscaling returns a client that will respond with the provided objects

func (*FakeAutoscaling) HorizontalPodAutoscalers added in v0.4.0

func (c *FakeAutoscaling) HorizontalPodAutoscalers(namespace string) client.HorizontalPodAutoscalerInterface

type FakeBatch added in v0.4.0

type FakeBatch struct {
	*Fake
}

func NewSimpleFakeBatch added in v0.4.0

func NewSimpleFakeBatch(objects ...runtime.Object) *FakeBatch

NewSimpleFakeBatch returns a client that will respond with the provided objects

func (*FakeBatch) Jobs added in v0.4.0

func (c *FakeBatch) Jobs(namespace string) client.JobInterface

func (*FakeBatch) ScheduledJobs added in v1.3.0

func (c *FakeBatch) ScheduledJobs(namespace string) client.ScheduledJobInterface

type FakeClusterRoleBindings added in v1.3.0

type FakeClusterRoleBindings struct {
	Fake *FakeRbac
}

FakeClusterRoleBindings implements ClusterRoleBindingInterface

func (*FakeClusterRoleBindings) Create added in v1.3.0

func (*FakeClusterRoleBindings) Delete added in v1.3.0

func (c *FakeClusterRoleBindings) Delete(name string, opts *api.DeleteOptions) error

func (*FakeClusterRoleBindings) Get added in v1.3.0

func (*FakeClusterRoleBindings) List added in v1.3.0

func (*FakeClusterRoleBindings) Update added in v1.3.0

func (*FakeClusterRoleBindings) Watch added in v1.3.0

type FakeClusterRoles added in v1.3.0

type FakeClusterRoles struct {
	Fake *FakeRbac
}

FakeClusterRoles implements ClusterRoleInterface

func (*FakeClusterRoles) Create added in v1.3.0

func (c *FakeClusterRoles) Create(csr *rbac.ClusterRole) (*rbac.ClusterRole, error)

func (*FakeClusterRoles) Delete added in v1.3.0

func (c *FakeClusterRoles) Delete(name string, opts *api.DeleteOptions) error

func (*FakeClusterRoles) Get added in v1.3.0

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

func (*FakeClusterRoles) List added in v1.3.0

func (*FakeClusterRoles) Update added in v1.3.0

func (c *FakeClusterRoles) Update(csr *rbac.ClusterRole) (*rbac.ClusterRole, error)

func (*FakeClusterRoles) Watch added in v1.3.0

type FakeComponentStatuses

type FakeComponentStatuses struct {
	Fake *Fake
}

Fake implements ComponentStatusInterface.

func (*FakeComponentStatuses) Get

func (*FakeComponentStatuses) List

func (c *FakeComponentStatuses) List(opts api.ListOptions) (result *api.ComponentStatusList, err error)

type FakeConfigMaps added in v0.3.0

type FakeConfigMaps struct {
	Fake      *Fake
	Namespace string
}

FakeConfigMaps implements ConfigMapInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeConfigMaps) Create added in v0.3.0

func (c *FakeConfigMaps) Create(cfg *api.ConfigMap) (*api.ConfigMap, error)

func (*FakeConfigMaps) Delete added in v0.3.0

func (c *FakeConfigMaps) Delete(name string) error

func (*FakeConfigMaps) Get added in v0.3.0

func (c *FakeConfigMaps) Get(name string) (*api.ConfigMap, error)

func (*FakeConfigMaps) List added in v0.3.0

func (*FakeConfigMaps) Update added in v0.3.0

func (c *FakeConfigMaps) Update(cfg *api.ConfigMap) (*api.ConfigMap, error)

func (*FakeConfigMaps) Watch added in v0.3.0

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

type FakeDaemonSets

type FakeDaemonSets struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeDaemonSet implements DaemonInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeDaemonSets) Create

func (*FakeDaemonSets) Delete

func (c *FakeDaemonSets) Delete(name string) error

func (*FakeDaemonSets) Get

func (c *FakeDaemonSets) Get(name string) (*extensions.DaemonSet, error)

func (*FakeDaemonSets) List

func (*FakeDaemonSets) Update

func (*FakeDaemonSets) UpdateStatus

func (c *FakeDaemonSets) UpdateStatus(daemon *extensions.DaemonSet) (*extensions.DaemonSet, error)

func (*FakeDaemonSets) Watch

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

type FakeDeployments

type FakeDeployments struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeDeployments implements DeploymentInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeDeployments) Create

func (c *FakeDeployments) Create(deployment *extensions.Deployment) (*extensions.Deployment, error)

func (*FakeDeployments) Delete

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

func (*FakeDeployments) Get

func (*FakeDeployments) List

func (*FakeDeployments) Rollback added in v0.4.0

func (c *FakeDeployments) Rollback(deploymentRollback *extensions.DeploymentRollback) error

func (*FakeDeployments) Update

func (c *FakeDeployments) Update(deployment *extensions.Deployment) (*extensions.Deployment, error)

func (*FakeDeployments) UpdateStatus added in v0.3.0

func (c *FakeDeployments) UpdateStatus(deployment *extensions.Deployment) (*extensions.Deployment, error)

func (*FakeDeployments) Watch

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

type FakeDiscovery added in v0.3.0

type FakeDiscovery struct {
	*Fake
}

func (*FakeDiscovery) ServerGroups added in v0.3.0

func (c *FakeDiscovery) ServerGroups() (*unversioned.APIGroupList, error)

func (*FakeDiscovery) ServerPreferredNamespacedResources added in v1.3.0

func (c *FakeDiscovery) ServerPreferredNamespacedResources() ([]unversioned.GroupVersionResource, error)

func (*FakeDiscovery) ServerPreferredResources added in v1.3.0

func (c *FakeDiscovery) ServerPreferredResources() ([]unversioned.GroupVersionResource, error)

func (*FakeDiscovery) ServerResources added in v0.3.0

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

func (*FakeDiscovery) ServerResourcesForGroupVersion added in v0.3.0

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

func (*FakeDiscovery) ServerVersion added in v0.4.0

func (c *FakeDiscovery) ServerVersion() (*version.Info, error)

type FakeEndpoints

type FakeEndpoints struct {
	Fake      *Fake
	Namespace string
}

FakeEndpoints implements EndpointInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeEndpoints) Create

func (c *FakeEndpoints) Create(endpoints *api.Endpoints) (*api.Endpoints, error)

func (*FakeEndpoints) Delete

func (c *FakeEndpoints) Delete(name string) error

func (*FakeEndpoints) Get

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

func (*FakeEndpoints) List

func (c *FakeEndpoints) List(opts api.ListOptions) (*api.EndpointsList, error)

func (*FakeEndpoints) Update

func (c *FakeEndpoints) Update(endpoints *api.Endpoints) (*api.Endpoints, error)

func (*FakeEndpoints) Watch

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

type FakeEvents

type FakeEvents struct {
	Fake      *Fake
	Namespace string
}

FakeEvents implements EventInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeEvents) Create

func (c *FakeEvents) Create(event *api.Event) (*api.Event, error)

Create makes a new event. Returns the copy of the event the server returns, or an error.

func (*FakeEvents) Delete

func (c *FakeEvents) Delete(name string) error

func (*FakeEvents) DeleteCollection added in v0.3.0

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

func (*FakeEvents) Get

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

Get returns the given event, or an error.

func (*FakeEvents) GetFieldSelector

func (c *FakeEvents) GetFieldSelector(involvedObjectName, involvedObjectNamespace, involvedObjectKind, involvedObjectUID *string) fields.Selector

func (*FakeEvents) List

func (c *FakeEvents) List(opts api.ListOptions) (*api.EventList, error)

List returns a list of events matching the selectors.

func (*FakeEvents) Patch added in v0.3.0

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

Patch patches an existing event. Returns the copy of the event the server returns, or an error.

func (*FakeEvents) Search

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

Search returns a list of events matching the specified object.

func (*FakeEvents) Update

func (c *FakeEvents) Update(event *api.Event) (*api.Event, error)

Update replaces an existing event. Returns the copy of the event the server returns, or an error.

func (*FakeEvents) Watch

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

Watch starts watching for events matching the given selectors.

type FakeExperimental

type FakeExperimental struct {
	*Fake
}

func NewSimpleFakeExp added in v0.3.0

func NewSimpleFakeExp(objects ...runtime.Object) *FakeExperimental

NewSimpleFakeExp returns a client that will respond with the provided objects

func (*FakeExperimental) DaemonSets

func (c *FakeExperimental) DaemonSets(namespace string) client.DaemonSetInterface

func (*FakeExperimental) Deployments

func (c *FakeExperimental) Deployments(namespace string) client.DeploymentInterface

func (*FakeExperimental) Ingress

func (c *FakeExperimental) Ingress(namespace string) client.IngressInterface

func (*FakeExperimental) Jobs

func (c *FakeExperimental) Jobs(namespace string) client.JobInterface

func (*FakeExperimental) NetworkPolicies added in v1.3.0

func (c *FakeExperimental) NetworkPolicies(namespace string) client.NetworkPolicyInterface

func (*FakeExperimental) ReplicaSets added in v0.4.0

func (c *FakeExperimental) ReplicaSets(namespace string) client.ReplicaSetInterface

func (*FakeExperimental) Scales

func (c *FakeExperimental) Scales(namespace string) client.ScaleInterface

func (*FakeExperimental) ThirdPartyResources added in v0.3.0

func (c *FakeExperimental) ThirdPartyResources() client.ThirdPartyResourceInterface

type FakeHorizontalPodAutoscalers

type FakeHorizontalPodAutoscalers struct {
	Fake      *FakeAutoscaling
	Namespace string
}

FakeHorizontalPodAutoscalers implements HorizontalPodAutoscalerInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeHorizontalPodAutoscalers) Delete

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

func (*FakeHorizontalPodAutoscalers) Get

func (*FakeHorizontalPodAutoscalers) List

func (*FakeHorizontalPodAutoscalers) UpdateStatus added in v0.3.0

func (*FakeHorizontalPodAutoscalers) Watch

type FakeIngress

type FakeIngress struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeIngress implements IngressInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeIngress) Create

func (c *FakeIngress) Create(ingress *extensions.Ingress) (*extensions.Ingress, error)

func (*FakeIngress) Delete

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

func (*FakeIngress) Get

func (c *FakeIngress) Get(name string) (*extensions.Ingress, error)

func (*FakeIngress) List

func (*FakeIngress) Update

func (c *FakeIngress) Update(ingress *extensions.Ingress) (*extensions.Ingress, error)

func (*FakeIngress) UpdateStatus

func (c *FakeIngress) UpdateStatus(ingress *extensions.Ingress) (result *extensions.Ingress, err error)

func (*FakeIngress) Watch

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

type FakeJobs

type FakeJobs struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeJobs implements JobInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeJobs) Create

func (c *FakeJobs) Create(job *batch.Job) (*batch.Job, error)

func (*FakeJobs) Delete

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

func (*FakeJobs) Get

func (c *FakeJobs) Get(name string) (*batch.Job, error)

func (*FakeJobs) List

func (c *FakeJobs) List(opts api.ListOptions) (*batch.JobList, error)

func (*FakeJobs) Update

func (c *FakeJobs) Update(job *batch.Job) (*batch.Job, error)

func (*FakeJobs) UpdateStatus

func (c *FakeJobs) UpdateStatus(job *batch.Job) (result *batch.Job, err error)

func (*FakeJobs) Watch

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

type FakeJobsV1 added in v0.4.0

type FakeJobsV1 struct {
	Fake      *FakeBatch
	Namespace string
}

FakeJobs implements JobInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier. This is a test implementation of JobsV1 TODO(piosz): get back to one client implementation once HPA will be graduated to GA completely

func (*FakeJobsV1) Create added in v0.4.0

func (c *FakeJobsV1) Create(job *batch.Job) (*batch.Job, error)

func (*FakeJobsV1) Delete added in v0.4.0

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

func (*FakeJobsV1) Get added in v0.4.0

func (c *FakeJobsV1) Get(name string) (*batch.Job, error)

func (*FakeJobsV1) List added in v0.4.0

func (c *FakeJobsV1) List(opts api.ListOptions) (*batch.JobList, error)

func (*FakeJobsV1) Update added in v0.4.0

func (c *FakeJobsV1) Update(job *batch.Job) (*batch.Job, error)

func (*FakeJobsV1) UpdateStatus added in v0.4.0

func (c *FakeJobsV1) UpdateStatus(job *batch.Job) (result *batch.Job, err error)

func (*FakeJobsV1) Watch added in v0.4.0

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

type FakeLimitRanges

type FakeLimitRanges struct {
	Fake      *Fake
	Namespace string
}

FakeLimitRanges implements PodsInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeLimitRanges) Create

func (c *FakeLimitRanges) Create(limitRange *api.LimitRange) (*api.LimitRange, error)

func (*FakeLimitRanges) Delete

func (c *FakeLimitRanges) Delete(name string) error

func (*FakeLimitRanges) Get

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

func (*FakeLimitRanges) List

func (*FakeLimitRanges) Update

func (c *FakeLimitRanges) Update(limitRange *api.LimitRange) (*api.LimitRange, error)

func (*FakeLimitRanges) Watch

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

type FakeNamespaces

type FakeNamespaces struct {
	Fake *Fake
}

FakeNamespaces implements NamespacesInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeNamespaces) Create

func (c *FakeNamespaces) Create(namespace *api.Namespace) (*api.Namespace, error)

func (*FakeNamespaces) Delete

func (c *FakeNamespaces) Delete(name string) error

func (*FakeNamespaces) Finalize

func (c *FakeNamespaces) Finalize(namespace *api.Namespace) (*api.Namespace, error)

func (*FakeNamespaces) Get

func (c *FakeNamespaces) Get(name string) (*api.Namespace, error)

func (*FakeNamespaces) List

func (*FakeNamespaces) Status

func (c *FakeNamespaces) Status(namespace *api.Namespace) (*api.Namespace, error)

func (*FakeNamespaces) Update

func (c *FakeNamespaces) Update(namespace *api.Namespace) (*api.Namespace, error)

func (*FakeNamespaces) Watch

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

type FakeNetworkPolicies added in v1.3.0

type FakeNetworkPolicies struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeNetworkPolicies implements NetworkPolicyInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeNetworkPolicies) Create added in v1.3.0

func (*FakeNetworkPolicies) Delete added in v1.3.0

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

func (*FakeNetworkPolicies) Get added in v1.3.0

func (*FakeNetworkPolicies) List added in v1.3.0

func (*FakeNetworkPolicies) Update added in v1.3.0

func (*FakeNetworkPolicies) Watch added in v1.3.0

type FakeNetworks

type FakeNetworks struct {
	Fake *Fake
}

FakeNetworks implements NetworksInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeNetworks) Create

func (c *FakeNetworks) Create(network *api.Network) (*api.Network, error)

func (*FakeNetworks) Delete

func (c *FakeNetworks) Delete(name string) error

func (*FakeNetworks) Finalize

func (c *FakeNetworks) Finalize(network *api.Network) (*api.Network, error)

func (*FakeNetworks) Get

func (c *FakeNetworks) Get(name string) (*api.Network, error)

func (*FakeNetworks) List

func (c *FakeNetworks) List(opts api.ListOptions) (*api.NetworkList, error)

func (*FakeNetworks) Status

func (c *FakeNetworks) Status(network *api.Network) (*api.Network, error)

func (*FakeNetworks) Update

func (c *FakeNetworks) Update(network *api.Network) (*api.Network, error)

func (*FakeNetworks) Watch

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

type FakeNodes

type FakeNodes struct {
	Fake *Fake
}

FakeNodes implements NodeInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeNodes) Create

func (c *FakeNodes) Create(node *api.Node) (*api.Node, error)

func (*FakeNodes) Delete

func (c *FakeNodes) Delete(name string) error

func (*FakeNodes) Get

func (c *FakeNodes) Get(name string) (*api.Node, error)

func (*FakeNodes) List

func (c *FakeNodes) List(opts api.ListOptions) (*api.NodeList, error)

func (*FakeNodes) Update

func (c *FakeNodes) Update(node *api.Node) (*api.Node, error)

func (*FakeNodes) UpdateStatus

func (c *FakeNodes) UpdateStatus(node *api.Node) (*api.Node, error)

func (*FakeNodes) Watch

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

type FakePersistentVolumeClaims

type FakePersistentVolumeClaims struct {
	Fake      *Fake
	Namespace string
}

func (*FakePersistentVolumeClaims) Create

func (*FakePersistentVolumeClaims) Delete

func (c *FakePersistentVolumeClaims) Delete(name string) error

func (*FakePersistentVolumeClaims) Get

func (*FakePersistentVolumeClaims) List

func (*FakePersistentVolumeClaims) Update

func (*FakePersistentVolumeClaims) UpdateStatus

func (*FakePersistentVolumeClaims) Watch

type FakePersistentVolumes

type FakePersistentVolumes struct {
	Fake *Fake
}

func (*FakePersistentVolumes) Create

func (*FakePersistentVolumes) Delete

func (c *FakePersistentVolumes) Delete(name string) error

func (*FakePersistentVolumes) Get

func (*FakePersistentVolumes) List

func (*FakePersistentVolumes) Update

func (*FakePersistentVolumes) UpdateStatus

func (*FakePersistentVolumes) Watch

type FakePodSecurityPolicy added in v0.4.0

type FakePodSecurityPolicy struct {
	Fake      *Fake
	Namespace string
}

FakePodSecurityPolicy implements PodSecurityPolicyInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakePodSecurityPolicy) Create added in v0.4.0

func (*FakePodSecurityPolicy) Delete added in v0.4.0

func (c *FakePodSecurityPolicy) Delete(name string) error

func (*FakePodSecurityPolicy) Get added in v0.4.0

func (*FakePodSecurityPolicy) List added in v0.4.0

func (*FakePodSecurityPolicy) Update added in v0.4.0

func (*FakePodSecurityPolicy) Watch added in v0.4.0

type FakePodTemplates

type FakePodTemplates struct {
	Fake      *Fake
	Namespace string
}

FakePodTemplates implements PodTemplatesInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakePodTemplates) Create

func (c *FakePodTemplates) Create(pod *api.PodTemplate) (*api.PodTemplate, error)

func (*FakePodTemplates) Delete

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

func (*FakePodTemplates) Get

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

func (*FakePodTemplates) List

func (*FakePodTemplates) Update

func (c *FakePodTemplates) Update(pod *api.PodTemplate) (*api.PodTemplate, error)

func (*FakePodTemplates) Watch

type FakePods

type FakePods struct {
	Fake      *Fake
	Namespace string
}

FakePods implements PodsInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakePods) Bind

func (c *FakePods) Bind(binding *api.Binding) error

func (*FakePods) Create

func (c *FakePods) Create(pod *api.Pod) (*api.Pod, error)

func (*FakePods) Delete

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

func (*FakePods) Get

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

func (*FakePods) GetLogs added in v0.3.0

func (c *FakePods) GetLogs(name string, opts *api.PodLogOptions) *restclient.Request

func (*FakePods) List

func (c *FakePods) List(opts api.ListOptions) (*api.PodList, error)

func (*FakePods) Update

func (c *FakePods) Update(pod *api.Pod) (*api.Pod, error)

func (*FakePods) UpdateStatus

func (c *FakePods) UpdateStatus(pod *api.Pod) (*api.Pod, error)

func (*FakePods) Watch

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

type FakeRbac added in v1.3.0

type FakeRbac struct {
	*Fake
}

func NewSimpleFakeRbac added in v1.3.0

func NewSimpleFakeRbac(objects ...runtime.Object) *FakeRbac

func (*FakeRbac) ClusterRoleBindings added in v1.3.0

func (c *FakeRbac) ClusterRoleBindings() client.ClusterRoleBindingInterface

func (*FakeRbac) ClusterRoles added in v1.3.0

func (c *FakeRbac) ClusterRoles() client.ClusterRoleInterface

func (*FakeRbac) RoleBindings added in v1.3.0

func (c *FakeRbac) RoleBindings(namespace string) client.RoleBindingInterface

func (*FakeRbac) Roles added in v1.3.0

func (c *FakeRbac) Roles(namespace string) client.RoleInterface

type FakeReplicaSets added in v0.4.0

type FakeReplicaSets struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeReplicaSets implements ReplicaSetsInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeReplicaSets) Create added in v0.4.0

func (*FakeReplicaSets) Delete added in v0.4.0

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

func (*FakeReplicaSets) Get added in v0.4.0

func (*FakeReplicaSets) List added in v0.4.0

func (*FakeReplicaSets) Update added in v0.4.0

func (*FakeReplicaSets) UpdateStatus added in v0.4.0

func (c *FakeReplicaSets) UpdateStatus(rs *extensions.ReplicaSet) (result *extensions.ReplicaSet, err error)

func (*FakeReplicaSets) Watch added in v0.4.0

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

type FakeReplicationControllers

type FakeReplicationControllers struct {
	Fake      *Fake
	Namespace string
}

FakeReplicationControllers implements ReplicationControllerInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeReplicationControllers) Create

func (*FakeReplicationControllers) Delete

func (c *FakeReplicationControllers) Delete(name string) error

func (*FakeReplicationControllers) Get

func (*FakeReplicationControllers) List

func (*FakeReplicationControllers) Update

func (*FakeReplicationControllers) UpdateStatus added in v0.3.0

func (*FakeReplicationControllers) Watch

type FakeResourceQuotas

type FakeResourceQuotas struct {
	Fake      *Fake
	Namespace string
}

FakeResourceQuotas implements ResourceQuotaInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeResourceQuotas) Create

func (c *FakeResourceQuotas) Create(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

func (*FakeResourceQuotas) Delete

func (c *FakeResourceQuotas) Delete(name string) error

func (*FakeResourceQuotas) Get

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

func (*FakeResourceQuotas) List

func (*FakeResourceQuotas) Update

func (c *FakeResourceQuotas) Update(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

func (*FakeResourceQuotas) UpdateStatus

func (c *FakeResourceQuotas) UpdateStatus(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

func (*FakeResourceQuotas) Watch

type FakeRoleBindings added in v1.3.0

type FakeRoleBindings struct {
	Fake      *FakeRbac
	Namespace string
}

FakeRoleBindings implements RoleBindingInterface

func (*FakeRoleBindings) Create added in v1.3.0

func (c *FakeRoleBindings) Create(csr *rbac.RoleBinding) (*rbac.RoleBinding, error)

func (*FakeRoleBindings) Delete added in v1.3.0

func (c *FakeRoleBindings) Delete(name string, opts *api.DeleteOptions) error

func (*FakeRoleBindings) Get added in v1.3.0

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

func (*FakeRoleBindings) List added in v1.3.0

func (*FakeRoleBindings) Update added in v1.3.0

func (c *FakeRoleBindings) Update(csr *rbac.RoleBinding) (*rbac.RoleBinding, error)

func (*FakeRoleBindings) Watch added in v1.3.0

type FakeRoles added in v1.3.0

type FakeRoles struct {
	Fake      *FakeRbac
	Namespace string
}

FakeRoles implements RoleInterface

func (*FakeRoles) Create added in v1.3.0

func (c *FakeRoles) Create(csr *rbac.Role) (*rbac.Role, error)

func (*FakeRoles) Delete added in v1.3.0

func (c *FakeRoles) Delete(name string, opts *api.DeleteOptions) error

func (*FakeRoles) Get added in v1.3.0

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

func (*FakeRoles) List added in v1.3.0

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

func (*FakeRoles) Update added in v1.3.0

func (c *FakeRoles) Update(csr *rbac.Role) (*rbac.Role, error)

func (*FakeRoles) Watch added in v1.3.0

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

type FakeScales

type FakeScales struct {
	Fake      *FakeExperimental
	Namespace string
}

FakeScales implements ScaleInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeScales) Get

func (c *FakeScales) Get(kind string, name string) (result *extensions.Scale, err error)

func (*FakeScales) Update

func (c *FakeScales) Update(kind string, scale *extensions.Scale) (result *extensions.Scale, err error)

type FakeScheduledJobs added in v1.3.0

type FakeScheduledJobs struct {
	Fake      *FakeBatch
	Namespace string
}

FakeScheduledJobs implements ScheduledJobInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the methods you want to test easier.

func (*FakeScheduledJobs) Create added in v1.3.0

func (c *FakeScheduledJobs) Create(scheduledJob *batch.ScheduledJob) (*batch.ScheduledJob, error)

func (*FakeScheduledJobs) Delete added in v1.3.0

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

func (*FakeScheduledJobs) Get added in v1.3.0

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

func (*FakeScheduledJobs) List added in v1.3.0

func (*FakeScheduledJobs) Update added in v1.3.0

func (c *FakeScheduledJobs) Update(scheduledJob *batch.ScheduledJob) (*batch.ScheduledJob, error)

func (*FakeScheduledJobs) UpdateStatus added in v1.3.0

func (c *FakeScheduledJobs) UpdateStatus(scheduledJob *batch.ScheduledJob) (result *batch.ScheduledJob, err error)

func (*FakeScheduledJobs) Watch added in v1.3.0

type FakeSecrets

type FakeSecrets struct {
	Fake      *Fake
	Namespace string
}

Fake implements SecretInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeSecrets) Create

func (c *FakeSecrets) Create(secret *api.Secret) (*api.Secret, error)

func (*FakeSecrets) Delete

func (c *FakeSecrets) Delete(name string) error

func (*FakeSecrets) Get

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

func (*FakeSecrets) List

func (c *FakeSecrets) List(opts api.ListOptions) (*api.SecretList, error)

func (*FakeSecrets) Update

func (c *FakeSecrets) Update(secret *api.Secret) (*api.Secret, error)

func (*FakeSecrets) Watch

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

type FakeServiceAccounts

type FakeServiceAccounts struct {
	Fake      *Fake
	Namespace string
}

FakeServiceAccounts implements ServiceAccountsInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeServiceAccounts) Create

func (c *FakeServiceAccounts) Create(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

func (*FakeServiceAccounts) Delete

func (c *FakeServiceAccounts) Delete(name string) error

func (*FakeServiceAccounts) Get

func (*FakeServiceAccounts) List

func (*FakeServiceAccounts) Update

func (c *FakeServiceAccounts) Update(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

func (*FakeServiceAccounts) Watch

type FakeServices

type FakeServices struct {
	Fake      *Fake
	Namespace string
}

Fake implements ServiceInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeServices) Create

func (c *FakeServices) Create(service *api.Service) (*api.Service, error)

func (*FakeServices) Delete

func (c *FakeServices) Delete(name string) error

func (*FakeServices) Get

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

func (*FakeServices) List

func (c *FakeServices) List(opts api.ListOptions) (*api.ServiceList, error)

func (*FakeServices) ProxyGet

func (c *FakeServices) ProxyGet(scheme, name, port, path string, params map[string]string) restclient.ResponseWrapper

func (*FakeServices) Update

func (c *FakeServices) Update(service *api.Service) (*api.Service, error)

func (*FakeServices) UpdateStatus added in v0.4.0

func (c *FakeServices) UpdateStatus(service *api.Service) (result *api.Service, err error)

func (*FakeServices) Watch

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

type FakeThirdPartyResources added in v0.3.0

type FakeThirdPartyResources struct {
	Fake *FakeExperimental
}

FakeThirdPartyResources implements ThirdPartyResourceInterface. Meant to be embedded into a struct to get a default implementation. This makes faking out just the method you want to test easier.

func (*FakeThirdPartyResources) Create added in v0.3.0

func (*FakeThirdPartyResources) Delete added in v0.3.0

func (c *FakeThirdPartyResources) Delete(name string) error

func (*FakeThirdPartyResources) Get added in v0.3.0

func (*FakeThirdPartyResources) List added in v0.3.0

func (*FakeThirdPartyResources) Update added in v0.3.0

func (*FakeThirdPartyResources) UpdateStatus added in v0.3.0

func (*FakeThirdPartyResources) Watch added in v0.3.0

type GenericAction

type GenericAction interface {
	Action
	GetValue() interface{}
}

type GenericActionImpl

type GenericActionImpl struct {
	ActionImpl
	Value interface{}
}

func (GenericActionImpl) GetValue

func (a GenericActionImpl) GetValue() interface{}

type GetAction

type GetAction interface {
	Action
	GetName() string
}

type GetActionImpl

type GetActionImpl struct {
	ActionImpl
	Name string
}

func NewGetAction

func NewGetAction(resource, namespace, name string) GetActionImpl

func NewRootGetAction

func NewRootGetAction(resource, name string) GetActionImpl

func (GetActionImpl) GetName

func (a GetActionImpl) GetName() string

type ListAction

type ListAction interface {
	Action
	GetListRestrictions() ListRestrictions
}

type ListActionImpl

type ListActionImpl struct {
	ActionImpl
	ListRestrictions ListRestrictions
}

func NewListAction

func NewListAction(resource, namespace string, opts api.ListOptions) ListActionImpl

func NewRootListAction

func NewRootListAction(resource string, opts api.ListOptions) ListActionImpl

func (ListActionImpl) GetListRestrictions

func (a ListActionImpl) GetListRestrictions() ListRestrictions

type ListRestrictions

type ListRestrictions struct {
	Labels labels.Selector
	Fields fields.Selector
}

type ObjectRetriever

type ObjectRetriever interface {
	// Kind should return a resource or a list of resources (depending on the provided kind and
	// name). It should return an error if the caller should communicate an error to the server.
	Kind(gvk unversioned.GroupVersionKind, name string) (runtime.Object, error)
	// Add adds a runtime object for test purposes into this object.
	Add(runtime.Object) error
}

ObjectRetriever abstracts the implementation for retrieving or setting generic objects. It is intended to be used to fake calls to a server by returning objects based on their kind and name.

func NewObjects

func NewObjects(scheme ObjectScheme, decoder runtime.Decoder) ObjectRetriever

NewObjects implements the ObjectRetriever interface by introspecting the objects provided to Add() and returning them when the Kind method is invoked. If an api.List object is provided to Add(), each child item is added. If an object is added that is itself a list (PodList, ServiceList) then that is added to the "PodList" kind. If no PodList is added, the retriever will take any loaded Pods and return them in a list. If an api.Status is added, and the Details.Kind field is set, that status will be returned instead (as an error if Status != Success, or as a runtime.Object if Status == Success). If multiple PodLists are provided, they will be returned in order by the Kind call, and the last PodList will be reused for subsequent calls.

type ObjectScheme added in v0.3.0

type ObjectScheme interface {
	runtime.ObjectCreater
	runtime.ObjectCopier
	runtime.ObjectTyper
}

ObjectScheme abstracts the implementation of common operations on objects.

type PatchActionImpl added in v0.3.0

type PatchActionImpl struct {
	ActionImpl
	Object runtime.Object
}

func NewPatchAction added in v0.3.0

func NewPatchAction(resource, namespace string, object runtime.Object) PatchActionImpl

func NewRootPatchAction added in v0.3.0

func NewRootPatchAction(resource string, object runtime.Object) PatchActionImpl

func (PatchActionImpl) GetObject added in v0.3.0

func (a PatchActionImpl) GetObject() runtime.Object

type ProxyGetAction

type ProxyGetAction interface {
	Action
	GetScheme() string
	GetName() string
	GetPort() string
	GetPath() string
	GetParams() map[string]string
}

type ProxyGetActionImpl

type ProxyGetActionImpl struct {
	ActionImpl
	Scheme string
	Name   string
	Port   string
	Path   string
	Params map[string]string
}

func NewProxyGetAction

func NewProxyGetAction(resource, namespace, scheme, name, port, path string, params map[string]string) ProxyGetActionImpl

func (ProxyGetActionImpl) GetName

func (a ProxyGetActionImpl) GetName() string

func (ProxyGetActionImpl) GetParams

func (a ProxyGetActionImpl) GetParams() map[string]string

func (ProxyGetActionImpl) GetPath

func (a ProxyGetActionImpl) GetPath() string

func (ProxyGetActionImpl) GetPort added in v0.3.0

func (a ProxyGetActionImpl) GetPort() string

func (ProxyGetActionImpl) GetScheme added in v0.3.0

func (a ProxyGetActionImpl) GetScheme() string

type ProxyReactionFunc

type ProxyReactionFunc func(action Action) (handled bool, ret restclient.ResponseWrapper, err error)

ProxyReactionFunc is a function that returns a ResponseWrapper interface for a given Action. If "handled" is false, then the test client will continue ignore the results and continue to the next ProxyReactionFunc

type ProxyReactor

type ProxyReactor interface {
	// Handles indicates whether or not this Reactor deals with a given action
	Handles(action Action) bool
	// React handles a watch action and returns results.  It may choose to delegate by indicated handled=false
	React(action Action) (handled bool, ret restclient.ResponseWrapper, err error)
}

ProxyReactor is an interface to allow the composition of proxy get functions.

type ReactionFunc

type ReactionFunc func(action Action) (handled bool, ret runtime.Object, err error)

ReactionFunc is a function that returns an object or error for a given Action. If "handled" is false, then the test client will continue ignore the results and continue to the next ReactionFunc

func ObjectReaction

func ObjectReaction(o ObjectRetriever, mapper meta.RESTMapper) ReactionFunc

ObjectReaction returns a ReactionFunc that takes a generic action string of the form <verb>-<resource> or <verb>-<subresource>-<resource> and attempts to return a runtime Object or error that matches the requested action. For instance, list-replicationControllers should attempt to return a list of replication controllers. This method delegates to the ObjectRetriever interface to satisfy retrieval of lists or retrieval of single items. TODO: add support for sub resources

type Reactor

type Reactor interface {
	// Handles indicates whether or not this Reactor deals with a given action
	Handles(action Action) bool
	// React handles the action and returns results.  It may choose to delegate by indicated handled=false
	React(action Action) (handled bool, ret runtime.Object, err error)
}

Reactor is an interface to allow the composition of reaction functions.

type SimpleProxyReactor

type SimpleProxyReactor struct {
	Resource string

	Reaction ProxyReactionFunc
}

SimpleProxyReactor is a ProxyReactor. Each reaction function is attached to a given resource. "*" matches everything for that value. For instance, *,pods matches all verbs on pods. This allows for easier composition of reaction functions.

func (*SimpleProxyReactor) Handles

func (r *SimpleProxyReactor) Handles(action Action) bool

func (*SimpleProxyReactor) React

type SimpleReactor

type SimpleReactor struct {
	Verb     string
	Resource string

	Reaction ReactionFunc
}

SimpleReactor is a Reactor. Each reaction function is attached to a given verb,resource tuple. "*" in either field matches everything for that value. For instance, *,pods matches all verbs on pods. This allows for easier composition of reaction functions

func (*SimpleReactor) Handles

func (r *SimpleReactor) Handles(action Action) bool

func (*SimpleReactor) React

func (r *SimpleReactor) React(action Action) (bool, runtime.Object, error)

type SimpleWatchReactor

type SimpleWatchReactor struct {
	Resource string

	Reaction WatchReactionFunc
}

SimpleWatchReactor is a WatchReactor. Each reaction function is attached to a given resource. "*" matches everything for that value. For instance, *,pods matches all verbs on pods. This allows for easier composition of reaction functions

func (*SimpleWatchReactor) Handles

func (r *SimpleWatchReactor) Handles(action Action) bool

func (*SimpleWatchReactor) React

func (r *SimpleWatchReactor) React(action Action) (bool, watch.Interface, error)

type UpdateAction

type UpdateAction interface {
	Action
	GetObject() runtime.Object
}

type UpdateActionImpl

type UpdateActionImpl struct {
	ActionImpl
	Object runtime.Object
}

func NewRootUpdateAction

func NewRootUpdateAction(resource string, object runtime.Object) UpdateActionImpl

func NewUpdateAction

func NewUpdateAction(resource, namespace string, object runtime.Object) UpdateActionImpl

func NewUpdateSubresourceAction

func NewUpdateSubresourceAction(resource, subresource, namespace string, object runtime.Object) UpdateActionImpl

func (UpdateActionImpl) GetObject

func (a UpdateActionImpl) GetObject() runtime.Object

type WatchAction

type WatchAction interface {
	Action
	GetWatchRestrictions() WatchRestrictions
}

type WatchActionImpl

type WatchActionImpl struct {
	ActionImpl
	WatchRestrictions WatchRestrictions
}

func NewRootWatchAction

func NewRootWatchAction(resource string, opts api.ListOptions) WatchActionImpl

func NewWatchAction

func NewWatchAction(resource, namespace string, opts api.ListOptions) WatchActionImpl

func (WatchActionImpl) GetWatchRestrictions

func (a WatchActionImpl) GetWatchRestrictions() WatchRestrictions

type WatchReactionFunc

type WatchReactionFunc func(action Action) (handled bool, ret watch.Interface, err error)

WatchReactionFunc is a function that returns a watch interface. If "handled" is false, then the test client will continue ignore the results and continue to the next ReactionFunc

func DefaultWatchReactor

func DefaultWatchReactor(watchInterface watch.Interface, err error) WatchReactionFunc

type WatchReactor

type WatchReactor interface {
	// Handles indicates whether or not this Reactor deals with a given action
	Handles(action Action) bool
	// React handles a watch action and returns results.  It may choose to delegate by indicated handled=false
	React(action Action) (handled bool, ret watch.Interface, err error)
}

WatchReactor is an interface to allow the composition of watch functions.

type WatchRestrictions

type WatchRestrictions struct {
	Labels          labels.Selector
	Fields          fields.Selector
	ResourceVersion string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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