本文整理汇总了Golang中github.com/gfrey/smutje/logger.Logger类的典型用法代码示例。如果您正苦于以下问题:Golang Logger类的具体用法?Golang Logger怎么用?Golang Logger使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Logger类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: Provision
func (res *smResource) Provision(l logger.Logger) (err error) {
l = l.Tag(res.ID)
for _, pkg := range res.Packages {
if err := pkg.Provision(l, res.client); err != nil {
return err
}
}
return nil
}
开发者ID:gfrey,项目名称:smutje,代码行数:10,代码来源:resource.go
示例2: readStream
func (lsess *loggedSession) readStream(l logger.Logger, stream io.Reader) {
defer lsess.wg.Done()
sc := bufio.NewScanner(stream)
for sc.Scan() {
l.Printf(sc.Text())
}
if err := sc.Err(); err != nil {
l.Printf("failed scanning stderr: %s", err)
}
}
开发者ID:gfrey,项目名称:smutje,代码行数:12,代码来源:logged_session.go
示例3: Prepare
func (res *smResource) Prepare(l logger.Logger) error {
l = l.Tag(res.ID)
if err := res.initializeClient(); err != nil {
return err
}
for _, pkg := range res.Packages {
if err := pkg.Prepare(res.client, res.Attributes); err != nil {
return err
}
}
return nil
}
开发者ID:gfrey,项目名称:smutje,代码行数:14,代码来源:resource.go
示例4: newLoggedSession
func newLoggedSession(l logger.Logger, sess Session) (Session, error) {
s := &loggedSession{Session: sess, wg: new(sync.WaitGroup)}
stdout, err := s.Session.StdoutPipe()
if err != nil {
return nil, errors.Wrap(err, "failed to build stdout pipe")
}
stderr, err := s.Session.StderrPipe()
if err != nil {
return nil, errors.Wrap(err, "failed to build stderr pipe")
}
s.wg.Add(2)
go s.readStream(l.Tag("stdout"), stdout)
go s.readStream(l.Tag("stderr"), stderr)
return s, nil
}
开发者ID:gfrey,项目名称:smutje,代码行数:19,代码来源:logged_session.go
示例5: Exec
func (a *execJenkinsArtifactCmd) Exec(l logger.Logger, client connection.Client) error {
sess, err := client.NewLoggedSession(l)
if err != nil {
return err
}
defer sess.Close()
l.Printf("downloading file %q from %q", a.Target, a.url)
setFilePerms := ""
// TODO is possible to set only one of the both?
if a.Owner != "" && a.Umask != "" {
setFilePerms = " && chown " + a.Owner + " %[1]s && chmod " + a.Umask + " %[1]s"
}
cmd := fmt.Sprintf(`bash -c "{ dir=$(dirname %[1]s); test -d \${dir} || mkdir -p \${dir}; } && curl -sSL %[2]s -o %[1]s`+setFilePerms+`"`, a.Target, a.url)
if err := sess.Start(cmd); err != nil {
return err
}
return sess.Wait()
}
开发者ID:gfrey,项目名称:smutje,代码行数:21,代码来源:script_smutje.go
示例6: Provision
func (pkg *smPackage) Provision(l logger.Logger, client connection.Client) (err error) {
l = l.Tag(pkg.ID)
oldState := pkg.state
pkg.state = make([]string, len(pkg.Scripts))
allCached := true
defer func() {
if allCached {
return
}
e := pkg.writeTargetState(client)
if err == nil {
err = e
}
}()
for i, s := range pkg.Scripts {
hash := s.Hash()
if allCached && i < len(oldState) && oldState[i][1:] == hash {
l.Printf("step %d cached", i)
pkg.state[i] = "." + hash
continue
}
allCached = false
if err = s.Exec(l, client); err != nil {
l.Printf("failed in %s", hash)
pkg.state[i] = "-" + hash
pkg.state = pkg.state[:i+1]
return err
}
pkg.state[i] = "+" + hash
}
return nil
}
开发者ID:gfrey,项目名称:smutje,代码行数:39,代码来源:package.go
示例7: Create
func (hp *smartOS) Create(l logger.Logger, blueprint string) (string, error) {
m := map[string]interface{}{}
if err := json.Unmarshal([]byte(blueprint), &m); err != nil {
return "", errors.Wrap(err, "failed to unmarshal the blueprint")
}
l.Printf("updating the image database")
if err := runCommand(hp.client, "imgadm update"); err != nil {
return "", err
}
imgUUID := m["image_uuid"].(string)
l.Printf("importing image %s", imgUUID)
if err := runCommand(hp.client, "imgadm import -q "+imgUUID); err != nil {
return "", err
}
// determine whether the VM in question already exists
sess, err := hp.client.NewSession()
if err != nil {
return "", err
}
defer sess.Close()
wg := new(sync.WaitGroup)
wg.Add(2)
outBuf := bytes.NewBuffer(nil)
stderr, err := sess.StderrPipe()
if err != nil {
return "", errors.Wrap(err, "failed to retrieve stderr pipe")
}
go func() {
defer wg.Done()
_, _ = io.Copy(outBuf, stderr)
}()
stdin, err := sess.StdinPipe()
if err != nil {
return "", errors.Wrap(err, "failed to retrieve stdin pipe")
}
go func() {
defer wg.Done()
_, _ = io.WriteString(stdin, blueprint)
stdin.Close()
}()
l.Printf("creating the virtual resource")
if err := sess.Run("vmadm create"); err != nil {
log.Printf("failed: %s", outBuf.String())
return "", err
}
wg.Wait()
output := strings.TrimSpace(outBuf.String())
expResponsePrefix := "Successfully created VM "
if !strings.HasPrefix(output, expResponsePrefix) {
return "", errors.Errorf("wrong response received: %s", output)
}
return strings.TrimPrefix(output, expResponsePrefix), nil
}
开发者ID:gfrey,项目名称:smutje,代码行数:63,代码来源:smartos.go
注:本文中的github.com/gfrey/smutje/logger.Logger类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论