- Sort Score
- Result 10 results
- Languages All
Results 501 - 510 of 1,387 for funcs (0.03 sec)
-
cmd/erasure-object_test.go
} gr.Close() if !bytes.Equal(output.Bytes(), bigData) { t.Fatalf("Corrupted data found") } } func TestObjectQuorumFromMeta(t *testing.T) { ExecObjectLayerTestWithDirs(t, testObjectQuorumFromMeta) } func testObjectQuorumFromMeta(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) { bucket := getRandomBucketName() var opts ObjectOptions
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
"istio.io/istio/pkg/util/sets" ) type PodToNetns map[string]WorkloadInfo func (p PodToNetns) Close() { for _, wl := range p { wl.Netns.Close() } } type PodNetnsFinder interface { FindNetnsForPods(filter map[types.UID]*corev1.Pod) (PodToNetns, error) } type PodNetnsProcFinder struct { proc fs.FS } func NewPodNetnsProcFinder(proc fs.FS) *PodNetnsProcFinder { return &PodNetnsProcFinder{proc: proc}
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 11K bytes - Viewed (0) -
internal/arn/arn_test.go
ResourceID: "my-role", }, want: "arn:minio::us-east-1::role/my-role", }, } for _, tt := range tests { t.Run(tt.want, func(t *testing.T) { if got := tt.arn.String(); got != tt.want { t.Errorf("ARN.String() = %v, want %v", got, tt.want) } }) } } func TestNewIAMRoleARN(t *testing.T) { type args struct { resourceID string serverRegion string } tests := []struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 08:31:34 UTC 2024 - 5.1K bytes - Viewed (0) -
src/cmd/cgo/gcc.go
// // When the call to C.f is deferred, we use an additional function // literal to evaluate the arguments at the right time. // defer func() func() { // _cgo0 := p // return func() { // _cgoCheckPointer(_cgo0, nil) // C.f(_cgo0) // } // }()() // This works because the defer statement evaluates the first
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Sep 18 15:07:34 UTC 2024 - 97.1K bytes - Viewed (0) -
internal/s3select/json/preader.go
func (r *PReader) startReaders() { r.bufferPool.New = func() interface{} { return make([]byte, jsonSplitSize+1024) } // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/event/name.go
} // Mask returns the type as mask. // Compound "All" types are expanded. func (name Name) Mask() uint64 { if name < objectSingleTypesEnd { return 1 << (name - 1) } var mask uint64 for _, n := range name.Expand() { mask |= 1 << (n - 1) } return mask } // String - returns string representation of event type. func (name Name) String() string { switch name { case BucketCreated:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 01:11:10 UTC 2024 - 10.4K bytes - Viewed (0) -
internal/logger/config.go
} // NewConfig - initialize new logger config. func NewConfig() Config { cfg := Config{ // Console logging is on by default Console: Console{ Enabled: true, }, HTTP: make(map[string]http.Config), AuditWebhook: make(map[string]http.Config), AuditKafka: make(map[string]kafka.Config), } return cfg } func getCfgVal(envName, key, defaultValue string) string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 20 16:02:50 UTC 2024 - 18.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
etcdStr = " (with etcd backend)" } t.Run( fmt.Sprintf("Test: %d, ServerType: %s%s", i+1, testCase.serverType, etcdStr), func(t *testing.T) { runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 97.1K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list_test.go
}, }, expectedRevision: "test-anno", }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.name), func(t *testing.T) { assert.Equal(t, c.expectedRevision, extractRevisionFromPod(c.pod)) }) } } func Test_getNamespaces(t *testing.T) { createNamespace := func(name string, labels map[string]string) *corev1.Namespace { return &corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: name,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
* limitations under the License. */ package target import ( "testing" xnet "github.com/minio/pkg/v3/net" natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnPlain(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14222 s := natsserver.RunServer(&opts) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K bytes - Viewed (0)