本文整理汇总了Golang中github.com/pkg/errors.Wrap函数的典型用法代码示例。如果您正苦于以下问题:Golang Wrap函数的具体用法?Golang Wrap怎么用?Golang Wrap使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Wrap函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: IssueAndSaveNewCertificates
// IssueAndSaveNewCertificates generates a new key-pair, signs it with the local root-ca, and returns a
// tls certificate
func (rca *RootCA) IssueAndSaveNewCertificates(paths CertPaths, cn, ou, org string) (*tls.Certificate, error) {
csr, key, err := GenerateAndWriteNewKey(paths)
if err != nil {
return nil, errors.Wrap(err, "error when generating new node certs")
}
if !rca.CanSign() {
return nil, ErrNoValidSigner
}
// Obtain a signed Certificate
certChain, err := rca.ParseValidateAndSignCSR(csr, cn, ou, org)
if err != nil {
return nil, errors.Wrap(err, "failed to sign node certificate")
}
// Ensure directory exists
err = os.MkdirAll(filepath.Dir(paths.Cert), 0755)
if err != nil {
return nil, err
}
// Write the chain to disk
if err := ioutils.AtomicWriteFile(paths.Cert, certChain, 0644); err != nil {
return nil, err
}
// Create a valid TLSKeyPair out of the PEM encoded private key and certificate
tlsKeyPair, err := tls.X509KeyPair(certChain, key)
if err != nil {
return nil, err
}
return &tlsKeyPair, nil
}
开发者ID:SUSE,项目名称:docker.mirror,代码行数:37,代码来源:certificates.go
示例2: handleAddressChange
func (n *Node) handleAddressChange(ctx context.Context, member *membership.Member, reconnectAddr string) error {
newConn, err := n.ConnectToMember(reconnectAddr, 0)
if err != nil {
return errors.Wrapf(err, "could connect to member ID %x at observed address %s", member.RaftID, reconnectAddr)
}
healthCtx, cancelHealth := context.WithTimeout(ctx, time.Duration(n.Config.ElectionTick)*n.opts.TickInterval)
defer cancelHealth()
if err := newConn.HealthCheck(healthCtx); err != nil {
return errors.Wrapf(err, "%x failed health check at observed address %s", member.RaftID, reconnectAddr)
}
if err := n.cluster.ReplaceMemberConnection(member.RaftID, member, newConn, reconnectAddr, false); err != nil {
newConn.Conn.Close()
return errors.Wrap(err, "failed to replace connection to raft member")
}
// If we're the leader, write the address change to raft
updateCtx, cancelUpdate := context.WithTimeout(ctx, time.Duration(n.Config.ElectionTick)*n.opts.TickInterval)
defer cancelUpdate()
if err := n.updateMember(updateCtx, reconnectAddr, member.RaftID, member.NodeID); err != nil {
return errors.Wrap(err, "failed to update member address in raft")
}
return nil
}
开发者ID:Mic92,项目名称:docker,代码行数:27,代码来源:raft.go
示例3: editSubmitPlayerViewHandler
func (s *Site) editSubmitPlayerViewHandler(w http.ResponseWriter, req *http.Request) {
id := mux.Vars(req)["id"]
pid := strToUint(id)
log.Printf("edit player ID: %s", id)
defer func() {
if r := recover(); r != nil {
s.commonEditPlayerViewHandler(w, req,
fmt.Sprintf("%v", r))
}
}()
if err := req.ParseForm(); err != nil {
panic(errors.Wrap(err, "error processing form data"))
}
aliases := req.Form["aliases"]
// expecting name to be 1 element list, aliases a list with
// many aliases
if len(aliases) == 0 {
panic(errors.New("no aliases selected"))
}
log.Printf("claimed aliases: %s", aliases)
err := s.p.UpdatePlayerAliases(pid, aliases)
if err != nil {
panic(errors.Wrap(err, "error updating player"))
}
// redirect to player view
http.Redirect(w, req, s.playerViewURL(pid), http.StatusFound)
}
开发者ID:bboozzoo,项目名称:q3stats,代码行数:34,代码来源:editplayerview.go
示例4: migrateSnapshots
func migrateSnapshots(legacySnapDir, snapDir string) error {
// use temporary snaphot directory so initialization appears atomic
tmpdirpath := filepath.Clean(snapDir) + ".tmp"
if fileutil.Exist(tmpdirpath) {
if err := os.RemoveAll(tmpdirpath); err != nil {
return errors.Wrap(err, "could not remove temporary snapshot directory")
}
}
if err := fileutil.CreateDirAll(tmpdirpath); err != nil {
return errors.Wrap(err, "could not create temporary snapshot directory")
}
snapshotNames, err := fileutil.ReadDir(legacySnapDir)
if err != nil {
return errors.Wrapf(err, "could not list snapshot directory %s", legacySnapDir)
}
for _, fname := range snapshotNames {
err := os.Link(filepath.Join(legacySnapDir, fname), filepath.Join(tmpdirpath, fname))
if err != nil {
return errors.Wrap(err, "error linking snapshot file")
}
}
if err := os.Rename(tmpdirpath, snapDir); err != nil {
return err
}
return nil
}
开发者ID:SUSE,项目名称:docker.mirror,代码行数:30,代码来源:storage.go
示例5: getDirtyExitFailedJobsFromRedis
func getDirtyExitFailedJobsFromRedis(redisClient *redis.Client) ([]redisWorker, error) {
failedJobsLength, err := redisClient.LLen(resqueFailedQueueKey).Result()
if err != nil {
return []redisWorker{}, errors.Wrap(err, "Failed to get failed resque jobs length")
}
failedJobs, err := redisClient.LRange(resqueFailedQueueKey, 0, failedJobsLength).Result()
if err != nil {
return []redisWorker{}, errors.Wrap(err, "Failed to get failed resque jobs")
}
var failedResqueJobs []redisWorker
for _, failedJob := range failedJobs {
var job failedResqueJob
if err := json.Unmarshal([]byte(failedJob), &job); err != nil {
continue
}
if job.Exception == "Resque::DirtyExit" {
failedResqueJobs = append(failedResqueJobs, redisWorker{failedJob, failedJob})
}
}
return failedResqueJobs, nil
}
开发者ID:wearemolecule,项目名称:worker_cleaner,代码行数:25,代码来源:main.go
示例6: UpdateCluster
func UpdateCluster(h sshAble, d drivers.Driver, config KubernetesConfig) error {
client, err := sshutil.NewSSHClient(d)
if err != nil {
return errors.Wrap(err, "Error creating new ssh client")
}
// transfer localkube from cache/asset to vm
if localkubeURIWasSpecified(config) {
lCacher := localkubeCacher{config}
if err = lCacher.updateLocalkubeFromURI(client); err != nil {
return errors.Wrap(err, "Error updating localkube from uri")
}
} else {
if err = updateLocalkubeFromAsset(client); err != nil {
return errors.Wrap(err, "Error updating localkube from asset")
}
}
fileAssets := []CopyableFile{}
addMinikubeAddonsDirToAssets(&fileAssets)
// merge files to copy
var copyableFiles []CopyableFile
copyableFiles = append(copyableFiles, memoryAssets...)
copyableFiles = append(copyableFiles, fileAssets...)
// transfer files to vm
for _, copyableFile := range copyableFiles {
if err := sshutil.Transfer(copyableFile, copyableFile.GetLength(),
copyableFile.GetTargetDir(), copyableFile.GetTargetName(),
copyableFile.GetPermissions(), client); err != nil {
return err
}
}
return nil
}
开发者ID:rawlingsj,项目名称:gofabric8,代码行数:33,代码来源:cluster.go
示例7: StartHost
// StartHost starts a host VM.
func StartHost(api libmachine.API, config MachineConfig) (*host.Host, error) {
exists, err := api.Exists(constants.MachineName)
if err != nil {
return nil, errors.Wrapf(err, "Error checking if host exists: %s", constants.MachineName)
}
if !exists {
return createHost(api, config)
}
glog.Infoln("Machine exists!")
h, err := api.Load(constants.MachineName)
if err != nil {
return nil, errors.Wrap(err, "Error loading existing host. Please try running [minikube delete], then run [minikube start] again.")
}
s, err := h.Driver.GetState()
glog.Infoln("Machine state: ", s)
if err != nil {
return nil, errors.Wrap(err, "Error getting state for host")
}
if s != state.Running {
if err := h.Driver.Start(); err != nil {
return nil, errors.Wrapf(err, "Error starting stopped host")
}
if err := api.Save(h); err != nil {
return nil, errors.Wrapf(err, "Error saving started host")
}
}
if err := h.ConfigureAuth(); err != nil {
return nil, errors.Wrap(err, "Error configuring auth on host: %s")
}
return h, nil
}
开发者ID:rawlingsj,项目名称:gofabric8,代码行数:36,代码来源:cluster.go
示例8: requestToken
func requestToken(schemeData map[string]string) (string, error) {
maxRetries := samlRequestTimeout(schemeData) - 7
time.Sleep(5 * time.Second)
id := samlRequestId(schemeData)
v := url.Values{}
v.Set("request_id", id)
for count := 0; count <= maxRetries; count += 2 {
u, err := GetURL("/auth/login")
if err != nil {
return "", errors.Wrap(err, "Error in GetURL")
}
resp, err := tsuruNet.Dial5Full300Client.Post(u, "application/x-www-form-urlencoded", strings.NewReader(v.Encode()))
if err != nil {
return "", errors.Wrap(err, "Error during login post")
}
defer resp.Body.Close()
result, err := ioutil.ReadAll(resp.Body)
if err != nil {
return "", errors.Wrap(err, "Error reading body")
}
if strings.TrimSpace(string(result)) == saml.ErrRequestWaitingForCredentials.Message {
if count < maxRetries {
time.Sleep(2 * time.Second)
}
continue
}
data := make(map[string]interface{})
if err = json.Unmarshal(result, &data); err != nil {
return "", errors.Errorf("API response: %s", result)
}
return data["token"].(string), nil
}
// finish when timeout
return "", saml.ErrRequestWaitingForCredentials
}
开发者ID:tsuru,项目名称:tsuru,代码行数:35,代码来源:saml.go
示例9: fetchArbitraryCard
func (c *Card) fetchArbitraryCard() error {
u, err := CurrentUser()
if err != nil {
return errors.Wrap(err, "No user logged in")
}
if c.db == nil {
db, err := u.DB()
if err != nil {
return errors.Wrap(err, "Error connecting to User DB")
}
c.db = db
}
doc := make(map[string][]*fb.Card)
query := map[string]interface{}{
"selector": map[string]string{"type": "card"},
"limit": 1,
}
if err := c.db.Find(query, &doc); err != nil {
return err
}
if len(doc["docs"]) == 0 {
return errors.New("No cards available")
}
c.Card = doc["docs"][0]
return nil
}
开发者ID:FlashbackSRS,项目名称:flashback,代码行数:26,代码来源:card.go
示例10: GetJob
func (s *DatabaseStore) GetJob(inst flux.InstanceID, id JobID) (Job, error) {
var (
queue string
method string
paramsBytes []byte
scheduledAt time.Time
priority int
key string
submittedAt time.Time
claimedAt nullTime
heartbeatAt nullTime
finishedAt nullTime
logStr string
status string
done sql.NullBool
success sql.NullBool
)
if err := s.conn.QueryRow(`
SELECT queue, method, params, scheduled_at, priority, key, submitted_at, claimed_at, heartbeat_at, finished_at, log, status, done, success
FROM jobs
WHERE id = $1
AND instance_id = $2
`, string(id), string(inst)).Scan(
&queue, &method, ¶msBytes, &scheduledAt, &priority, &key, &submittedAt,
&claimedAt, &heartbeatAt, &finishedAt, &logStr, &status, &done, &success,
); err == sql.ErrNoRows {
return Job{}, ErrNoSuchJob
} else if err != nil {
return Job{}, errors.Wrap(err, "error getting job")
}
params, err := s.scanParams(method, paramsBytes)
if err != nil {
return Job{}, errors.Wrap(err, "unmarshaling params")
}
var log []string
if err := json.NewDecoder(strings.NewReader(logStr)).Decode(&log); err != nil {
return Job{}, errors.Wrap(err, "unmarshaling log")
}
return Job{
Instance: inst,
ID: id,
Queue: queue,
Method: method,
Params: params,
ScheduledAt: scheduledAt,
Priority: priority,
Key: key,
Submitted: submittedAt,
Claimed: claimedAt.Time,
Heartbeat: heartbeatAt.Time,
Finished: finishedAt.Time,
Log: log,
Status: status,
Done: done.Bool,
Success: success.Bool,
}, nil
}
开发者ID:weaveworks,项目名称:flux,代码行数:60,代码来源:db_store.go
示例11: AddStockcollections
// AddStockcollections adds the given related objects to the existing relationships
// of the contact, optionally inserting them as new records.
// Appends related to o.R.Stockcollections.
// Sets related.R.Contact appropriately.
func (o *Contact) AddStockcollections(exec boil.Executor, insert bool, related ...*Stockcollection) error {
var err error
for _, rel := range related {
rel.ContactID.Int = o.ContactID
rel.ContactID.Valid = true
if insert {
if err = rel.Insert(exec); err != nil {
return errors.Wrap(err, "failed to insert into foreign table")
}
} else {
if err = rel.Update(exec, "contact_id"); err != nil {
return errors.Wrap(err, "failed to update foreign table")
}
}
}
if o.R == nil {
o.R = &contactR{
Stockcollections: related,
}
} else {
o.R.Stockcollections = append(o.R.Stockcollections, related...)
}
for _, rel := range related {
if rel.R == nil {
rel.R = &stockcollectionR{
Contact: o,
}
} else {
rel.R.Contact = o
}
}
return nil
}
开发者ID:dictyBase,项目名称:Modware,代码行数:39,代码来源:contact.go
示例12: writeTargetState
func (pkg *smPackage) writeTargetState(client connection.Client) error {
sess, err := client.NewSession()
if err != nil {
return err
}
defer sess.Close()
stdin, err := sess.StdinPipe()
if err != nil {
return errors.Wrap(err, "failed to receive stdin pipe")
}
tstamp := time.Now().UTC().Format("20060102T150405")
filename := fmt.Sprintf("/var/lib/smutje/%s.%s.log", pkg.ID, tstamp)
cmd := fmt.Sprintf(`bash -c "cat - > %[1]s && ln -sf %[1]s /var/lib/smutje/%[2]s.log"`, filename, pkg.ID)
if err := sess.Start(cmd); err != nil {
return err
}
if _, err := io.WriteString(stdin, strings.Join(pkg.state, "\n")+"\n"); err != nil {
return errors.Wrap(err, "failed to send script to target")
}
stdin.Close()
return sess.Wait()
}
开发者ID:gfrey,项目名称:smutje,代码行数:25,代码来源:package.go
示例13: UnmarshalJSON
// UnmarshalJSON unmarshals a list of conditions from json.
func (cs Conditions) UnmarshalJSON(data []byte) error {
if cs == nil {
return errors.New("Can not be nil")
}
var jcs map[string]jsonCondition
var dc Condition
if err := json.Unmarshal(data, &jcs); err != nil {
return errors.Wrap(err, "")
}
for k, jc := range jcs {
for name, c := range ConditionFactories {
if name == jc.Type {
dc = c()
if len(jc.Options) == 0 {
cs[k] = dc
break
}
if err := json.Unmarshal(jc.Options, dc); err != nil {
return errors.Wrap(err, "")
}
cs[k] = dc
break
}
}
}
return nil
}
开发者ID:ory-am,项目名称:ladon,代码行数:35,代码来源:condition.go
示例14: Update
// Update does PATCH workitem
func (c *WorkitemController) Update(ctx *app.UpdateWorkitemContext) error {
return application.Transactional(c.db, func(appl application.Application) error {
if ctx.Payload == nil || ctx.Payload.Data == nil || ctx.Payload.Data.ID == nil {
return jsonapi.JSONErrorResponse(ctx, errors.NewBadParameterError("missing data.ID element in request", nil))
}
wi, err := appl.WorkItems().Load(ctx, *ctx.Payload.Data.ID)
if err != nil {
return jsonapi.JSONErrorResponse(ctx, errs.Wrap(err, fmt.Sprintf("Failed to load work item with id %v", *ctx.Payload.Data.ID)))
}
// Type changes of WI are not allowed which is why we overwrite it the
// type with the old one after the WI has been converted.
oldType := wi.Type
err = ConvertJSONAPIToWorkItem(appl, *ctx.Payload.Data, wi)
if err != nil {
return jsonapi.JSONErrorResponse(ctx, err)
}
wi.Type = oldType
wi, err = appl.WorkItems().Save(ctx, *wi)
if err != nil {
return jsonapi.JSONErrorResponse(ctx, errs.Wrap(err, "Error updating work item"))
}
wi2 := ConvertWorkItem(ctx.RequestData, wi)
resp := &app.WorkItem2Single{
Data: wi2,
Links: &app.WorkItemLinks{
Self: buildAbsoluteURL(ctx.RequestData),
},
}
return ctx.OK(resp)
})
}
开发者ID:Ritsyy,项目名称:almighty-core,代码行数:32,代码来源:workitem.go
示例15: createSockets
// createSockets initializes the sockets for the socket group based on values from zmq.
func createSockets() (*zmq.Context, SocketGroup, error) {
context, err := zmq.NewContext()
if err != nil {
return context, SocketGroup{}, errors.Wrap(err, "Could not create zmq Context")
}
var sg SocketGroup
sg.ShellSocket, err = context.NewSocket(zmq.ROUTER)
if err != nil {
return context, sg, errors.Wrap(err, "Could not get Shell Socket")
}
sg.ControlSocket, err = context.NewSocket(zmq.ROUTER)
if err != nil {
return context, sg, errors.Wrap(err, "Could not get Control Socket")
}
sg.StdinSocket, err = context.NewSocket(zmq.ROUTER)
if err != nil {
return context, sg, errors.Wrap(err, "Could not get Stdin Socket")
}
sg.IOPubSocket, err = context.NewSocket(zmq.PUB)
if err != nil {
return context, sg, errors.Wrap(err, "Could not get IOPub Socket")
}
return context, sg, nil
}
开发者ID:gopherds,项目名称:gophernotes,代码行数:31,代码来源:gophernotes.go
示例16: makePlots
// makePlots creates and saves the first of our plots showing the raw input data.
func makePlots(xys plotter.XYs) error {
// Create a new plot.
p, err := plot.New()
if err != nil {
return errors.Wrap(err, "Could not create plot object")
}
// Label the new plot.
p.Title.Text = "Daily Counts of Go Repos Created"
p.X.Label.Text = "Days from Jan. 1, 2013"
p.Y.Label.Text = "Count"
// Add the prepared points to the plot.
if err = plotutil.AddLinePoints(p, "Counts", xys); err != nil {
return errors.Wrap(err, "Could not add lines to plot")
}
// Save the plot to a PNG file.
if err := p.Save(7*vg.Inch, 4*vg.Inch, "countseries.png"); err != nil {
return errors.Wrap(err, "Could not output plot")
}
return nil
}
开发者ID:Rahmadkurniawan,项目名称:2016-talks,代码行数:26,代码来源:counts.go
示例17: IssueAndSaveNewCertificates
// IssueAndSaveNewCertificates generates a new key-pair, signs it with the local root-ca, and returns a
// tls certificate
func (rca *RootCA) IssueAndSaveNewCertificates(kw KeyWriter, cn, ou, org string) (*tls.Certificate, error) {
csr, key, err := GenerateNewCSR()
if err != nil {
return nil, errors.Wrap(err, "error when generating new node certs")
}
if !rca.CanSign() {
return nil, ErrNoValidSigner
}
// Obtain a signed Certificate
certChain, err := rca.ParseValidateAndSignCSR(csr, cn, ou, org)
if err != nil {
return nil, errors.Wrap(err, "failed to sign node certificate")
}
// Create a valid TLSKeyPair out of the PEM encoded private key and certificate
tlsKeyPair, err := tls.X509KeyPair(certChain, key)
if err != nil {
return nil, err
}
if err := kw.Write(certChain, key, nil); err != nil {
return nil, err
}
return &tlsKeyPair, nil
}
开发者ID:fabianofranz,项目名称:docker,代码行数:30,代码来源:certificates.go
示例18: sendLoop
func (c *Conn) sendLoop() {
defer c.wg.Done()
sendc := c.Send
for {
select {
case msg := <-sendc:
log.Printf("ws-conn-%04d: send-> %# v", c.ID, pretty.Formatter(msg))
err := websocket.JSON.Send(c.WSConn, msg)
if err != nil {
if !isUseOfClosed(err) {
log.Printf("ws-conn-%04d: send error: %v", c.ID, err)
c.errors.Push(errors.Wrap(err, "send error"))
}
c.Close()
sendc = nil // stop sending messages after an error
}
case <-c.shutdown:
err := c.WSConn.Close()
if err != nil && !isUseOfClosed(err) {
log.Printf("ws-conn-%04d: close error: %v", c.ID, err)
c.errors.Push(errors.Wrap(err, "close error"))
}
log.Printf("ws-conn-%04d: closed", c.ID)
return
case <-c.Done:
c.Close()
}
}
}
开发者ID:livereload,项目名称:LiveReload,代码行数:33,代码来源:conn.go
示例19: CacheMinikubeISOFromURL
func (m *MachineConfig) CacheMinikubeISOFromURL() error {
// store the miniube-iso inside the .minikube dir
response, err := http.Get(m.MinikubeISO)
if err != nil {
return errors.Wrapf(err, "Error getting minikube iso at %s via http", m.MinikubeISO)
}
defer response.Body.Close()
isoData, err := ioutil.ReadAll(response.Body)
if err != nil {
return errors.Wrap(err, "Error reading minikubeISO url response")
}
// Validate the ISO if it was the default URL, before writing it to disk.
if m.MinikubeISO == constants.DefaultIsoUrl {
if !isIsoChecksumValid(&isoData, constants.DefaultIsoShaUrl) {
return errors.New("Error validating ISO checksum.")
}
}
if response.StatusCode != http.StatusOK {
return errors.Errorf("Received %d response from %s while trying to download minikube.iso", response.StatusCode, m.MinikubeISO)
}
out, err := os.Create(m.GetISOCacheFilepath())
if err != nil {
return errors.Wrap(err, "Error creating minikube iso cache filepath")
}
defer out.Close()
if _, err = out.Write(isoData); err != nil {
return errors.Wrap(err, "Error writing iso data to file")
}
return nil
}
开发者ID:rawlingsj,项目名称:gofabric8,代码行数:35,代码来源:cluster.go
示例20: Mount
// Mount mounts the remote at mountpoint.
//
// If noModTime is set then it
func Mount(f fs.Fs, mountpoint string) error {
if debugFUSE {
fuse.Debug = func(msg interface{}) {
fs.Debug("fuse", "%v", msg)
}
}
// Set permissions
dirPerms = 0777 &^ os.FileMode(umask)
filePerms = 0666 &^ os.FileMode(umask)
// Show stats if the user has specifically requested them
if cmd.ShowStats() {
stopStats := cmd.StartStats()
defer close(stopStats)
}
// Mount it
errChan, err := mount(f, mountpoint)
if err != nil {
return errors.Wrap(err, "failed to mount FUSE fs")
}
// Wait for umount
err = <-errChan
if err != nil {
return errors.Wrap(err, "failed to umount FUSE fs")
}
return nil
}
开发者ID:ncw,项目名称:rclone,代码行数:34,代码来源:mount.go
注:本文中的github.com/pkg/errors.Wrap函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论