Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for TargetType (0.52 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 Apr 21 19:28:08 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Nov 10 18:20:21 GMT 2022
    - 1.4K bytes
    - Viewed (0)
  3. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiExtensionsGenerator.kt

            append("inline fun ")
            if (typeParameters.isNotEmpty()) append("${typeParameters.joinInAngleBrackets { it.toTypeParameterString() }} ")
            append(targetType.sourceName)
            if (targetType.typeParameters.isNotEmpty()) append(targetType.typeParameters.toTypeArgumentsString(targetType))
            append(".")
            append("`$name`")
            append("(")
            append(parameters.toDeclarationString())
            append("): ")
    Plain Text
    - Registered: Wed Feb 28 11:36:09 GMT 2024
    - Last Modified: Wed Dec 20 21:41:53 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  4. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 02 00:13:57 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  6. 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)
  7. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4K bytes
    - Viewed (0)
  8. 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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  9. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  10. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/diagnostics/KtFirDiagnostics.kt

            override val diagnosticClass get() = CannotCheckForExternalInterface::class
            val targetType: KtType
        }
    
        interface UncheckedCastToExternalInterface : KtFirDiagnostic<KtElement> {
            override val diagnosticClass get() = UncheckedCastToExternalInterface::class
            val sourceType: KtType
            val targetType: KtType
        }
    
        interface ExternalInterfaceAsClassLiteral : KtFirDiagnostic<KtElement> {
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Wed Apr 24 09:49:26 GMT 2024
    - 171.1K bytes
    - Viewed (0)
Back to top