Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 1,387 for funcs (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top