- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 237 for exits (1.28 sec)
-
cmd/site-replication.go
DeploymentID: d, BandwidthLimit: int64(peer.DefaultBandwidth.Limit), } var exists bool // true if ARN already exists bucketTarget.Arn, exists = globalBucketTargetSys.getRemoteARN(bucket, &bucketTarget, peer.DeploymentID) if !exists { // persist newly generated ARN to targets and metadata on disk err := globalBucketTargetSys.SetTarget(ctx, bucket, &bucketTarget, false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
lib/time/mkzip.go
"archive/zip" "bytes" "flag" "fmt" "hash/crc32" "io/fs" "log" "os" "path/filepath" "strings" ) func usage() { fmt.Fprintf(os.Stderr, "usage: go run mkzip.go zoneinfo.zip\n") os.Exit(2) } func main() { log.SetPrefix("mkzip: ") log.SetFlags(0) flag.Usage = usage flag.Parse() args := flag.Args() if len(args) != 1 || !strings.HasSuffix(args[0], ".zip") { usage() }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 17:32:07 GMT 2024 - 2.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
obj client.Object, patch client.Patch, opts ...client.PatchOption, ) error { // Apply patches are supposed to upsert, but fake client fails if the object doesn't exist, // if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType { return clnt.Patch(ctx, obj, patch, opts...) } check, ok := obj.DeepCopyObject().(client.Object) if !ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cmd/bucket-versioning-handler.go
if s3Error := checkRequestAuthType(ctx, r, policy.GetBucketVersioningAction, bucket, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Check if bucket exists. if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } config, err := globalBucketVersioningSys.Get(bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
internal/logger/reqinfo.go
} // SetTags - sets key/val to ReqInfo.tags func (r *ReqInfo) SetTags(key string, val interface{}) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() // Search of tag key already exists in tags var updated bool for _, tag := range r.tags { if tag.Key == key { tag.Val = val updated = true break } } if !updated { // Append to the end of tags list
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
if !strings.Contains(output, noClusterID) { t.Fatal(err) } } checkFiles := map[string]bool{ // inputs that we allow to exist, if other files seep in unexpectedly we fail the test ".gitignore": false, "meshconfig.yaml": false, "workloadgroup.yaml": false, } for k, v := range generated { checkFiles[k] = v }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { return nil, err } defer func() { if debugReqs { _, ok := c.outgoing.Load(client.MuxID) fmt.Println(client.MuxID, c.String(), "Connection.Request: DELETING MUX. Exists:", ok) } client.cancelFn(context.Canceled) c.outgoing.Delete(client.MuxID) }() return client.traceRoundtrip(ctx, c.trace, h, req) } // Request allows to do a single remote request.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
migrator/migrator.go
tx := m.DB.Session(&gorm.Session{}) if err := m.RunWithValue(values[i], func(stmt *gorm.Statement) error { return tx.Exec("DROP TABLE IF EXISTS ?", m.CurrentTable(stmt)).Error }); err != nil { return err } } return nil } // HasTable returns table exists or not for value, value could be a struct or string func (m Migrator) HasTable(value interface{}) bool { var count int64
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
internal/event/target/nsq.go
return err } eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} return client, nil } // createHostsideProbeIpset creates an ipset. This is designed to be called from the host netns. // Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0)