Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for TargetType (0.11 sec)

  1. internal/logger/target/types/targettype_string.go

    func (i TargetType) String() string {
    	i -= 1
    	if i >= TargetType(len(_TargetType_index)-1) {
    		return "TargetType(" + strconv.FormatInt(int64(i+1), 10) + ")"
    	}
    	return _TargetType_name[_TargetType_index[i]:_TargetType_index[i+1]]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 703 bytes
    - Viewed (0)
  2. internal/logger/target/types/types.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package types
    
    // TargetType indicates type of the target e.g. console, http, kafka
    type TargetType uint8
    
    //go:generate stringer -type=TargetType -trimprefix=Target $GOFILE
    
    // Constants for target types
    const (
    	_ TargetType = iota
    	TargetConsole
    	TargetHTTP
    	TargetKafka
    )
    
    // TargetStats contains statistics for a target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry interface{}) error
    	Type() types.TargetType
    }
    
    type targetsList struct {
    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    	return &targetsList{}
    }
    
    func (tl *targetsList) get() []Target {
    	tl.mu.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. 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)
  5. internal/logger/target/testlogger/testlogger.go

    					continue
    				}
    				msg += fmt.Sprintf("\n%s", m)
    			}
    			logf("%s", msg)
    		}
    	default:
    		logf("%+v (%T)", v, v)
    	}
    	return nil
    }
    
    func (t *testLogger) Type() types.TargetType {
    	return types.TargetConsole
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. cmd/consolelogger.go

    	sys.RUnlock()
    
    	return
    }
    
    // Cancel - cancels the target
    func (sys *HTTPConsoleLoggerSys) Cancel() {
    }
    
    // Type - returns type of the target
    func (sys *HTTPConsoleLoggerSys) Type() types.TargetType {
    	return types.TargetConsole
    }
    
    // Send log message 'e' to console and publish to console
    // log pubsub system
    func (sys *HTTPConsoleLoggerSys) Send(ctx context.Context, entry interface{}) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. 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)
  8. 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