本文整理汇总了Golang中git/curoverse/com/arvados/git/sdk/go/arvadostest.StartAPI函数的典型用法代码示例。如果您正苦于以下问题:Golang StartAPI函数的具体用法?Golang StartAPI怎么用?Golang StartAPI使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了StartAPI函数的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: SetupDataManagerTest
func SetupDataManagerTest(t *testing.T) {
os.Setenv("ARVADOS_API_HOST_INSECURE", "true")
// start api and keep servers
arvadostest.ResetEnv()
arvadostest.StartAPI()
arvadostest.StartKeep(2, false)
var err error
arv, err = arvadosclient.MakeArvadosClient()
if err != nil {
t.Fatalf("Error making arvados client: %s", err)
}
arv.ApiToken = arvadostest.DataManagerToken
// keep client
keepClient = &keepclient.KeepClient{
Arvados: &arv,
Want_replicas: 2,
Client: &http.Client{},
}
// discover keep services
if err = keepClient.DiscoverKeepServers(); err != nil {
t.Fatalf("Error discovering keep services: %s", err)
}
keepServers = []string{}
for _, host := range keepClient.LocalRoots() {
keepServers = append(keepServers, host)
}
}
开发者ID:aflyhorse,项目名称:arvados,代码行数:31,代码来源:datamanager_test.go
示例2: SetUpSuite
func (s *NoKeepServerSuite) SetUpSuite(c *C) {
arvadostest.StartAPI()
// We need API to have some keep services listed, but the
// services themselves should be unresponsive.
arvadostest.StartKeep(2, false)
arvadostest.StopKeep(2)
}
开发者ID:Kunde21,项目名称:arvados,代码行数:7,代码来源:keepproxy_test.go
示例3: SetUpTest
func (s *TestSuite) SetUpTest(c *C) {
args := []string{"crunch-dispatch-slurm"}
os.Args = args
arvadostest.StartAPI()
os.Setenv("ARVADOS_API_TOKEN", arvadostest.Dispatch1Token)
}
开发者ID:pombredanne,项目名称:arvados,代码行数:7,代码来源:crunch-dispatch-slurm_test.go
示例4: SetUpSuite
func (s *ServerRequiredSuite) SetUpSuite(c *C) {
if *no_server {
c.Skip("Skipping tests that require server")
return
}
arvadostest.StartAPI()
arvadostest.StartKeep()
}
开发者ID:WangZhenfei,项目名称:arvados,代码行数:8,代码来源:keepclient_test.go
示例5: SetUpSuite
func (s *IntegrationSuite) SetUpSuite(c *check.C) {
arvadostest.StartAPI()
arvadostest.StartKeep(2, true)
arv, err := arvadosclient.MakeArvadosClient()
c.Assert(err, check.Equals, nil)
arv.ApiToken = arvadostest.ActiveToken
kc, err := keepclient.MakeKeepClient(&arv)
c.Assert(err, check.Equals, nil)
kc.PutB([]byte("Hello world\n"))
kc.PutB([]byte("foo"))
kc.PutB([]byte("foobar"))
}
开发者ID:pombredanne,项目名称:arvados,代码行数:13,代码来源:server_test.go
示例6: SetupPullWorkerIntegrationTest
func SetupPullWorkerIntegrationTest(t *testing.T, testData PullWorkIntegrationTestData, wantData bool) PullRequest {
os.Setenv("ARVADOS_API_HOST_INSECURE", "true")
// start api and keep servers
arvadostest.StartAPI()
arvadostest.StartKeep()
// make arvadosclient
arv, err := arvadosclient.MakeArvadosClient()
if err != nil {
t.Error("Error creating arv")
}
// keep client
keepClient = &keepclient.KeepClient{
Arvados: &arv,
Want_replicas: 1,
Using_proxy: true,
Client: &http.Client{},
}
// discover keep services
var servers []string
if err := keepClient.DiscoverKeepServers(); err != nil {
t.Error("Error discovering keep services")
}
for _, host := range keepClient.LocalRoots() {
servers = append(servers, host)
}
// Put content if the test needs it
if wantData {
locator, _, err := keepClient.PutB([]byte(testData.Content))
if err != nil {
t.Errorf("Error putting test data in setup for %s %s %v", testData.Content, locator, err)
}
if locator == "" {
t.Errorf("No locator found after putting test data")
}
}
// Create pullRequest for the test
pullRequest := PullRequest{
Locator: testData.Locator,
Servers: servers,
}
return pullRequest
}
开发者ID:boratonAJ,项目名称:arvados,代码行数:48,代码来源:pull_worker_integration_test.go
示例7: SetUpSuite
func (s *integrationSuite) SetUpSuite(c *check.C) {
if testing.Short() {
c.Skip("-short")
}
arvadostest.ResetEnv()
arvadostest.StartAPI()
arvadostest.StartKeep(4, true)
arv, err := arvadosclient.MakeArvadosClient()
arv.ApiToken = arvadostest.DataManagerToken
c.Assert(err, check.IsNil)
s.keepClient = &keepclient.KeepClient{
Arvados: &arv,
Client: &http.Client{},
}
c.Assert(s.keepClient.DiscoverKeepServers(), check.IsNil)
s.putReplicas(c, "foo", 4)
s.putReplicas(c, "bar", 1)
}
开发者ID:pombredanne,项目名称:arvados,代码行数:19,代码来源:integration_test.go
示例8: SetUpSuite
func (s *ServerRequiredSuite) SetUpSuite(c *C) {
// Start API server
arvadostest.StartAPI()
}
开发者ID:pombredanne,项目名称:arvados,代码行数:4,代码来源:keep-rsync_test.go
示例9: SetUpSuite
func (s *IntegrationSuite) SetUpSuite(c *check.C) {
arvadostest.StartAPI()
}
开发者ID:WangZhenfei,项目名称:arvados,代码行数:3,代码来源:server_test.go
示例10: SetUpSuite
func (s *TestSuite) SetUpSuite(c *C) {
initialArgs = os.Args
arvadostest.StartAPI()
runningCmds = make(map[string]*exec.Cmd)
}
开发者ID:pombredanne,项目名称:arvados,代码行数:5,代码来源:crunch-dispatch-local_test.go
示例11: setupRsync
// Testing keep-rsync needs two sets of keep services: src and dst.
// The test setup hence creates 3 servers instead of the default 2,
// and uses the first 2 as src and the 3rd as dst keep servers.
func setupRsync(c *C, enforcePermissions bool, replications int) {
// srcConfig
var srcConfig apiConfig
srcConfig.APIHost = os.Getenv("ARVADOS_API_HOST")
srcConfig.APIToken = os.Getenv("ARVADOS_API_TOKEN")
srcConfig.APIHostInsecure = matchTrue.MatchString(os.Getenv("ARVADOS_API_HOST_INSECURE"))
// dstConfig
var dstConfig apiConfig
dstConfig.APIHost = os.Getenv("ARVADOS_API_HOST")
dstConfig.APIToken = os.Getenv("ARVADOS_API_TOKEN")
dstConfig.APIHostInsecure = matchTrue.MatchString(os.Getenv("ARVADOS_API_HOST_INSECURE"))
if enforcePermissions {
blobSigningKey = "zfhgfenhffzltr9dixws36j1yhksjoll2grmku38mi7yxd66h5j4q9w4jzanezacp8s6q0ro3hxakfye02152hncy6zml2ed0uc"
}
// Start Keep servers
arvadostest.StartAPI()
arvadostest.StartKeepWithParams(3, enforcePermissions)
// setup keepclients
var err error
kcSrc, err = setupKeepClient(srcConfig, srcKeepServicesJSON, false, 0)
c.Check(err, IsNil)
kcDst, err = setupKeepClient(dstConfig, dstKeepServicesJSON, true, replications)
c.Check(err, IsNil)
for uuid := range kcSrc.LocalRoots() {
if strings.HasSuffix(uuid, "02") {
delete(kcSrc.LocalRoots(), uuid)
}
}
for uuid := range kcSrc.GatewayRoots() {
if strings.HasSuffix(uuid, "02") {
delete(kcSrc.GatewayRoots(), uuid)
}
}
for uuid := range kcSrc.WritableLocalRoots() {
if strings.HasSuffix(uuid, "02") {
delete(kcSrc.WritableLocalRoots(), uuid)
}
}
for uuid := range kcDst.LocalRoots() {
if strings.HasSuffix(uuid, "00") || strings.HasSuffix(uuid, "01") {
delete(kcDst.LocalRoots(), uuid)
}
}
for uuid := range kcDst.GatewayRoots() {
if strings.HasSuffix(uuid, "00") || strings.HasSuffix(uuid, "01") {
delete(kcDst.GatewayRoots(), uuid)
}
}
for uuid := range kcDst.WritableLocalRoots() {
if strings.HasSuffix(uuid, "00") || strings.HasSuffix(uuid, "01") {
delete(kcDst.WritableLocalRoots(), uuid)
}
}
if replications == 0 {
// Must have got default replications value of 2 from dst discovery document
c.Assert(kcDst.Want_replicas, Equals, 2)
} else {
// Since replications value is provided, it is used
c.Assert(kcDst.Want_replicas, Equals, replications)
}
}
开发者ID:brainstorm,项目名称:arvados,代码行数:72,代码来源:keep-rsync_test.go
注:本文中的git/curoverse/com/arvados/git/sdk/go/arvadostest.StartAPI函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论