Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 1,087 for contextos (0.15 sec)

  1. cmd/erasure-healing_test.go

    			}
    		})
    	}
    }
    
    // Tests both object and bucket healing.
    func TestHealing(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(context.Background())
    
    	// initialize the server and obtain the credentials and root.
    	// credentials are necessary to sign the HTTP request.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. internal/http/dial_others.go

    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext configures a custom dialer for internode communications
    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. internal/event/target/elasticsearch.go

    type esClient interface {
    	isAtleastV7() bool
    	createIndex(ElasticsearchArgs) error
    	ping(context.Context, ElasticsearchArgs) (bool, error)
    	stop()
    	entryExists(context.Context, string, string) (bool, error)
    	removeEntry(context.Context, string, string) error
    	updateEntry(context.Context, string, string, event.Event) error
    	addEntry(context.Context, string, event.Event) error
    }
    
    // ElasticsearchArgs - Elasticsearch target arguments.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. tensorflow/c/eager/parallel_device/parallel_device_test.cc

                                  status.get());
      std::unique_ptr<TFE_Context, decltype(&TFE_DeleteContext)> context(
          TFE_NewContext(opts.get(), status.get()), TFE_DeleteContext);
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
      BasicTestsForTwoDevices(context.get(),
                              "/job:localhost/replica:0/task:0/device:CPU:0",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  5. cmd/erasure-metadata-utils_test.go

    			},
    			nil, nil,
    		},
    		// Checks if wrapped context cancellation errors are grouped as one.
    		{canceledErrs, nil, context.Canceled},
    	}
    	// Validates list of all the testcases for returning valid errors.
    	for i, testCase := range testCases {
    		gotErr := reduceReadQuorumErrs(context.Background(), testCase.errs, testCase.ignoredErrs, 5)
    		if gotErr != testCase.err {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. cmd/batch-rotate.go

    type BatchJobKeyRotateEncryption struct {
    	Type       BatchKeyRotationType `yaml:"type" json:"type"`
    	Key        string               `yaml:"key" json:"key"`
    	Context    string               `yaml:"context" json:"context"`
    	kmsContext kms.Context          `msg:"-"`
    }
    
    // Validate validates input key rotation encryption options.
    func (e BatchJobKeyRotateEncryption) Validate() error {
    	if e.Type != sses3 && e.Type != ssekms {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. api/go1.9.txt

    pkg runtime/pprof, func Do(context.Context, LabelSet, func(context.Context))
    pkg runtime/pprof, func ForLabels(context.Context, func(string, string) bool)
    pkg runtime/pprof, func Label(context.Context, string) (string, bool)
    pkg runtime/pprof, func Labels(...string) LabelSet
    pkg runtime/pprof, func SetGoroutineLabels(context.Context)
    pkg runtime/pprof, func WithLabels(context.Context, LabelSet) context.Context
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 04 20:20:20 UTC 2021
    - 10.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/query/FuzzyQueryCommand.java

                context.addFieldLog(field, text);
                context.addHighlightedQuery(text);
                return buildDefaultQueryBuilder(fessConfig, context,
                        (f, b) -> QueryBuilders.fuzzyQuery(f, text).fuzziness(Fuzziness.fromEdits(fuzzyQuery.getMaxEdits())).boost(b * boost)
                                .maxExpansions(fessConfig.getQueryFuzzyExpansionsAsInteger())
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java

            if (Constants.DEFAULT_FIELD.equals(field)) {
                context.addFieldLog(field, text);
                stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
                return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> buildMatchPhraseQuery(f, text).boost(b * boost));
            }
    
            if (isSearchField(field)) {
                context.addFieldLog(field, text);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    	t := time.Now()
    	return func() {
    		doneAt := time.Now()
    		d.Sleep(ctx, doneAt.Sub(t))
    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top