本文整理汇总了Golang中github.com/juju/utils.GetValidatingHTTPClient函数的典型用法代码示例。如果您正苦于以下问题:Golang GetValidatingHTTPClient函数的具体用法?Golang GetValidatingHTTPClient怎么用?Golang GetValidatingHTTPClient使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了GetValidatingHTTPClient函数的12个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: TestValidatingClientGetter
func (s *httpSuite) TestValidatingClientGetter(c *gc.C) {
client := utils.GetValidatingHTTPClient()
_, err := client.Get(s.Server.URL)
c.Assert(err, gc.ErrorMatches, "(.|\n)*x509: certificate signed by unknown authority")
client1 := utils.GetValidatingHTTPClient()
c.Assert(client1, gc.Not(gc.Equals), client)
}
开发者ID:kat-co,项目名称:utils,代码行数:8,代码来源:http_test.go
示例2: checkFileHasContents
func checkFileHasContents(c *gc.C, stor storage.StorageReader, name string, contents []byte, attempt utils.AttemptStrategy) {
r, err := storage.GetWithRetry(stor, name, attempt)
c.Assert(err, gc.IsNil)
c.Check(r, gc.NotNil)
defer r.Close()
data, err := ioutil.ReadAll(r)
c.Check(err, gc.IsNil)
c.Check(data, gc.DeepEquals, contents)
url, err := stor.URL(name)
c.Assert(err, gc.IsNil)
var resp *http.Response
for a := attempt.Start(); a.Next(); {
resp, err = utils.GetValidatingHTTPClient().Get(url)
c.Assert(err, gc.IsNil)
if resp.StatusCode != 404 {
break
}
c.Logf("get retrying after earlier get succeeded. *sigh*.")
}
c.Assert(err, gc.IsNil)
data, err = ioutil.ReadAll(resp.Body)
c.Assert(err, gc.IsNil)
defer resp.Body.Close()
c.Assert(resp.StatusCode, gc.Equals, 200, gc.Commentf("error response: %s", data))
c.Check(data, gc.DeepEquals, contents)
}
开发者ID:rogpeppe,项目名称:juju,代码行数:29,代码来源:tests.go
示例3: downloadToolsRaw
// downloadToolsRaw downloads the supplied tools and returns the raw bytes.
func downloadToolsRaw(c *gc.C, t *coretools.Tools) []byte {
resp, err := utils.GetValidatingHTTPClient().Get(t.URL)
c.Assert(err, gc.IsNil)
defer resp.Body.Close()
c.Assert(resp.StatusCode, gc.Equals, http.StatusOK)
var buf bytes.Buffer
_, err = io.Copy(&buf, resp.Body)
c.Assert(err, gc.IsNil)
return buf.Bytes()
}
开发者ID:zhouqt,项目名称:juju,代码行数:11,代码来源:sync_test.go
示例4: downloadTools
// downloadTools downloads the supplied tools and extracts them into a
// new directory.
func downloadTools(c *gc.C, t *coretools.Tools) string {
resp, err := utils.GetValidatingHTTPClient().Get(t.URL)
c.Assert(err, gc.IsNil)
defer resp.Body.Close()
cmd := exec.Command("tar", "xz")
cmd.Dir = c.MkDir()
cmd.Stdin = resp.Body
out, err := cmd.CombinedOutput()
c.Assert(err, gc.IsNil, gc.Commentf(string(out)))
return cmd.Dir
}
开发者ID:zhouqt,项目名称:juju,代码行数:13,代码来源:sync_test.go
示例5: NewHTTPClient
// NewHTTPClient returns an HTTP client initialized based on State.
func (s *State) NewHTTPClient() *http.Client {
httpclient := utils.GetValidatingHTTPClient()
tlsconfig := tls.Config{
RootCAs: s.certPool,
// We want to be specific here (rather than just using "anything".
// See commit 7fc118f015d8480dfad7831788e4b8c0432205e8 (PR 899).
ServerName: "juju-apiserver",
}
httpclient.Transport = utils.NewHttpTLSTransport(&tlsconfig)
return httpclient
}
开发者ID:Pankov404,项目名称:juju,代码行数:12,代码来源:http.go
示例6: PrimeTools
// PrimeTools sets up the current version of the tools to vers and
// makes sure that they're available in the dataDir.
func PrimeTools(c *gc.C, stor storage.Storage, dataDir, toolsDir string, vers version.Binary) *coretools.Tools {
err := os.RemoveAll(filepath.Join(dataDir, "tools"))
c.Assert(err, jc.ErrorIsNil)
agentTools, err := uploadFakeToolsVersion(stor, toolsDir, vers)
c.Assert(err, jc.ErrorIsNil)
resp, err := utils.GetValidatingHTTPClient().Get(agentTools.URL)
c.Assert(err, jc.ErrorIsNil)
defer resp.Body.Close()
err = agenttools.UnpackTools(dataDir, agentTools, resp.Body)
c.Assert(err, jc.ErrorIsNil)
return agentTools
}
开发者ID:pmatulis,项目名称:juju,代码行数:14,代码来源:tools.go
示例7: copyOneToolsPackage
// copyOneToolsPackage copies one tool from the source to the target.
func copyOneToolsPackage(tool *coretools.Tools, dest storage.Storage) error {
toolsName := envtools.StorageName(tool.Version)
logger.Infof("copying %v", toolsName)
resp, err := utils.GetValidatingHTTPClient().Get(tool.URL)
if err != nil {
return err
}
buf := &bytes.Buffer{}
srcFile := resp.Body
defer srcFile.Close()
tool.SHA256, tool.Size, err = utils.ReadSHA256(io.TeeReader(srcFile, buf))
if err != nil {
return err
}
sizeInKB := (tool.Size + 512) / 1024
logger.Infof("downloaded %v (%dkB), uploading", toolsName, sizeInKB)
logger.Infof("download %dkB, uploading", sizeInKB)
return dest.Put(toolsName, buf, tool.Size)
}
开发者ID:jiasir,项目名称:juju,代码行数:20,代码来源:sync.go
示例8: copyOneToolsPackage
// copyOneToolsPackage copies one tool from the source to the target.
func copyOneToolsPackage(tools *coretools.Tools, u ToolsUploader) error {
toolsName := envtools.StorageName(tools.Version)
logger.Infof("downloading %v (%v)", toolsName, tools.URL)
resp, err := utils.GetValidatingHTTPClient().Get(tools.URL)
if err != nil {
return err
}
defer resp.Body.Close()
// Verify SHA-256 hash.
var buf bytes.Buffer
sha256, size, err := utils.ReadSHA256(io.TeeReader(resp.Body, &buf))
if err != nil {
return err
}
if tools.SHA256 == "" {
logger.Warningf("no SHA-256 hash for %v", tools.SHA256)
} else if sha256 != tools.SHA256 {
return errors.Errorf("SHA-256 hash mismatch (%v/%v)", sha256, tools.SHA256)
}
sizeInKB := (size + 512) / 1024
logger.Infof("uploading %v (%dkB) to environment", toolsName, sizeInKB)
return u.UploadTools(tools, buf.Bytes())
}
开发者ID:kapilt,项目名称:juju,代码行数:24,代码来源:sync.go
示例9: TestValidatingClientGetter
func (s *httpSuite) TestValidatingClientGetter(c *gc.C) {
client1 := utils.GetValidatingHTTPClient()
client2 := utils.GetHTTPClient(utils.VerifySSLHostnames)
c.Check(client1, gc.Equals, client2)
}
开发者ID:sinzui,项目名称:utils,代码行数:5,代码来源:http_test.go
示例10: TestSecureClientNoAccess
func (s *dialSuite) TestSecureClientNoAccess(c *gc.C) {
s.PatchValue(&utils.OutgoingAccessAllowed, false)
_, err := utils.GetValidatingHTTPClient().Get("http://10.0.0.1:1234")
c.Assert(err, gc.ErrorMatches, `.*access to address "10.0.0.1:1234" not allowed`)
}
开发者ID:sinzui,项目名称:utils,代码行数:5,代码来源:http_test.go
示例11: Client
// Client returns a storage object that will talk to the
// storage server at the given network address (see Serve)
func Client(addr string) storage.Storage {
return &localStorage{
addr: addr,
client: utils.GetValidatingHTTPClient(),
}
}
开发者ID:jiasir,项目名称:juju,代码行数:8,代码来源:storage.go
示例12: TestSecureClientAllowAccess
func (s *httpDialSuite) TestSecureClientAllowAccess(c *gc.C) {
_, err := utils.GetValidatingHTTPClient().Get("http://0.1.2.3:1234")
c.Assert(err, gc.ErrorMatches, `Get http://0.1.2.3:1234: dial tcp 0.1.2.3:1234: connect: .*`)
}
开发者ID:anastasiamac,项目名称:utils,代码行数:4,代码来源:http_test.go
注:本文中的github.com/juju/utils.GetValidatingHTTPClient函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论