- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for devops (0.18 sec)
-
cni/pkg/nodeagent/net_test.go
ztunnelServer := &fakeZtunnel{} fakeIPSetDeps := ipset.FakeNLDeps() set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps} netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs()), set) netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error { return toRun() }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
internal/grid/benchmark_test.go
// This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) b.Run("rpc", func(b *testing.B) { for par := 1; par <= 32; par *= 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/object-handlers.go
_, err := globalDNSConfig.Get(bucket) if err != nil && err != dns.ErrNotImplemented { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } opts, err := delOpts(ctx, r, bucket, object) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } rcfg, _ := globalBucketObjectLockSys.Get(bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
func NewIPSet(name string, v6 bool, deps NetlinkIpsetDeps) (IPSet, error) { var err error set := IPSet{ V4Name: fmt.Sprintf(V4Name, name), Deps: deps, Prefix: name, } err = deps.ipsetIPHashCreate(set.V4Name, false) if v6 { set.V6Name = fmt.Sprintf(V6Name, name) v6err := deps.ipsetIPHashCreate(set.V6Name, true) err = errors.Join(err, v6err) } return set, err
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/object-api-options.go
Bucket: bucket, Object: object, Err: fmt.Errorf("Unable to parse %s, value should be either 'true' or 'false'", headerName), } } } return false, nil } func delOpts(ctx context.Context, r *http.Request, bucket, object string) (opts ObjectOptions, err error) { opts, err = getOpts(ctx, r, bucket, object) if err != nil { return opts, err } deletePrefix := false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 14.2K bytes - Viewed (0) -
src/bufio/scan.go
// but advance only one byte. This matches the behavior of a range loop over // an incorrectly encoded string. return 1, errorRune, nil } // dropCR drops a terminal \r from the data. func dropCR(data []byte) []byte { if len(data) > 0 && data[len(data)-1] == '\r' { return data[0 : len(data)-1] } return data }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication.go
rcfg, err := getReplicationConfig(ctx, bucket) if err != nil || rcfg == nil { replLogOnceIf(ctx, err, bucket) return } // If incoming request is a replication request, it does not need to be re-replicated. if delOpts.ReplicationRequest { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
src/archive/tar/reader_test.go
Uid: 010000000, ModTime: time.Unix(0, 0), Typeflag: '0', }}, }, { // USTAR archive with a regular entry with non-zero device numbers. file: "testdata/ustar-file-devs.tar", headers: []*Header{{ Name: "file", Mode: 0644, Typeflag: '0', ModTime: time.Unix(0, 0), Devmajor: 1, Devminor: 1, Format: FormatUSTAR, }}, }, {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Nov 21 21:14:38 GMT 2022 - 47.1K bytes - Viewed (0) -
src/cmd/api/main_test.go
} name := contextName(w.context) imports, ok := listCache.Load(name) if !ok { listSem <- semToken{} defer func() { <-listSem }() cmd := exec.Command(goCmd(), "list", "-e", "-deps", "-json", "std") cmd.Env = listEnv(w.context) if w.context.Dir != "" { cmd.Dir = w.context.Dir } cmd.Stderr = os.Stderr out, err := cmd.Output() if err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
lastBatchProcess = time.Now() retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 { nWorkers := atomic.LoadInt64(&h.workers)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)