Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,124 for Nil (0.01 sec)

  1. cmd/admin-handlers_test.go

    1. erasureDirs, err := getRandomDisks(16)
    2. if err != nil {
    3. return nil, nil, err
    4. }
    5. endpoints := mustGetPoolEndpoints(0, erasureDirs...)
    6. globalPolicySys = NewPolicySys()
    7. objLayer, err := newErasureServerPools(ctx, endpoints)
    8. if err != nil {
    9. return nil, nil, err
    10. }
    11.  
    12. // 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)
  2. internal/logger/config.go

    1. var host *xnet.Host
    2. host, err = xnet.ParseHost(s)
    3. if err != nil {
    4. break
    5. }
    6. brokers = append(brokers, *host)
    7. }
    8. if err != nil {
    9. return cfg, err
    10. }
    11.  
    12. clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth))
    13. clientAuth, err := strconv.Atoi(clientAuthCfgVal)
    14. if err != nil {
    15. return cfg, err
    16. }
    17.  
    18. 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)
  3. cmd/iam-etcd-store.go

    1. data, err := json.Marshal(item)
    2. if err != nil {
    3. return err
    4. }
    5. if GlobalKMS != nil {
    6. data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
    7. minioMetaBucket: path.Join(minioMetaBucket, itemPath),
    8. })
    9. if err != nil {
    10. return err
    11. }
    12. }
    13. return saveKeyEtcd(ctx, ies.client, itemPath, data, opts...)
    14. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  4. cmd/encryption-v1_test.go

    1. for i, test := range decryptETagTests {
    2. etag, err := DecryptETag(test.ObjectKey, test.ObjectInfo)
    3. if err != nil && !test.ShouldFail {
    4. t.Fatalf("Test %d: should succeed but failed: %v", i, err)
    5. }
    6. if err == nil && test.ShouldFail {
    7. t.Fatalf("Test %d: should fail but succeeded", i)
    8. }
    9. if err == nil {
    10. if etag != test.ETag {
    11. t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag)
    12. }
    13. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    1. }
    2.  
    3. func (c *ConfigWriter) retrieveSortedListenerSlice() ([]*listener.Listener, error) {
    4. if c.configDump == nil {
    5. return nil, fmt.Errorf("config writer has not been primed")
    6. }
    7. listenerDump, err := c.configDump.GetListenerConfigDump()
    8. if err != nil {
    9. return nil, fmt.Errorf("listener dump: %v", err)
    10. }
    11. listeners := make([]*listener.Listener, 0)
    12. 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)
  6. cni/pkg/nodeagent/cni-watcher.go

    1. if !sleep.UntilContext(s.ctx, time.Duration(msInterval)*time.Millisecond) {
    2. return nil, fmt.Errorf("aborted")
    3. }
    4. }
    5. if err != nil {
    6. return nil, fmt.Errorf("failed to get pod %s/%s: %v", namespace, name, err)
    7. }
    8.  
    9. // This shouldn't happen - we only trigger this when a pod is added to ambient.
    10. if ambientPod == nil {
    11. return nil, fmt.Errorf("pod %s/%s is unexpectedly not enrolled in ambient", namespace, name)
    12. }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  7. cmd/tier-handlers.go

    1. if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
    2. writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    3. return
    4. }
    5.  
    6. err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
    7. if err != nil {
    8. writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    9. return
    10. }
    11.  
    12. err = globalTierConfigMgr.Save(ctx, objAPI)
    13. if err != nil {
    14. 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)
  8. internal/s3select/sql/evaluate.go

    1. case []interface{}:
    2. dst := make([]Value, len(rval))
    3. for i := range rval {
    4. v, err := jsonToValue(rval[i])
    5. if err != nil {
    6. return nil, err
    7. }
    8. dst[i] = *v
    9. }
    10. return FromArray(dst), nil
    11. case simdjson.Object:
    12. o := rval
    13. elems, err := o.Parse(nil)
    14. if err != nil {
    15. return nil, err
    16. }
    17. bs, err := elems.MarshalJSON()
    18. if err != nil {
    19. return nil, err
    20. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. internal/s3select/simdj/reader.go

    1. func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    2. v, ok := <-r.decoded
    3. if !ok {
    4. if r.err != nil && *r.err != nil {
    5. return nil, errJSONParsingError(*r.err)
    6. }
    7. return nil, io.EOF
    8. }
    9. dstRec, ok := dst.(*Record)
    10. if !ok {
    11. dstRec = &Record{}
    12. }
    13. dstRec.object = v
    14. return dstRec, nil
    15. }
    16.  
    17. // Close - closes underlying reader.
    18. func (r *Reader) Close() error {
    19. // 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)
  10. internal/event/targetlist_test.go

    1. func (target ExampleTarget) Save(eventData Event) error {
    2. return target.send(eventData)
    3. }
    4.  
    5. // Store - Returns a nil store.
    6. func (target ExampleTarget) Store() TargetStore {
    7. return nil
    8. }
    9.  
    10. func (target ExampleTarget) send(eventData Event) error {
    11. b := make([]byte, 1)
    12. if _, err := rand.Read(b); err != nil {
    13. panic(err)
    14. }
    15.  
    16. time.Sleep(time.Duration(b[0]) * time.Millisecond)
    17.  
    18. 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)
Back to top