Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for TargetType (0.06 sec)

  1. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * DEFAULT_VALUE} if this method call takes over 50 ms, you can use this code:
       *
       * <pre>
       *   TimeLimiter limiter = . . .;
       *   TargetType proxy = limiter.newProxy(
       *       target, TargetType.class, 50, TimeUnit.MILLISECONDS);
       *   try {
       *     return proxy.someMethod();
       *   } catch (UncheckedTimeoutException e) {
       *     return DEFAULT_VALUE;
       *   }
       * </pre>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    		logCh:   make(chan interface{}, config.QueueSize),
    		kconfig: config,
    		status:  statusOffline,
    	}
    	return target
    }
    
    // Type - returns type of the target
    func (h *Target) Type() types.TargetType {
    	return types.TargetKafka
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. internal/logger/target/http/http.go

    }
    
    // Name returns the name of the target
    func (h *Target) Name() string {
    	return "minio-http-" + h.config.Name
    }
    
    // Type - returns type of the target
    func (h *Target) Type() types.TargetType {
    	return types.TargetHTTP
    }
    
    // Endpoint returns the backend endpoint
    func (h *Target) Endpoint() string {
    	return h.config.Endpoint.String()
    }
    
    func (h *Target) String() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top