- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for CH (0.14 sec)
-
cmd/metrics.go
func (c *minioCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioCollector) Collect(ch chan<- prometheus.Metric) { // Expose MinIO's version information minioVersionInfo.WithLabelValues(Version, CommitID).Set(1.0) storageMetricsPrometheus(ch) nodeHealthMetricsPrometheus(ch) bucketUsageMetricsPrometheus(ch)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/event/target/amqp.go
defer target.connMutex.Unlock() if target.conn != nil { ch, err = target.conn.Channel() if err == nil { if target.args.PublisherConfirms { confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1)) if err := ch.Confirm(false); err != nil { ch.Close() return nil, nil, err } return ch, confirms, nil } return ch, nil, nil } if !isAMQPClosedErr(err) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
* header field name. * * @since 30.0 */ public static final String SEC_CH_UA = "Sec-CH-UA"; /** * The HTTP <a href="https://wicg.github.io/ua-client-hints/#sec-ch-ua-arch">{@code * Sec-CH-UA-Arch}</a> header field name. * * @since 30.0 */ public static final String SEC_CH_UA_ARCH = "Sec-CH-UA-Arch"; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:08:08 GMT 2024 - 34.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/service.go
// Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil { if ch, ok := val.(chan struct{}); ok && ch != nil { // Close previous non-nil channel. xioutil.SafeClose(ch) } } globalServiceFreezeCnt = 0 // Don't risk going negative. } globalServiceFreezeMu.Unlock()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/dsync/drwmutex.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/signature-v4-parser.go
if !isValidRegion(sRegion, region) { return ch, ErrAuthorizationHeaderMalformed } if credElements[2] != string(stype) { if stype == serviceSTS { return ch, ErrInvalidServiceSTS } return ch, ErrInvalidServiceS3 } cred.scope.service = credElements[2] if credElements[3] != "aws4_request" { return ch, ErrInvalidRequestVersion } cred.scope.request = credElements[3]
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/grid/grid.go
// The context both allows returning errors on writes and to ensure that // this isn't abandoned if the channel is no longer being read from. func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer { return &writerWrapper{ch: ch, ctx: ctx} } // bytesOrLength returns small (<=100b) byte slices as string, otherwise length. func bytesOrLength(b []byte) string { if len(b) > 100 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/peer-rest-client.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/text/Tokenizer.java
} /** * 単独で存在する文字として設定します。 * * @param ctype2 * 文字のタイプの配列 * @param ch * 文字コード */ protected static void ordinaryChar(final byte[] ctype2, final int ch) { if (ch >= 0 && ch < ctype2.length) { ctype2[ch] = 0; } } /** * 文字列の値を返します。 * * @return 文字列の値 */
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8.6K bytes - Viewed (0)