- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 175 for encloses (0.05 seconds)
-
internal/event/target/nsq.go
return nil } return eErr } if err := target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/config/dns/etcd_dns.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 8K bytes - Click Count (0) -
internal/s3select/json/preader.go
r.recordsRead++ dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.KVS = kvRecord dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *PReader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
docs/fr/docs/tutorial/query-params-str-validations.md
/// ## Déclarer des métadonnées supplémentaires On peut aussi ajouter plus d'informations sur le paramètre. Ces informations seront incluses dans le schéma `OpenAPI` généré et utilisées par la documentation interactive ou les outils externes utilisés. /// note Gardez en tête que les outils externes utilisés ne supportent pas forcément tous parfaitement OpenAPI.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Nov 09 16:39:20 GMT 2024 - 9.5K bytes - Click Count (0) -
src/archive/tar/strconv.go
return 0 } if inv == 0xff { return ^int64(x) } return int64(x) } // Normal case is base-8 (octal) format. return p.parseOctal(b) } // formatNumeric encodes x into b using base-8 (octal) encoding if possible. // Otherwise it will attempt to use base-256 (binary) encoding. func (f *formatter) formatNumeric(b []byte, x int64) { if fitsInOctal(len(b), x) { f.formatOctal(b, x)Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Sep 08 17:08:20 GMT 2025 - 9.1K bytes - Click Count (0) -
internal/event/target/mysql.go
if IsConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to MySQL database. func (target *MySQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil { // FIXME: log returned error. ignore time being. _ = target.updateStmt.Close()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt
return when { value > Int.MAX_VALUE -> Int.MAX_VALUE value < 0 -> 0 else -> value.toInt() } } catch (_: NumberFormatException) { return defaultValue } } /** Closes this, ignoring any checked exceptions. */ fun Closeable.closeQuietly() { try { close() } catch (rethrown: RuntimeException) { throw rethrown } catch (_: Exception) { } } /**Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon May 05 16:01:00 GMT 2025 - 10.1K bytes - Click Count (0) -
internal/s3select/csv/reader.go
if !ok { dstRec = &Record{} } dstRec.columnNames = r.columnNames dstRec.csvRecord = csvRecord dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOFCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 8.8K bytes - Click Count (0) -
internal/event/targetlist.go
type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock() for id := range targetIDSet { target, ok := list.targets[id] if ok {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/event/target/kafka.go
return nil, err } return &sarama.ProducerMessage{ Topic: target.args.Topic, Key: sarama.StringEncoder(key), Value: sarama.ByteEncoder(data), }, nil } // Close - closes underneath kafka connection. func (target *KafkaTarget) Close() error { close(target.quitCh) if target.batch != nil { target.batch.Close() } if target.producer != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0)