- Sort Score
- Result 10 results
- Languages All
Results 951 - 960 of 1,384 for funcs (0.02 sec)
-
cmd/server-main_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "reflect" "testing" ) func TestServerConfigFile(t *testing.T) { for _, testcase := range []struct { config string expectedErr bool hash string }{ { config: "testdata/config/1.yaml", expectedErr: false,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Dec 07 09:33:56 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/metacache-manager.go
trash map[string]metacache // Recently deleted lists. } const metacacheMaxEntries = 5000 // initManager will start async saving the cache. func (m *metacacheManager) initManager() { // Add a transient bucket. // Start saver when object layer is ready. go func() { objAPI := newObjectLayerFn() for objAPI == nil { time.Sleep(time.Second) objAPI = newObjectLayerFn() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
cmd/xl-storage-format-v1_gen.go
"github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BitrotAlgorithm) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint zb0001, err = dc.ReadUint() if err != nil { err = msgp.WrapError(err) return } (*z) = BitrotAlgorithm(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 41.2K bytes - Viewed (0) -
api/next/66626.txt
pkg go/types, method (*Interface) EmbeddedTypes() iter.Seq[Type] #66626 pkg go/types, method (*Interface) ExplicitMethods() iter.Seq[*Func] #66626 pkg go/types, method (*Interface) Methods() iter.Seq[*Func] #66626 pkg go/types, method (*MethodSet) Methods() iter.Seq[*Selection] #66626 pkg go/types, method (*Named) Methods() iter.Seq[*Func] #66626 pkg go/types, method (*Scope) Children() iter.Seq[*Scope] #66626 pkg go/types, method (*Struct) Fields() iter.Seq[*Var] #66626
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Jul 31 22:54:09 UTC 2024 - 743 bytes - Viewed (0) -
cmd/metacache-server-pool.go
"github.com/minio/minio/internal/grid" xioutil "github.com/minio/minio/internal/ioutil" ) func renameAllBucketMetacache(epPath string) error { // Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to // to `.minio.sys/tmp/` for deletion. return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error { if typ == os.ModeDir {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/scannermetric_string.go
// Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[scannerMetricReadMetadata-0] _ = x[scannerMetricCheckMissing-1] _ = x[scannerMetricSaveUsage-2]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/bitrot_test.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "testing" ) func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) { tmpDir := t.TempDir() volume := "testvol" filePath := "testfile" disk, err := newLocalXLStorage(tmpDir) if err != nil { t.Fatal(err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 2.1K bytes - Viewed (0) -
istioctl/pkg/util/configdump/util.go
ecds configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump" ) // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) { var dumpAny *anypb.Any for _, conf := range w.Configs { if conf.TypeUrl == string(sectionTypeURL) { dumpAny = conf } }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sun Dec 24 08:16:26 UTC 2023 - 2.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
// ---------- // Places a quota configuration on the specified bucket. The quota // specified in the quota configuration will be applied by default // to enforce total quota for the specified bucket. func (a adminAPIHandlers) PutBucketQuotaConfigHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction) if objectAPI == nil { return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 33.2K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
t.Errorf("Read error: got %T, want testError1", err) } } func TestRingBufferCloseErrorUnblocks(t *testing.T) { const sz = 100 rb := New(sz).SetBlocking(true) testCancel := func(fn func()) { t.Helper() defer timeout(5 * time.Second)() rb.Reset() done := make(chan struct{}) go func() { defer close(done) time.Sleep(10 * time.Millisecond) fn() }()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0)