本文整理汇总了Golang中github.com/cloudfoundry-incubator/cf-test-helpers/cf.AsUser函数的典型用法代码示例。如果您正苦于以下问题:Golang AsUser函数的具体用法?Golang AsUser怎么用?Golang AsUser使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了AsUser函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: Destroy
func (b ServiceBroker) Destroy() {
cf.AsUser(b.context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
Expect(cf.Cf("purge-service-offering", b.Service.Name, "-f").Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
b.Delete()
Expect(cf.Cf("delete", b.Name, "-f", "-r").Wait(DEFAULT_TIMEOUT)).To(Exit(0))
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:7,代码来源:broker.go
示例2: Setup
func (context *ConfiguredContext) Setup() {
cf.AsUser(context.AdminUserContext(), func() {
definition := quotaDefinition{
Name: context.quotaDefinitionName,
TotalServices: "100",
TotalRoutes: "1000",
MemoryLimit: "10G",
NonBasicServicesAllowed: true,
}
args := []string{
"create-quota",
context.quotaDefinitionName,
"-m", definition.MemoryLimit,
"-r", definition.TotalRoutes,
"-s", definition.TotalServices,
}
if definition.NonBasicServicesAllowed {
args = append(args, "--allow-paid-service-plans")
}
Expect(cf.Cf(args...).Wait(CF_API_TIMEOUT)).To(Exit(0))
createUserSession := cf.Cf("create-user", context.regularUserUsername, context.regularUserPassword)
createUserSession.Wait(CF_API_TIMEOUT)
if createUserSession.ExitCode() != 0 {
Expect(createUserSession.Out).To(Say("scim_resource_already_exists"))
}
Expect(cf.Cf("create-org", context.organizationName).Wait(CF_API_TIMEOUT)).To(Exit(0))
Expect(cf.Cf("set-quota", context.organizationName, definition.Name).Wait(CF_API_TIMEOUT)).To(Exit(0))
})
}
开发者ID:naohiko,项目名称:cf-acceptance-tests,代码行数:35,代码来源:context.go
示例3: Setup
func (context *ConfiguredContext) Setup() {
cf.AsUser(context.AdminUserContext(), func() {
channel := cf.Cf("create-user", context.regularUserUsername, context.regularUserPassword)
select {
case <-channel.Out.Detect("OK"):
case <-channel.Out.Detect("scim_resource_already_exists"):
case <-time.After(ScaledTimeout(10 * time.Second)):
Fail("failed to create user")
}
definition := quotaDefinition{
Name: context.quotaDefinitionName,
TotalServices: 100,
TotalRoutes: 1000,
MemoryLimit: 10240,
NonBasicServicesAllowed: true,
}
definitionPayload, err := json.Marshal(definition)
Expect(err).ToNot(HaveOccurred())
var response cf.GenericResource
cf.ApiRequest("POST", "/v2/quota_definitions", &response, string(definitionPayload))
context.quotaDefinitionGUID = response.Metadata.Guid
Eventually(cf.Cf("create-org", context.organizationName), ScaledTimeout(60*time.Second)).Should(Exit(0))
Eventually(cf.Cf("set-quota", context.organizationName, definition.Name), ScaledTimeout(60*time.Second)).Should(Exit(0))
})
}
开发者ID:shalako,项目名称:cf-mysql-release,代码行数:34,代码来源:context.go
示例4: Teardown
func (c *context) Teardown() {
userOrg := c.RegularUserContext().Org
cf.RestoreUserContext(c.RegularUserContext(), c.shortTimeout, c.originalCfHomeDir, c.currentCfHomeDir)
cf.AsUser(c.AdminUserContext(), c.shortTimeout, func() {
runner.NewCmdRunner(cf.Cf("delete-user", "-f", c.regularUserUsername), c.longTimeout).Run()
// delete-space does not provide an org flag, so we must target the Org first
runner.NewCmdRunner(cf.Cf("target", "-o", userOrg), c.longTimeout).Run()
runner.NewCmdRunner(cf.Cf("delete-space", "-f", c.spaceName), c.longTimeout).Run()
if !c.useExistingOrg {
runner.NewCmdRunner(cf.Cf("delete-org", "-f", c.organizationName), c.longTimeout).Run()
cf.ApiRequest(
"DELETE",
"/v2/quota_definitions/"+c.quotaDefinitionGUID+"?recursive=true",
nil,
c.ShortTimeout(),
)
}
if c.config.CreatePermissiveSecurityGroup {
runner.NewCmdRunner(cf.Cf("delete-security-group", "-f", c.securityGroupName), c.shortTimeout).Run()
}
})
}
开发者ID:ekcasey,项目名称:cf-test-helpers,代码行数:29,代码来源:context.go
示例5: PublicizePlan
func (b ServiceBroker) PublicizePlan(url string) {
jsonMap := make(map[string]bool)
jsonMap["public"] = true
planJson, _ := json.Marshal(jsonMap)
cf.AsUser(b.context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
Expect(cf.Cf("curl", url, "-X", "PUT", "-d", string(planJson)).Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:8,代码来源:broker.go
示例6: deleteServiceBroker
func deleteServiceBroker(brokerName string) {
config = helpers.LoadConfig()
context := helpers.NewContext(config)
cf.AsUser(context.AdminUserContext(), context.ShortTimeout(), func() {
responseBuffer := cf.Cf("delete-service-broker", brokerName, "-f")
Expect(responseBuffer.Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:8,代码来源:route_services_test.go
示例7: Delete
func (b ServiceBroker) Delete() {
cf.AsUser(b.context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
Expect(cf.Cf("delete-service-broker", b.Name, "-f").Wait(DEFAULT_TIMEOUT)).To(Exit(0))
brokers := cf.Cf("service-brokers").Wait(DEFAULT_TIMEOUT)
Expect(brokers).To(Exit(0))
Expect(brokers.Out.Contents()).ToNot(ContainSubstring(b.Name))
})
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:9,代码来源:broker.go
示例8: lastPageUsageEvents
func lastPageUsageEvents(appName string) []AppUsageEvent {
var response AppUsageEvents
cf.AsUser(context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
cf.ApiRequest("GET", "/v2/app_usage_events?order-direction=desc&page=1", &response, DEFAULT_TIMEOUT)
})
return response.Resources
}
开发者ID:naheedmk,项目名称:cf-acceptance-tests,代码行数:9,代码来源:app_lifecycle_test.go
示例9: Setup
func (e *Environment) Setup() {
e.context.Setup()
cf.AsUser(e.context.AdminUserContext(), func() {
setUpSpaceWithUserAccess(e.context.RegularUserContext())
})
e.originalCfHomeDir, e.currentCfHomeDir = cf.InitiateUserContext(e.context.RegularUserContext())
cf.TargetSpace(e.context.RegularUserContext())
}
开发者ID:naohiko,项目名称:cf-acceptance-tests,代码行数:10,代码来源:environment.go
示例10: Teardown
func (context *ConfiguredContext) Teardown() {
cf.AsUser(context.AdminUserContext(), func() {
Expect(cf.Cf("delete-user", "-f", context.regularUserUsername).Wait(CF_API_TIMEOUT)).To(Exit(0))
if !context.isPersistent {
Expect(cf.Cf("delete-org", "-f", context.organizationName).Wait(CF_API_TIMEOUT)).To(Exit(0))
Expect(cf.Cf("delete-quota", "-f", context.quotaDefinitionName).Wait(CF_API_TIMEOUT)).To(Exit(0))
}
})
}
开发者ID:naohiko,项目名称:cf-acceptance-tests,代码行数:11,代码来源:context.go
示例11: lastAppUsageEvent
func lastAppUsageEvent(appName string, state string) (bool, AppUsageEvent) {
var response AppUsageEvents
cf.AsUser(context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
cf.ApiRequest("GET", "/v2/app_usage_events?order-direction=desc&page=1&results-per-page=150", &response, DEFAULT_TIMEOUT)
})
for _, event := range response.Resources {
if event.Entity.AppName == appName && event.Entity.State == state {
return true, event
}
}
return false, AppUsageEvent{}
}
开发者ID:cwlbraa,项目名称:cf-acceptance-tests,代码行数:14,代码来源:lifecycle_test.go
示例12: Teardown
func (context *ConfiguredContext) Teardown() {
cf.AsUser(context.AdminUserContext(), func() {
Eventually(cf.Cf("delete-user", "-f", context.regularUserUsername), ScaledTimeout(60*time.Second)).Should(Exit(0))
if !context.isPersistent {
Eventually(cf.Cf("delete-org", "-f", context.organizationName), ScaledTimeout(60*time.Second)).Should(Exit(0))
cf.ApiRequest(
"DELETE",
"/v2/quota_definitions/"+context.quotaDefinitionGUID+"?recursive=true",
nil,
)
}
})
}
开发者ID:shalako,项目名称:cf-mysql-release,代码行数:15,代码来源:context.go
示例13: PublicizePlans
func (b ServiceBroker) PublicizePlans() {
url := fmt.Sprintf("/v2/services?inline-relations-depth=1&q=label:%s", b.Service.Name)
var session *Session
cf.AsUser(b.context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
session = cf.Cf("curl", url).Wait(DEFAULT_TIMEOUT)
Expect(session).To(Exit(0))
})
structure := ServicesResponse{}
json.Unmarshal(session.Out.Contents(), &structure)
for _, service := range structure.Resources {
if service.Entity.Label == b.Service.Name {
for _, plan := range service.Entity.ServicePlans {
if b.HasPlan(plan.Entity.Name) {
b.PublicizePlan(plan.Metadata.Url)
}
}
}
}
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:20,代码来源:broker.go
示例14: getCfHomeConfig
func getCfHomeConfig() *cfHomeConfig {
myCfHomeConfig := &cfHomeConfig{}
cf.AsUser(context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
path := filepath.Join(os.Getenv("CF_HOME"), ".cf", "config.json")
configFile, err := os.Open(path)
if err != nil {
panic(err)
}
decoder := json.NewDecoder(configFile)
err = decoder.Decode(myCfHomeConfig)
if err != nil {
panic(err)
}
})
return myCfHomeConfig
}
开发者ID:cwlbraa,项目名称:cf-acceptance-tests,代码行数:20,代码来源:loggregator_test.go
示例15: Setup
func (c *context) Setup() {
cf.AsUser(c.AdminUserContext(), c.shortTimeout, func() {
runner.NewCmdRunner(cf.Cf("create-user", c.regularUserUsername, c.regularUserPassword), c.shortTimeout).Run()
if c.useExistingOrg == false {
definition := QuotaDefinition{
Name: c.quotaDefinitionName,
TotalServices: 100,
TotalRoutes: 1000,
MemoryLimit: 10240,
NonBasicServicesAllowed: true,
}
definitionPayload, err := json.Marshal(definition)
gomega.Expect(err).ToNot(gomega.HaveOccurred())
var response cf.GenericResource
cf.ApiRequest("POST", "/v2/quota_definitions", &response, c.shortTimeout, string(definitionPayload))
c.quotaDefinitionGUID = response.Metadata.Guid
runner.NewCmdRunner(cf.Cf("create-org", c.organizationName), c.shortTimeout).Run()
runner.NewCmdRunner(cf.Cf("set-quota", c.organizationName, c.quotaDefinitionName), c.shortTimeout).Run()
}
c.setUpSpaceWithUserAccess(c.RegularUserContext())
if c.config.CreatePermissiveSecurityGroup {
c.createPermissiveSecurityGroup()
}
})
c.originalCfHomeDir, c.currentCfHomeDir = cf.InitiateUserContext(c.RegularUserContext(), c.shortTimeout)
cf.TargetSpace(c.RegularUserContext(), c.shortTimeout)
}
开发者ID:ekcasey,项目名称:cf-test-helpers,代码行数:39,代码来源:context.go
示例16: createServiceBroker
func createServiceBroker() (string, string, string) {
serviceBrokerAsset := assets.NewAssets().ServiceBroker
serviceBrokerAppName := PushApp(serviceBrokerAsset, config.RubyBuildpackName)
serviceName := initiateBrokerConfig(serviceBrokerAppName)
brokerName := generator.PrefixedRandomName("RATS-BROKER-")
brokerUrl := helpers.AppUri(serviceBrokerAppName, "")
config = helpers.LoadConfig()
context := helpers.NewContext(config)
cf.AsUser(context.AdminUserContext(), context.ShortTimeout(), func() {
session := cf.Cf("create-service-broker", brokerName, "user", "password", brokerUrl)
Expect(session.Wait(DEFAULT_TIMEOUT)).To(Exit(0))
session = cf.Cf("enable-service-access", serviceName)
Expect(session.Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
return brokerName, serviceBrokerAppName, serviceName
}
开发者ID:cf-routing,项目名称:cf-acceptance-tests,代码行数:22,代码来源:route_services_test.go
示例17: Teardown
func (c *context) Teardown() {
cf.RestoreUserContext(c.RegularUserContext(), c.shortTimeout, c.originalCfHomeDir, c.currentCfHomeDir)
cf.AsUser(c.AdminUserContext(), c.shortTimeout, func() {
runner.NewCmdRunner(cf.Cf("delete-user", "-f", c.regularUserUsername), c.longTimeout).Run()
if !c.isPersistent {
runner.NewCmdRunner(cf.Cf("delete-org", "-f", c.organizationName), c.longTimeout).Run()
cf.ApiRequest(
"DELETE",
"/v2/quota_definitions/"+c.quotaDefinitionGUID+"?recursive=true",
nil,
c.ShortTimeout(),
)
}
if c.config.CreatePermissiveSecurityGroup {
runner.NewCmdRunner(cf.Cf("delete-security-group", "-f", c.securityGroupName), c.shortTimeout).Run()
}
})
}
开发者ID:stefanschneider,项目名称:diego-windows-msi,代码行数:22,代码来源:context.go
示例18: SetupEnvironment
func SetupEnvironment(context SuiteContext) {
var originalCfHomeDir, currentCfHomeDir string
BeforeEach(func() {
AdminUserContext = context.AdminUserContext()
RegularUserContext = context.RegularUserContext()
context.Setup()
cf.AsUser(AdminUserContext, func() {
setUpSpaceWithUserAccess(RegularUserContext)
})
originalCfHomeDir, currentCfHomeDir = cf.InitiateUserContext(RegularUserContext)
cf.TargetSpace(RegularUserContext)
})
AfterEach(func() {
cf.RestoreUserContext(RegularUserContext, originalCfHomeDir, currentCfHomeDir)
context.Teardown()
})
}
开发者ID:shalako,项目名称:cf-mysql-release,代码行数:24,代码来源:environment.go
示例19:
var output []byte
var oldServiceName string
var oldPlanName string
BeforeEach(func() {
broker = NewServiceBroker(
generator.PrefixedRandomName("pblc-brkr-"),
assets.NewAssets().ServiceBroker,
context,
)
cf.TargetSpace(context.RegularUserContext(), context.ShortTimeout())
broker.Push()
broker.Configure()
cf.AsUser(context.AdminUserContext(), context.ShortTimeout(), func() {
broker.Create()
})
})
Describe("Updating the catalog", func() {
BeforeEach(func() {
broker.PublicizePlans()
})
It("updates the broker and sees catalog changes", func() {
// Confirming plans show up in the marketplace for regular user
plans := cf.Cf("marketplace").Wait(DEFAULT_TIMEOUT)
Expect(plans).To(Exit(0))
Expect(plans).To(Say(broker.Service.Name))
开发者ID:cwlbraa,项目名称:cf-acceptance-tests,代码行数:30,代码来源:service_broker_lifecycle_test.go
示例20:
rules := fmt.Sprintf(
`[{"destination":"%s","ports":"%d","protocol":"tcp"},
{"destination":"%s","ports":"%d","protocol":"tcp"}]`,
privateHost, privatePort, containerIp, privatePort)
file, _ := ioutil.TempFile(os.TempDir(), "CATS-sg-rules")
defer os.Remove(file.Name())
file.WriteString(rules)
rulesPath := file.Name()
securityGroupName = fmt.Sprintf("CATS-SG-%s", generator.RandomName())
cf.AsUser(context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
Expect(cf.Cf("create-security-group", securityGroupName, rulesPath).Wait(DEFAULT_TIMEOUT)).To(Exit(0))
Expect(
cf.Cf("bind-security-group",
securityGroupName,
context.RegularUserContext().Org,
context.RegularUserContext().Space).Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
defer func() {
cf.AsUser(context.AdminUserContext(), DEFAULT_TIMEOUT, func() {
Expect(cf.Cf("delete-security-group", securityGroupName, "-f").Wait(DEFAULT_TIMEOUT)).To(Exit(0))
})
}()
Expect(cf.Cf("restart", clientAppName).Wait(CF_PUSH_TIMEOUT)).To(Exit(0))
By("Testing app egress rules")
curlResponse = helpers.CurlApp(clientAppName, fmt.Sprintf("/curl/%s/%d", privateHost, privatePort))
json.Unmarshal([]byte(curlResponse), &doraCurlResponse)
Expect(doraCurlResponse.ReturnCode).To(Equal(0))
开发者ID:drnic,项目名称:noop-cf-boshrelease,代码行数:32,代码来源:running_security_groups_test.go
注:本文中的github.com/cloudfoundry-incubator/cf-test-helpers/cf.AsUser函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论