- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 541 for conceal (0.2 sec)
-
internal/config/dns/etcd_dns.go
key = key + etcdPathSeparator + ip ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout) _, err = c.etcdClient.Put(ctx, key, string(bucketMsg)) cancel() if err != nil { ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout) c.etcdClient.Delete(ctx, key) cancel() return err } } } return nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 8.3K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *ElasticsearchTarget) isActive() (bool, error) { ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() err := target.checkAndInitClient(ctx) if err != nil { return false, err } return target.client.ping(ctx, target.args) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
ctx, cancel := context.WithCancel(ctx) target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, cancel: cancel, cancelCh: ctx.Done(), } return target, nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
Method concat = String.class.getMethod("concat", String.class); new EqualsTester() .addEqualityGroup( Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) .addEqualityGroup(Subscriber.create(bus, "foo", concat)) .testEquals(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
inputFuture.cancel(true); // argument is ignored assertThrows(CancellationException.class, () -> resultFuture.get()); } public void testFutureGetThrowsCancellationIfOutputCancelled() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); outputFuture.cancel(true); // argument is ignored
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints) } } // Test printing server common message. func TestPrintServerCommonMessage(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
inputFuture.cancel(true); // argument is ignored assertThrows(CancellationException.class, () -> resultFuture.get()); } public void testFutureGetThrowsCancellationIfOutputCancelled() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); outputFuture.cancel(true); // argument is ignored
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/math/MathTesting.java
ImmutableList.copyOf( Iterables.concat( Iterables.transform(POSITIVE_INTEGER_CANDIDATES, NEGATE_INT), ImmutableList.of(Integer.MIN_VALUE))); NONZERO_INTEGER_CANDIDATES = ImmutableList.copyOf( Iterables.concat(POSITIVE_INTEGER_CANDIDATES, NEGATIVE_INTEGER_CANDIDATES)); ALL_INTEGER_CANDIDATES = Iterables.concat(NONZERO_INTEGER_CANDIDATES, ImmutableList.of(0)); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 11.2K bytes - Viewed (0) -
.github/workflows/ci.yml
java: 21 root-pom: pom.xml runs-on: ${{ matrix.os }} env: ROOT_POM: ${{ matrix.root-pom }} steps: # Cancel any previous runs for the same branch that are still running. - name: 'Cancel previous runs' uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1 with: access_token: ${{ github.token }} - name: 'Check out repository'
Others - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 24 19:33:50 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/shared-lock.go
} func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) { ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-ctx1.Done(): case <-ctx2.Done(): // The lock acquirer decides to cancel, exit this goroutine case <-ctx.Done(): } cancel() }() return ctx, cancel } func (ld sharedLock) GetLock(ctx context.Context) (context.Context, context.CancelFunc) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Feb 13 09:26:38 GMT 2023 - 2.3K bytes - Viewed (0)