- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,124 for Nil (0.01 sec)
-
cmd/admin-handlers_test.go
- erasureDirs, err := getRandomDisks(16)
- if err != nil {
- return nil, nil, err
- }
- endpoints := mustGetPoolEndpoints(0, erasureDirs...)
- globalPolicySys = NewPolicySys()
- objLayer, err := newErasureServerPools(ctx, endpoints)
- if err != nil {
- return nil, nil, err
- }
- // Make objLayer available to all internal services via globalObjectAPI.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
internal/logger/config.go
- var host *xnet.Host
- host, err = xnet.ParseHost(s)
- if err != nil {
- break
- }
- brokers = append(brokers, *host)
- }
- if err != nil {
- return cfg, err
- }
- clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth))
- clientAuth, err := strconv.Atoi(clientAuthCfgVal)
- if err != nil {
- return cfg, err
- }
- kafkaArgs := kafka.Config{
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/iam-etcd-store.go
- data, err := json.Marshal(item)
- if err != nil {
- return err
- }
- if GlobalKMS != nil {
- data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
- minioMetaBucket: path.Join(minioMetaBucket, itemPath),
- })
- if err != nil {
- return err
- }
- }
- return saveKeyEtcd(ctx, ies.client, itemPath, data, opts...)
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 01:29:20 UTC 2024 - 14K bytes - Viewed (0) -
cmd/encryption-v1_test.go
- for i, test := range decryptETagTests {
- etag, err := DecryptETag(test.ObjectKey, test.ObjectInfo)
- if err != nil && !test.ShouldFail {
- t.Fatalf("Test %d: should succeed but failed: %v", i, err)
- }
- if err == nil && test.ShouldFail {
- t.Fatalf("Test %d: should fail but succeeded", i)
- }
- if err == nil {
- if etag != test.ETag {
- t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag)
- }
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 24 04:17:08 UTC 2022 - 19.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
- }
- func (c *ConfigWriter) retrieveSortedListenerSlice() ([]*listener.Listener, error) {
- if c.configDump == nil {
- return nil, fmt.Errorf("config writer has not been primed")
- }
- listenerDump, err := c.configDump.GetListenerConfigDump()
- if err != nil {
- return nil, fmt.Errorf("listener dump: %v", err)
- }
- listeners := make([]*listener.Listener, 0)
- for _, l := range listenerDump.DynamicListeners {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
- if !sleep.UntilContext(s.ctx, time.Duration(msInterval)*time.Millisecond) {
- return nil, fmt.Errorf("aborted")
- }
- }
- if err != nil {
- return nil, fmt.Errorf("failed to get pod %s/%s: %v", namespace, name, err)
- }
- // This shouldn't happen - we only trigger this when a pod is added to ambient.
- if ambientPod == nil {
- return nil, fmt.Errorf("pod %s/%s is unexpectedly not enrolled in ambient", namespace, name)
- }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jul 02 18:48:50 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/tier-handlers.go
- if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
- writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
- return
- }
- err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
- if err != nil {
- writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
- return
- }
- err = globalTierConfigMgr.Save(ctx, objAPI)
- if err != nil {
- writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 7.5K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
- case []interface{}:
- dst := make([]Value, len(rval))
- for i := range rval {
- v, err := jsonToValue(rval[i])
- if err != nil {
- return nil, err
- }
- dst[i] = *v
- }
- return FromArray(dst), nil
- case simdjson.Object:
- o := rval
- elems, err := o.Parse(nil)
- if err != nil {
- return nil, err
- }
- bs, err := elems.MarshalJSON()
- if err != nil {
- return nil, err
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 12K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
- func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
- v, ok := <-r.decoded
- if !ok {
- if r.err != nil && *r.err != nil {
- return nil, errJSONParsingError(*r.err)
- }
- return nil, io.EOF
- }
- dstRec, ok := dst.(*Record)
- if !ok {
- dstRec = &Record{}
- }
- dstRec.object = v
- return dstRec, nil
- }
- // Close - closes underlying reader.
- func (r *Reader) Close() error {
- // Close the input.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
internal/event/targetlist_test.go
- func (target ExampleTarget) Save(eventData Event) error {
- return target.send(eventData)
- }
- // Store - Returns a nil store.
- func (target ExampleTarget) Store() TargetStore {
- return nil
- }
- func (target ExampleTarget) send(eventData Event) error {
- b := make([]byte, 1)
- if _, err := rand.Read(b); err != nil {
- panic(err)
- }
- time.Sleep(time.Duration(b[0]) * time.Millisecond)
- if target.sendErr {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0)