Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1081 - 1090 of 2,444 for ErrorS (0.04 sec)

  1. internal/event/target/nats_contrib_test.go

    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject: "test",
    	}
    	con, err := clientConfig.connectNats()
    	if err != nil {
    		t.Errorf("Could not connect to nats: %v", err)
    	}
    	defer con.Close()
    }
    
    func TestNatsConnUserPass(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14223
    	opts.Username = "testminio"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. cni/pkg/iptables/nldeps.go

    type NetlinkDependencies interface {
    	AddInpodMarkIPRule(cfg *Config) error
    	DelInpodMarkIPRule(cfg *Config) error
    	AddLoopbackRoutes(cfg *Config) error
    	DelLoopbackRoutes(cfg *Config) error
    }
    
    func RealNlDeps() NetlinkDependencies {
    	return &realDeps{}
    }
    
    type realDeps struct{}
    
    func (r *realDeps) AddInpodMarkIPRule(cfg *Config) error {
    	return AddInpodMarkIPRule(cfg)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. internal/kms/conn.go

    	// for multiple endpoints.
    	Version(context.Context) (string, error)
    
    	// APIs returns a list of APIs supported by the KMS server.
    	//
    	// TODO(aead): remove this API call. It's hardly useful.
    	APIs(context.Context) ([]madmin.KMSAPI, error)
    
    	// Stat returns the current KMS status.
    	Status(context.Context) (map[string]madmin.ItemState, error)
    
    	// CreateKey creates a new key at the KMS with the given key ID.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. internal/pubsub/pubsub_test.go

    	ch2 := make(chan Maskable, 1)
    	doneCh := make(chan struct{})
    	defer close(doneCh)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java

      @Override
      public void run() {
        T result = null;
        Throwable error = null;
        if (isDone()) {
          return;
        }
        try {
          result = runInterruptibly();
        } catch (Throwable t) {
          error = t;
        }
        if (error == null) {
          // The cast is safe because of the `run` and `error` checks.
          afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result));
        } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 08 20:30:27 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  6. cmd/format-erasure_test.go

    				},
    			},
    			false,
    		},
    	}
    
    	// Valid all test cases.
    	for i, testCase := range testCases {
    		if err := checkFormatErasureValue(testCase.format, nil); err != nil && testCase.success {
    			t.Errorf("Test %d: Expected failure %s", i+1, err)
    		}
    	}
    }
    
    // Tests getFormatErasureInQuorum()
    func TestGetFormatErasureInQuorumCheck(t *testing.T) {
    	setCount := 2
    	setDriveCount := 16
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. internal/logger/console.go

    )
    
    func (f fatalMsg) pretty(msg string, args ...interface{}) {
    	// Build the passed error message
    	errMsg := fmt.Sprintf(msg, args...)
    
    	tagPrinted := false
    
    	// Print the error message: the following code takes care
    	// of splitting error text and always pretty printing the
    	// red banner along with the error message. Since the error
    	// message itself contains some colored text, we needed
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  8. cmd/object-api-input-checks.go

    )
    
    // Checks on CopyObject arguments, bucket and object.
    func checkCopyObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on GetObject arguments, bucket and object.
    func checkGetObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on DeleteObject arguments, bucket and object.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. api/go1.23.txt

    pkg crypto/x509, func ParseOID(string) (OID, error) #66249
    pkg crypto/x509, method (*OID) UnmarshalBinary([]uint8) error #66249
    pkg crypto/x509, method (*OID) UnmarshalText([]uint8) error #66249
    pkg crypto/x509, method (OID) MarshalBinary() ([]uint8, error) #66249
    pkg crypto/x509, method (OID) MarshalText() ([]uint8, error) #66249
    pkg debug/elf, const PT_OPENBSD_NOBTCFI = 1705237480 #66054
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 25 17:08:08 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/logging/Slf4jStdoutLogger.java

            return false;
        }
    
        public void error(String format, Object arg) {}
    
        public void error(String format, Object arg1, Object arg2) {}
    
        public void error(String format, Object... arguments) {}
    
        public boolean isErrorEnabled(Marker marker) {
            return false;
        }
    
        public void error(Marker marker, String msg) {}
    
        public void error(Marker marker, String format, Object arg) {}
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top