- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for rulesets (0.21 sec)
-
src/bufio/bufio.go
return NewReaderSize(rd, defaultBufSize) } // Size returns the size of the underlying buffer in bytes. func (b *Reader) Size() int { return len(b.buf) } // Reset discards any buffered data, resets all state, and switches // the buffered reader to read from r. // Calling Reset on the zero value of [Reader] initializes the internal buffer // to the default size.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
cmd/admin-handlers_test.go
return &adminErasureTestBed{ erasureDirs: erasureDirs, objLayer: objLayer, router: adminRouter, done: cancel, }, nil } // TearDown - method that resets the test bed for subsequent unit // tests to start afresh. func (atb *adminErasureTestBed) TearDown() { atb.done() removeRoots(atb.erasureDirs) resetTestGlobals() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
t.Fatal(err) } ruleSet := make(map[string]struct{}) for _, rule := range lc.Rules { ruleBytes, err := xml.Marshal(rule) if err != nil { t.Fatal(err) } ruleSet[string(ruleBytes)] = struct{}{} } for _, rule := range lc1.Rules { ruleBytes, err := xml.Marshal(rule) if err != nil { t.Fatal(err) } if _, ok := ruleSet[string(ruleBytes)]; !ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 45.6K bytes - Viewed (0) -
cmd/http-stats.go
} func (st *HTTPStats) addRequestsInQueue(i int32) { atomic.AddInt32(&st.s3RequestsInQueue, i) } func (st *HTTPStats) incS3RequestsIncoming() { // Golang automatically resets to zero if this overflows atomic.AddUint64(&st.s3RequestsIncoming, 1) } // Converts http stats into struct to be sent back to the client. func (st *HTTPStats) toServerHTTPStats(toLowerKeys bool) ServerHTTPStats {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
src/bytes/buffer.go
if n == 0 { b.Reset() return } b.lastRead = opInvalid if n < 0 || n > b.Len() { panic("bytes.Buffer: truncation out of range") } b.buf = b.buf[:b.off+n] } // Reset resets the buffer to be empty, // but it retains the underlying storage for use by future writes. // Reset is the same as [Buffer.Truncate](0). func (b *Buffer) Reset() { b.buf = b.buf[:0] b.off = 0
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
Version: "25", }), strings.Split(command, " ")) rootCmd.SetOut(&out) err := rootCmd.Execute() return out.String(), err } // cleanTestCluster resets the test cluster. func cleanTestCluster() error { // Needed in case we are running a test through this path that doesn't start a new process. cache.FlushObjectCaches() if !kubeBuilderInstalled() { return nil }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (0) -
cmd/test-utils_test.go
if !v.hasEnded() { v.stop() } } globalBackgroundHealState.Unlock() } } // sets globalIAMSys to `nil`. func resetGlobalIAMSys() { globalIAMSys = nil } // Resets all the globals used modified in tests. // Resetting ensures that the changes made to globals by one test doesn't affect others. func resetTestGlobals() { // set globalObjectAPI to `nil`. resetGlobalObjectAPI()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
internal/store/batch.go
if b.isFull() { return ErrBatchFull } if _, ok := b.items[key]; !ok { b.keys = append(b.keys, key) } b.items[key] = item return nil } // GetAll fetches the items and resets the batch // Returned items are not referenced by the batch func (b *Batch[K, T]) GetAll() (orderedKeys []K, orderedItems []T, err error) { b.Lock() defer b.Unlock() orderedKeys = append([]K(nil), b.keys...)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
cfg.executeHostDeleteCommands() } func (cfg *IptablesConfigurator) executeHostDeleteCommands() { optionalDeleteCmds := [][]string{ // delete our main jump in the host ruleset. If it's not there, NBD. {"-t", iptablesconstants.NAT, "-D", iptablesconstants.POSTROUTING, "-j", ChainHostPostrouting}, // flush-then-delete our created chains
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
src/bytes/reader.go
if m > len(b) { panic("bytes.Reader.WriteTo: invalid Write count") } r.i += int64(m) n = int64(m) if m != len(b) && err == nil { err = io.ErrShortWrite } return } // Reset resets the [Reader.Reader] to be reading from b. func (r *Reader) Reset(b []byte) { *r = Reader{b, 0, -1} } // NewReader returns a new [Reader.Reader] reading from b.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 3.9K bytes - Viewed (0)