Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for TargetType (0.2 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]]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 10 18:20:21 GMT 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 10 18:20:21 GMT 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
    }
    
    var (
    
    	// systemTargets is the set of enabled loggers.
    	// Must be immutable at all times.
    	// Can be swapped to another while holding swapMu
    	systemTargets  = []Target{}
    	swapSystemMuRW sync.RWMutex
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  4. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  5. android/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>
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 8.3K bytes
    - Viewed (0)
  6. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4K bytes
    - Viewed (0)
Back to top