本文整理汇总了Golang中github.com/cloudfoundry/cli/cf/api/apifakes.NewCloudControllerTestRequest函数的典型用法代码示例。如果您正苦于以下问题:Golang NewCloudControllerTestRequest函数的具体用法?Golang NewCloudControllerTestRequest怎么用?Golang NewCloudControllerTestRequest使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NewCloudControllerTestRequest函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: deleteSharedDomainReq
func deleteSharedDomainReq(statusCode int) testnet.TestRequest {
return apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "DELETE",
Path: "/v2/shared_domains/my-domain-guid?recursive=true",
Response: testnet.TestResponse{Status: statusCode},
})
}
开发者ID:yingkitw,项目名称:cli,代码行数:7,代码来源:domains_test.go
示例2: uploadApplicationRequest
func uploadApplicationRequest(zipCheck func(*zip.Reader)) testnet.TestRequest {
return testapi.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "PUT",
Path: "/v2/apps/my-cool-app-guid/bits",
Matcher: uploadBodyMatcher(zipCheck),
Response: testnet.TestResponse{
Status: http.StatusCreated,
Body: `
{
"metadata":{
"guid": "my-job-guid",
"url": "/v2/jobs/my-job-guid"
}
}
`},
})
}
开发者ID:yingkitw,项目名称:cli,代码行数:17,代码来源:application_bits_test.go
示例3: testSpacesDidNotFindByNameWithOrg
func testSpacesDidNotFindByNameWithOrg(orgGUID string, findByName func(SpaceRepository, string) (models.Space, error)) {
request := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: fmt.Sprintf("/v2/organizations/%s/spaces?q=name%%3Aspace1", orgGUID),
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: ` { "resources": [ ] }`,
},
})
ts, handler, repo := createSpacesRepo(request)
defer ts.Close()
_, apiErr := findByName(repo, "Space1")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr.(*errors.ModelNotFoundError)).NotTo(BeNil())
}
开发者ID:jsloyer,项目名称:cli,代码行数:18,代码来源:spaces_test.go
示例4:
})
var appStatsRequest = apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/apps/my-cool-app-guid/stats",
Response: testnet.TestResponse{Status: http.StatusOK, Body: `
{
"1":{
"stats": {
"disk_quota": 10000,
"mem_quota": 1024,
"usage": {
"cpu": 0.3,
"disk": 10000,
"mem": 1024
}
}
},
"0":{
"stats": {
"disk_quota": 1073741824,
"mem_quota": 67108864,
"usage": {
"cpu": 3.659571249238058e-05,
"disk": 56037376,
"mem": 19218432
}
}
}
}`}})
var appInstancesRequest = apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
开发者ID:jsloyer,项目名称:cli,代码行数:32,代码来源:app_instances_test.go
示例5:
. "github.com/onsi/gomega"
)
var _ = Describe("AppSummaryRepository", func() {
var (
testServer *httptest.Server
handler *testnet.TestHandler
repo AppSummaryRepository
)
Describe("GetSummariesInCurrentSpace()", func() {
BeforeEach(func() {
getAppSummariesRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/spaces/my-space-guid/summary",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: getAppSummariesResponseBody,
},
})
testServer, handler = testnet.NewServer([]testnet.TestRequest{getAppSummariesRequest})
configRepo := testconfig.NewRepositoryWithDefaults()
configRepo.SetAPIEndpoint(testServer.URL)
gateway := net.NewCloudControllerGateway(configRepo, time.Now, new(terminalfakes.FakeUI), new(tracefakes.FakePrinter))
repo = NewCloudControllerAppSummaryRepository(configRepo, gateway)
})
AfterEach(func() {
testServer.Close()
})
开发者ID:jsloyer,项目名称:cli,代码行数:31,代码来源:app_summary_test.go
示例6:
AfterEach(func() {
testServer.Close()
})
setupTestServer := func(reqs ...testnet.TestRequest) {
testServer, testHandler = testnet.NewServer(reqs)
configRepo.SetAPIEndpoint(testServer.URL)
}
Describe("BindToStagingSet", func() {
It("makes a correct request", func() {
setupTestServer(
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "PUT",
Path: "/v2/config/staging_security_groups/a-real-guid",
Response: testnet.TestResponse{
Status: http.StatusCreated,
Body: bindStagingResponse,
},
}),
)
err := repo.BindToStagingSet("a-real-guid")
Expect(err).ToNot(HaveOccurred())
Expect(testHandler).To(HaveAllRequestsCalled())
})
})
Describe(".List", func() {
It("returns a list of security groups that are the defaults for staging", func() {
setupTestServer(
开发者ID:Reejoshi,项目名称:cli,代码行数:32,代码来源:staging_test.go
示例7:
})
It("does not call the provided function", func() {
_, apiErr := repo.ListOrgs(0)
Expect(apiErr).NotTo(HaveOccurred())
})
})
})
Describe(".GetManyOrgsByGUID", func() {
It("requests each org", func() {
firstOrgRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/organizations/org1-guid",
Response: testnet.TestResponse{Status: http.StatusOK, Body: `{
"metadata": { "guid": "org1-guid" },
"entity": { "name": "Org1" }
}`},
})
secondOrgRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/organizations/org2-guid",
Response: testnet.TestResponse{Status: http.StatusOK, Body: `{
"metadata": { "guid": "org2-guid" },
"entity": { "name": "Org2" }
}`},
})
testserver, handler, repo := createOrganizationRepo(firstOrgRequest, secondOrgRequest)
defer testserver.Close()
orgGUIDs := []string{"org1-guid", "org2-guid"}
开发者ID:Reejoshi,项目名称:cli,代码行数:32,代码来源:organizations_test.go
示例8:
It("lists all the spaces", func() {
firstPageSpacesRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/organizations/my-org-guid/spaces?inline-relations-depth=1",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: `
{
"next_url": "/v2/organizations/my-org-guid/spaces?inline-relations-depth=1&page=2",
"resources": [
{
"metadata": {
"guid": "acceptance-space-guid"
},
"entity": {
"name": "acceptance",
"allow_ssh": true,
"security_groups": [
{
"metadata": {
"guid": "4302b3b4-4afc-4f12-ae6d-ed1bb815551f"
},
"entity": {
"name": "imma-security-group"
}
}
]
}
}
]
}`}})
开发者ID:yingkitw,项目名称:cli,代码行数:31,代码来源:spaces_test.go
示例9:
writer.WriteHeader(http.StatusInternalServerError)
return
}
writer.WriteHeader(http.StatusOK)
fmt.Fprint(writer, expectedResponse)
}
listFilesServer := httptest.NewServer(http.HandlerFunc(listFilesEndpoint))
defer listFilesServer.Close()
req := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/apps/my-app-guid/instances/1/files/some/path",
Response: testnet.TestResponse{
Status: http.StatusTemporaryRedirect,
Header: http.Header{
"Location": {fmt.Sprintf("%s/some/path", listFilesServer.URL)},
},
},
})
listFilesRedirectServer, handler := testnet.NewServer([]testnet.TestRequest{req})
defer listFilesRedirectServer.Close()
configRepo := testconfig.NewRepositoryWithDefaults()
configRepo.SetAPIEndpoint(listFilesRedirectServer.URL)
gateway := cloudcontrollergateway.NewTestCloudControllerGateway(configRepo)
repo := NewCloudControllerAppFilesRepository(configRepo, gateway)
list, err := repo.ListFiles("my-app-guid", 1, "some/path")
开发者ID:yingkitw,项目名称:cli,代码行数:31,代码来源:app_files_test.go
示例10: testSpacesFindByNameWithOrg
func testSpacesFindByNameWithOrg(orgGUID string, findByName func(SpaceRepository, string) (models.Space, error)) {
findSpaceByNameResponse := testnet.TestResponse{
Status: http.StatusOK,
Body: `
{
"resources": [
{
"metadata": {
"guid": "space1-guid"
},
"entity": {
"name": "Space1",
"organization_guid": "org1-guid",
"organization": {
"metadata": {
"guid": "org1-guid"
},
"entity": {
"name": "Org1"
}
},
"apps": [
{
"metadata": {
"guid": "app1-guid"
},
"entity": {
"name": "app1"
}
},
{
"metadata": {
"guid": "app2-guid"
},
"entity": {
"name": "app2"
}
}
],
"domains": [
{
"metadata": {
"guid": "domain1-guid"
},
"entity": {
"name": "domain1"
}
}
],
"service_instances": [
{
"metadata": {
"guid": "service1-guid"
},
"entity": {
"name": "service1"
}
}
]
}
}
]
}`}
request := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: fmt.Sprintf("/v2/organizations/%s/spaces?q=name%%3Aspace1", orgGUID),
Response: findSpaceByNameResponse,
})
ts, handler, repo := createSpacesRepo(request)
defer ts.Close()
space, apiErr := findByName(repo, "Space1")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr).NotTo(HaveOccurred())
Expect(space.Name).To(Equal("Space1"))
Expect(space.GUID).To(Equal("space1-guid"))
Expect(space.Organization.GUID).To(Equal("org1-guid"))
Expect(len(space.Applications)).To(Equal(2))
Expect(space.Applications[0].GUID).To(Equal("app1-guid"))
Expect(space.Applications[1].GUID).To(Equal("app2-guid"))
Expect(len(space.Domains)).To(Equal(1))
Expect(space.Domains[0].GUID).To(Equal("domain1-guid"))
Expect(len(space.ServiceInstances)).To(Equal(1))
Expect(space.ServiceInstances[0].GUID).To(Equal("service1-guid"))
Expect(apiErr).NotTo(HaveOccurred())
return
}
开发者ID:jsloyer,项目名称:cli,代码行数:93,代码来源:spaces_test.go
示例11:
ts, handler = testnet.NewServer(requests)
config.SetAPIEndpoint(ts.URL)
}
It("lists buildpacks", func() {
setupTestServer(
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/buildpacks",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: `{
"next_url": "/v2/buildpacks?page=2",
"resources": [
{
"metadata": {
"guid": "buildpack1-guid"
},
"entity": {
"name": "Buildpack1",
"position" : 1,
"filename" : "firstbp.zip"
}
}
]
}`}}),
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/buildpacks?page=2",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: `{
开发者ID:Reejoshi,项目名称:cli,代码行数:32,代码来源:buildpacks_test.go
示例12:
app, apiErr := repo.Read("My App")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr).NotTo(HaveOccurred())
Expect(app.Name).To(Equal("My App"))
Expect(app.GUID).To(Equal("app1-guid"))
Expect(app.Memory).To(Equal(int64(128)))
Expect(app.DiskQuota).To(Equal(int64(512)))
Expect(app.InstanceCount).To(Equal(1))
Expect(app.EnvironmentVars).To(Equal(map[string]interface{}{"foo": "bar", "baz": "boom"}))
Expect(app.Routes[0].Host).To(Equal("app1"))
Expect(app.Routes[0].Domain.Name).To(Equal("cfapps.io"))
Expect(app.Stack.Name).To(Equal("awesome-stacks-ahoy"))
})
It("returns a failure response when the app is not found", func() {
request := apifakes.NewCloudControllerTestRequest(findAppRequest)
request.Response = testnet.TestResponse{Status: http.StatusOK, Body: `{"resources": []}`}
ts, handler, repo := createAppRepo([]testnet.TestRequest{request})
defer ts.Close()
_, apiErr := repo.Read("My App")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr.(*errors.ModelNotFoundError)).NotTo(BeNil())
})
})
Describe(".GetApp", func() {
It("returns an application using the given app guid", func() {
request := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
开发者ID:yingkitw,项目名称:cli,代码行数:31,代码来源:applications_test.go
示例13:
testSpacesDidNotFindByNameWithOrg("another-org-guid",
func(repo SpaceRepository, spaceName string) (models.Space, error) {
return repo.FindByNameInOrg(spaceName, "another-org-guid")
},
)
})
})
It("creates spaces without a space-quota", func() {
request := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "POST",
Path: "/v2/spaces",
Matcher: testnet.RequestBodyMatcher(`{"name":"space-name","organization_guid":"my-org-guid"}`),
Response: testnet.TestResponse{Status: http.StatusCreated, Body: `
{
"metadata": {
"guid": "space-guid"
},
"entity": {
"name": "space-name"
}
}`},
})
ts, handler, repo := createSpacesRepo(request)
defer ts.Close()
space, apiErr := repo.Create("space-name", "my-org-guid", "")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr).NotTo(HaveOccurred())
Expect(space.GUID).To(Equal("space-guid"))
Expect(space.SpaceQuotaGUID).To(Equal(""))
开发者ID:jsloyer,项目名称:cli,代码行数:32,代码来源:spaces_test.go
示例14:
)
var _ = Describe("Service Brokers Repo", func() {
It("lists services brokers", func() {
firstRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/service_brokers",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: `{
"next_url": "/v2/service_brokers?page=2",
"resources": [
{
"metadata": {
"guid":"found-guid-1"
},
"entity": {
"name": "found-name-1",
"broker_url": "http://found.example.com-1",
"auth_username": "found-username-1",
"auth_password": "found-password-1"
}
}
]
}`,
},
})
secondRequest := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/service_brokers?page=2",
开发者ID:Reejoshi,项目名称:cli,代码行数:31,代码来源:service_brokers_test.go
示例15:
"github.com/onsi/gomega/ghttp"
)
var _ = Describe("CloudControllerCurlRepository ", func() {
var (
headers string
body string
apiErr error
)
Describe("GET requests", func() {
BeforeEach(func() {
req := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/endpoint",
Response: testnet.TestResponse{
Status: http.StatusOK,
Body: expectedJSONResponse},
})
ts, handler := testnet.NewServer([]testnet.TestRequest{req})
defer ts.Close()
deps := newCurlDependencies()
deps.config.SetAPIEndpoint(ts.URL)
repo := NewCloudControllerCurlRepository(deps.config, deps.gateway)
headers, body, apiErr = repo.Request("GET", "/v2/endpoint", "", "")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr).NotTo(HaveOccurred())
})
开发者ID:yingkitw,项目名称:cli,代码行数:31,代码来源:curl_test.go
示例16:
gateway := net.NewCloudControllerGateway(configRepo, time.Now, new(terminalfakes.FakeUI), new(tracefakes.FakePrinter))
repo = NewCloudControllerRouteRepository(configRepo, gateway)
})
AfterEach(func() {
if ts != nil {
ts.Close()
}
})
Describe("List routes", func() {
It("lists routes in the current space", func() {
ts, handler = testnet.NewServer([]testnet.TestRequest{
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/spaces/the-space-guid/routes?inline-relations-depth=1",
Response: firstPageRoutesResponse,
}),
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/spaces/the-space-guid/routes?inline-relations-depth=1&page=2",
Response: secondPageRoutesResponse,
}),
})
configRepo.SetAPIEndpoint(ts.URL)
routes := []models.Route{}
apiErr := repo.ListRoutes(func(route models.Route) bool {
routes = append(routes, route)
return true
})
开发者ID:jsloyer,项目名称:cli,代码行数:31,代码来源:routes_test.go
示例17:
gateway := net.NewCloudControllerGateway(configRepo, time.Now, new(terminalfakes.FakeUI), new(tracefakes.FakePrinter), "")
repo = NewCloudControllerServiceRepository(configRepo, gateway)
})
AfterEach(func() {
if testServer != nil {
testServer.Close()
}
})
Describe("GetAllServiceOfferings", func() {
BeforeEach(func() {
setupTestServer(
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/services",
Response: firstOfferingsResponse,
}),
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "GET",
Path: "/v2/services",
Response: multipleOfferingsResponse,
}),
)
})
It("gets all public service offerings", func() {
offerings, err := repo.GetAllServiceOfferings()
Expect(testHandler).To(HaveAllRequestsCalled())
Expect(err).NotTo(HaveOccurred())
开发者ID:Reejoshi,项目名称:cli,代码行数:31,代码来源:services_test.go
示例18:
BeforeEach(func() {
configRepo = testconfig.NewRepositoryWithDefaults()
gateway := cloudcontrollergateway.NewTestCloudControllerGateway(configRepo)
repo = NewCloudControllerServiceAuthTokenRepository(configRepo, gateway)
})
AfterEach(func() {
testServer.Close()
})
Describe("Create", func() {
It("creates a service auth token", func() {
setupTestServer(apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "POST",
Path: "/v2/service_auth_tokens",
Matcher: testnet.RequestBodyMatcher(`{"label":"a label","provider":"a provider","token":"a token"}`),
Response: testnet.TestResponse{Status: http.StatusCreated},
}))
err := repo.Create(models.ServiceAuthTokenFields{
Label: "a label",
Provider: "a provider",
Token: "a token",
})
Expect(testHandler).To(HaveAllRequestsCalled())
Expect(err).NotTo(HaveOccurred())
})
})
Describe("FindAll", func() {
开发者ID:yingkitw,项目名称:cli,代码行数:32,代码来源:service_auth_tokens_test.go
示例19: createPasswordRepo
"github.com/cloudfoundry/cli/cf/terminal/terminalfakes"
testconfig "github.com/cloudfoundry/cli/testhelpers/configuration"
testnet "github.com/cloudfoundry/cli/testhelpers/net"
. "github.com/cloudfoundry/cli/cf/api/password"
"github.com/cloudfoundry/cli/cf/trace/tracefakes"
. "github.com/cloudfoundry/cli/testhelpers/matchers"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
var _ = Describe("CloudControllerPasswordRepository", func() {
It("updates your password", func() {
req := apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "PUT",
Path: "/Users/my-user-guid/password",
Matcher: testnet.RequestBodyMatcher(`{"password":"new-password","oldPassword":"old-password"}`),
Response: testnet.TestResponse{Status: http.StatusOK},
})
passwordUpdateServer, handler, repo := createPasswordRepo(req)
defer passwordUpdateServer.Close()
apiErr := repo.UpdatePassword("old-password", "new-password")
Expect(handler).To(HaveAllRequestsCalled())
Expect(apiErr).NotTo(HaveOccurred())
})
})
func createPasswordRepo(req testnet.TestRequest) (passwordServer *httptest.Server, handler *testnet.TestHandler, repo Repository) {
passwordServer, handler = testnet.NewServer([]testnet.TestRequest{req})
开发者ID:Reejoshi,项目名称:cli,代码行数:31,代码来源:password_test.go
示例20:
AfterEach(func() { testServer.Close() })
setupTestServer := func(reqs ...testnet.TestRequest) {
testServer, testHandler = testnet.NewServer(reqs)
configRepo.SetAPIEndpoint(testServer.URL)
}
Describe(".BindSpace", func() {
It("associates the security group with the space", func() {
setupTestServer(
apifakes.NewCloudControllerTestRequest(testnet.TestRequest{
Method: "PUT",
Path: "/v2/security_groups/this-is-a-security-group-guid/spaces/yes-its-a-space-guid",
Response: testnet.TestResponse{
Status: http.StatusCreated,
Body: `
{
"metadata": {"guid": "fb6fdf81-ce1b-448f-ada9-09bbb8807812"},
"entity": {"name": "dummy1", "rules": [] }
}`,
},
}))
err := repo.BindSpace("this-is-a-security-group-guid", "yes-its-a-space-guid")
Expect(err).ToNot(HaveOccurred())
Expect(testHandler).To(HaveAllRequestsCalled())
})
})
Describe(".UnbindSpace", func() {
It("removes the associated security group from the space", func() {
开发者ID:jsloyer,项目名称:cli,代码行数:32,代码来源:space_binder_test.go
注:本文中的github.com/cloudfoundry/cli/cf/api/apifakes.NewCloudControllerTestRequest函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论