本文整理汇总了Golang中k8s/io/kubernetes/pkg/client/testing/core.NewListAction函数的典型用法代码示例。如果您正苦于以下问题:Golang NewListAction函数的具体用法?Golang NewListAction怎么用?Golang NewListAction使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NewListAction函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: List
func (c *FakePolicyBindings) List(opts kapi.ListOptions) (*authorizationapi.PolicyBindingList, error) {
obj, err := c.Fake.Invokes(core.NewListAction(policyBindingsResource, c.Namespace, opts), &authorizationapi.PolicyBindingList{})
if obj == nil {
return nil, err
}
return obj.(*authorizationapi.PolicyBindingList), err
}
开发者ID:xgwang-zte,项目名称:origin,代码行数:8,代码来源:fake_policybindings.go
示例2: List
func (c *FakeDeploymentConfigs) List(opts kapi.ListOptions) (*deployapi.DeploymentConfigList, error) {
obj, err := c.Fake.Invokes(core.NewListAction(deploymentConfigsResource, c.Namespace, opts), &deployapi.DeploymentConfigList{})
if obj == nil {
return nil, err
}
return obj.(*deployapi.DeploymentConfigList), err
}
开发者ID:xgwang-zte,项目名称:origin,代码行数:8,代码来源:fake_deploymentconfigs.go
示例3: List
func (c *FakeTemplates) List(opts kapi.ListOptions) (*templateapi.TemplateList, error) {
obj, err := c.Fake.Invokes(core.NewListAction(templatesResource, c.Namespace, opts), &templateapi.TemplateList{})
if obj == nil {
return nil, err
}
return obj.(*templateapi.TemplateList), err
}
开发者ID:xgwang-zte,项目名称:origin,代码行数:8,代码来源:fake_templates.go
示例4: List
func (c *FakeBuildConfigs) List(opts kapi.ListOptions) (*buildapi.BuildConfigList, error) {
obj, err := c.Fake.Invokes(core.NewListAction(buildConfigsResource, c.Namespace, opts), &buildapi.BuildConfigList{})
if obj == nil {
return nil, err
}
return obj.(*buildapi.BuildConfigList), err
}
开发者ID:xgwang-zte,项目名称:origin,代码行数:8,代码来源:fake_buildconfigs.go
示例5: List
func (c *FakeAppliedClusterResourceQuotas) List(opts kapi.ListOptions) (*quotaapi.AppliedClusterResourceQuotaList, error) {
obj, err := c.Fake.Invokes(core.NewListAction(appliedClusterResourceQuotasResource, c.Namespace, opts), "aapi.AppliedClusterResourceQuotaList{})
if obj == nil {
return nil, err
}
return obj.(*quotaapi.AppliedClusterResourceQuotaList), err
}
开发者ID:xgwang-zte,项目名称:origin,代码行数:8,代码来源:fake_appliedclusterresourcequota.go
示例6: List
func (c *FakePodSecurityPolicySubjectReviews) List(opts api.ListOptions) (result *v1.PodSecurityPolicySubjectReviewList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(podsecuritypolicysubjectreviewsResource, c.ns, opts), &v1.PodSecurityPolicySubjectReviewList{})
if obj == nil {
return nil, err
}
return obj.(*v1.PodSecurityPolicySubjectReviewList), err
}
开发者ID:Xmagicer,项目名称:origin,代码行数:9,代码来源:fake_podsecuritypolicysubjectreview.go
示例7: Search
// Search returns a list of events matching the specified object.
func (c *FakeEvents) Search(objOrRef runtime.Object) (*v1.EventList, error) {
action := core.NewRootListAction(eventsResource, api.ListOptions{})
if c.ns != "" {
action = core.NewListAction(eventsResource, c.ns, api.ListOptions{})
}
obj, err := c.Fake.Invokes(action, &v1.EventList{})
if obj == nil {
return nil, err
}
return obj.(*v1.EventList), err
}
开发者ID:CodeJuan,项目名称:kubernetes,代码行数:13,代码来源:fake_event_expansion.go
示例8: List
func (c *FakePersistentVolumeClaims) List(opts api.ListOptions) (result *api.PersistentVolumeClaimList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(persistentvolumeclaimsResource, c.ns, opts), &api.PersistentVolumeClaimList{})
if obj == nil {
return nil, err
}
label, _, _ := core.ExtractFromListOptions(opts)
if label == nil {
label = labels.Everything()
}
list := &api.PersistentVolumeClaimList{}
for _, item := range obj.(*api.PersistentVolumeClaimList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:nak3,项目名称:kubernetes,代码行数:20,代码来源:fake_persistentvolumeclaim.go
示例9: List
func (c *FakeThirdPartyResources) List(opts api.ListOptions) (result *v1beta1.ThirdPartyResourceList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction("thirdpartyresources", c.ns, opts), &v1beta1.ThirdPartyResourceList{})
if obj == nil {
return nil, err
}
label := opts.LabelSelector
if label == nil {
label = labels.Everything()
}
list := &v1beta1.ThirdPartyResourceList{}
for _, item := range obj.(*v1beta1.ThirdPartyResourceList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:mml,项目名称:kubernetes,代码行数:20,代码来源:fake_thirdpartyresource.go
示例10: List
func (c *FakeHorizontalPodAutoscalers) List(opts api.ListOptions) (result *v1beta1.HorizontalPodAutoscalerList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction("horizontalpodautoscalers", c.ns, opts), &v1beta1.HorizontalPodAutoscalerList{})
if obj == nil {
return nil, err
}
label := opts.LabelSelector
if label == nil {
label = labels.Everything()
}
list := &v1beta1.HorizontalPodAutoscalerList{}
for _, item := range obj.(*v1beta1.HorizontalPodAutoscalerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:mml,项目名称:kubernetes,代码行数:20,代码来源:fake_horizontalpodautoscaler.go
示例11: List
func (c *FakeDaemonSets) List(opts api.ListOptions) (result *extensions.DaemonSetList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction("daemonsets", c.ns, opts), &extensions.DaemonSetList{})
if obj == nil {
return nil, err
}
label := opts.LabelSelector
if label == nil {
label = labels.Everything()
}
list := &extensions.DaemonSetList{}
for _, item := range obj.(*extensions.DaemonSetList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:XiaoningDing,项目名称:UbernetesPOC,代码行数:20,代码来源:fake_daemonset.go
示例12: List
func (c *FakeTestTypes) List(opts api.ListOptions) (result *testgroup_k8s_io.TestTypeList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction("testtypes", c.ns, opts), &testgroup_k8s_io.TestTypeList{})
if obj == nil {
return nil, err
}
label := opts.LabelSelector
if label == nil {
label = labels.Everything()
}
list := &testgroup_k8s_io.TestTypeList{}
for _, item := range obj.(*testgroup_k8s_io.TestTypeList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:xjxj1,项目名称:kubernetes,代码行数:20,代码来源:fake_testtype.go
示例13: List
func (c *FakeIngresses) List(opts api.ListOptions) (result *extensions.IngressList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(ingressesResource, c.ns, opts), &extensions.IngressList{})
if obj == nil {
return nil, err
}
label, _, _ := core.ExtractFromListOptions(opts)
if label == nil {
label = labels.Everything()
}
list := &extensions.IngressList{}
for _, item := range obj.(*extensions.IngressList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:nak3,项目名称:kubernetes,代码行数:20,代码来源:fake_ingress.go
示例14: List
func (c *FakePodDisruptionBudgets) List(opts api.ListOptions) (result *policy.PodDisruptionBudgetList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(poddisruptionbudgetsResource, c.ns, opts), &policy.PodDisruptionBudgetList{})
if obj == nil {
return nil, err
}
label, _, _ := core.ExtractFromListOptions(opts)
if label == nil {
label = labels.Everything()
}
list := &policy.PodDisruptionBudgetList{}
for _, item := range obj.(*policy.PodDisruptionBudgetList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:alex-mohr,项目名称:kubernetes,代码行数:20,代码来源:fake_poddisruptionbudget.go
示例15: List
func (c *FakePods) List(opts api.ListOptions) (result *api.PodList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(podsResource, c.ns, opts), &api.PodList{})
if obj == nil {
return nil, err
}
label := opts.LabelSelector
if label == nil {
label = labels.Everything()
}
list := &api.PodList{}
for _, item := range obj.(*api.PodList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:cesardraw2,项目名称:kubernetes,代码行数:20,代码来源:fake_pod.go
示例16: List
func (c *FakeHorizontalPodAutoscalers) List(opts api.ListOptions) (result *autoscaling.HorizontalPodAutoscalerList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(horizontalpodautoscalersResource, c.ns, opts), &autoscaling.HorizontalPodAutoscalerList{})
if obj == nil {
return nil, err
}
label, _, _ := core.ExtractFromListOptions(opts)
if label == nil {
label = labels.Everything()
}
list := &autoscaling.HorizontalPodAutoscalerList{}
for _, item := range obj.(*autoscaling.HorizontalPodAutoscalerList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:ncdc,项目名称:kubernetes,代码行数:20,代码来源:fake_horizontalpodautoscaler.go
示例17: List
func (c *FakeConfigMaps) List(opts v1.ListOptions) (result *v1.ConfigMapList, err error) {
obj, err := c.Fake.
Invokes(core.NewListAction(configmapsResource, c.ns, opts), &v1.ConfigMapList{})
if obj == nil {
return nil, err
}
label, _, _ := core.ExtractFromListOptions(opts)
if label == nil {
label = labels.Everything()
}
list := &v1.ConfigMapList{}
for _, item := range obj.(*v1.ConfigMapList).Items {
if label.Matches(labels.Set(item.Labels)) {
list.Items = append(list.Items, item)
}
}
return list, err
}
开发者ID:alex-mohr,项目名称:kubernetes,代码行数:20,代码来源:fake_configmap.go
示例18: TestGetClient
func TestGetClient(t *testing.T) {
testCases := []struct {
name string
clientName string
kubeClient *fake.Clientset
osClient *ostestclient.Fake
expectedDelegation bool
expectedErr string
expectedClient *oauthapi.OAuthClient
expectedKubeActions []core.Action
expectedOSActions []ktestclient.Action
}{
{
name: "delegate",
clientName: "not:serviceaccount",
kubeClient: fake.NewSimpleClientset(),
osClient: ostestclient.NewSimpleFake(),
expectedDelegation: true,
expectedKubeActions: []core.Action{},
expectedOSActions: []ktestclient.Action{},
},
{
name: "missing sa",
clientName: "system:serviceaccount:ns-01:missing-sa",
kubeClient: fake.NewSimpleClientset(),
osClient: ostestclient.NewSimpleFake(),
expectedErr: `ServiceAccount "missing-sa" not found`,
expectedKubeActions: []core.Action{core.NewGetAction(unversioned.GroupVersionResource{Resource: "serviceaccounts"}, "ns-01", "missing-sa")},
expectedOSActions: []ktestclient.Action{},
},
{
name: "sa no redirects",
clientName: "system:serviceaccount:ns-01:default",
kubeClient: fake.NewSimpleClientset(
&kapi.ServiceAccount{
ObjectMeta: kapi.ObjectMeta{
Namespace: "ns-01",
Name: "default",
Annotations: map[string]string{},
},
}),
osClient: ostestclient.NewSimpleFake(),
expectedErr: `system:serviceaccount:ns-01:default has no redirectURIs; set serviceaccounts.openshift.io/oauth-redirecturi.<some-value>`,
expectedKubeActions: []core.Action{core.NewGetAction(unversioned.GroupVersionResource{Resource: "serviceaccounts"}, "ns-01", "default")},
expectedOSActions: []ktestclient.Action{},
},
{
name: "sa no tokens",
clientName: "system:serviceaccount:ns-01:default",
kubeClient: fake.NewSimpleClientset(
&kapi.ServiceAccount{
ObjectMeta: kapi.ObjectMeta{
Namespace: "ns-01",
Name: "default",
Annotations: map[string]string{OAuthRedirectModelAnnotationURIPrefix + "one": "http://anywhere"},
},
}),
osClient: ostestclient.NewSimpleFake(),
expectedErr: `system:serviceaccount:ns-01:default has no tokens`,
expectedKubeActions: []core.Action{
core.NewGetAction(unversioned.GroupVersionResource{Resource: "serviceaccounts"}, "ns-01", "default"),
core.NewListAction(unversioned.GroupVersionResource{Resource: "secrets"}, "ns-01", kapi.ListOptions{}),
},
expectedOSActions: []ktestclient.Action{},
},
{
name: "good SA",
clientName: "system:serviceaccount:ns-01:default",
kubeClient: fake.NewSimpleClientset(
&kapi.ServiceAccount{
ObjectMeta: kapi.ObjectMeta{
Namespace: "ns-01",
Name: "default",
UID: types.UID("any"),
Annotations: map[string]string{OAuthRedirectModelAnnotationURIPrefix + "one": "http://anywhere"},
},
},
&kapi.Secret{
ObjectMeta: kapi.ObjectMeta{
Namespace: "ns-01",
Name: "default",
Annotations: map[string]string{
kapi.ServiceAccountNameKey: "default",
kapi.ServiceAccountUIDKey: "any",
},
},
Type: kapi.SecretTypeServiceAccountToken,
Data: map[string][]byte{kapi.ServiceAccountTokenKey: []byte("foo")},
}),
osClient: ostestclient.NewSimpleFake(),
expectedClient: &oauthapi.OAuthClient{
ObjectMeta: kapi.ObjectMeta{Name: "system:serviceaccount:ns-01:default"},
ScopeRestrictions: getScopeRestrictionsFor("ns-01", "default"),
AdditionalSecrets: []string{"foo"},
RedirectURIs: []string{"http://anywhere"},
GrantMethod: oauthapi.GrantHandlerPrompt,
},
expectedKubeActions: []core.Action{
core.NewGetAction(unversioned.GroupVersionResource{Resource: "serviceaccounts"}, "ns-01", "default"),
//.........这里部分代码省略.........
开发者ID:LalatenduMohanty,项目名称:origin,代码行数:101,代码来源:oauthclientregistry_test.go
示例19: expectListPodAction
func (f *fixture) expectListPodAction(namespace string, opt api.ListOptions) {
f.actions = append(f.actions, core.NewListAction(unversioned.GroupVersionResource{Resource: "pods"}, namespace, opt))
}
开发者ID:juanluisvaladas,项目名称:origin,代码行数:3,代码来源:deployment_controller_test.go
示例20: TestStop
func TestStop(t *testing.T) {
var (
deploymentConfigsResource = unversioned.GroupVersionResource{Resource: "deploymentconfigs"}
replicationControllersResource = unversioned.GroupVersionResource{Resource: "replicationcontrollers"}
)
pause := func(d *deployapi.DeploymentConfig) *deployapi.DeploymentConfig {
d.Spec.Paused = true
return d
}
fakeDC := map[string]*deployapi.DeploymentConfig{
"simple-stop": deploytest.OkDeploymentConfig(1),
"legacy-simple-stop": deploytest.OkDeploymentConfig(1),
"multi-stop": deploytest.OkDeploymentConfig(5),
"legacy-multi-stop": deploytest.OkDeploymentConfig(5),
"no-deployments": deploytest.OkDeploymentConfig(5),
"legacy-no-deployments": deploytest.OkDeploymentConfig(5),
}
tests := []struct {
testName string
namespace string
name string
oc *testclient.Fake
kc *fake.Clientset
expected []core.Action
kexpected []core.Action
err bool
}{
{
testName: "simple stop",
namespace: "default",
name: "config",
oc: testclient.NewSimpleFake(fakeDC["simple-stop"]),
kc: fake.NewSimpleClientset(mkdeploymentlist(1)),
expected: []core.Action{
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewUpdateAction(deploymentConfigsResource, "default", pause(fakeDC["simple-stop"])),
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewDeleteAction(deploymentConfigsResource, "default", "config"),
},
kexpected: []core.Action{
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{LabelSelector: labels.SelectorFromSet(map[string]string{"openshift.io/deployment-config.name": "config"})}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewUpdateAction(replicationControllersResource, "default", nil),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewDeleteAction(replicationControllersResource, "default", "config-1"),
},
err: false,
},
{
testName: "legacy simple stop",
namespace: "default",
name: "config",
oc: testclient.NewSimpleFake(fakeDC["legacy-simple-stop"]),
kc: fake.NewSimpleClientset(mkdeploymentlist(1)),
expected: []core.Action{
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewUpdateAction(deploymentConfigsResource, "default", nil),
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewDeleteAction(deploymentConfigsResource, "default", "config"),
},
kexpected: []core.Action{
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{LabelSelector: labels.SelectorFromSet(map[string]string{"openshift.io/deployment-config.name": "config"})}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewUpdateAction(replicationControllersResource, "default", nil),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewDeleteAction(replicationControllersResource, "default", "config-1"),
},
err: false,
},
{
testName: "stop multiple controllers",
namespace: "default",
name: "config",
oc: testclient.NewSimpleFake(fakeDC["multi-stop"]),
kc: fake.NewSimpleClientset(mkdeploymentlist(1, 2, 3, 4, 5)),
expected: []core.Action{
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewUpdateAction(deploymentConfigsResource, "default", pause(fakeDC["multi-stop"])),
core.NewGetAction(deploymentConfigsResource, "default", "config"),
core.NewDeleteAction(deploymentConfigsResource, "default", "config"),
},
kexpected: []core.Action{
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{LabelSelector: labels.SelectorFromSet(map[string]string{"openshift.io/deployment-config.name": "config"})}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{}),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewUpdateAction(replicationControllersResource, "default", nil),
core.NewGetAction(replicationControllersResource, "default", "config-1"),
core.NewDeleteAction(replicationControllersResource, "default", "config-1"),
core.NewGetAction(replicationControllersResource, "default", "config-2"),
core.NewListAction(replicationControllersResource, "default", kapi.ListOptions{}),
core.NewGetAction(replicationControllersResource, "default", "config-2"),
core.NewUpdateAction(replicationControllersResource, "default", nil),
//.........这里部分代码省略.........
开发者ID:xgwang-zte,项目名称:origin,代码行数:101,代码来源:delete_test.go
注:本文中的k8s/io/kubernetes/pkg/client/testing/core.NewListAction函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论