Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 175 for encloses (0.05 seconds)

  1. 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)
  2. internal/config/dns/etcd_dns.go

    	return json.Marshal(&SrvRecord{
    		Host:         ip,
    		Port:         json.Number(port),
    		TTL:          ttl,
    		CreationDate: t,
    	})
    }
    
    // Close closes the internal etcd client and cannot be used further
    func (c *CoreDNS) Close() error {
    	c.etcdClient.Close()
    	return nil
    }
    
    // List - Retrieves list of DNS entries for the domain.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 8K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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.EOF
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top