- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 766 for ONCE (0.14 sec)
-
internal/event/target/kafka.go
} // If batch is enabled, the event will be batched in memory // and will be committed once the batch is full. if target.batch != nil { return target.addToBatch(key) } eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade.go
var errs []error // If the coredns ConfigMap is missing, show a warning and assume that the // DNS addon was skipped during "kubeadm init", and that its redeployment on upgrade is not desired. // // TODO: remove this once "kubeadm upgrade apply" phases are supported: // https://github.com/kubernetes/kubeadm/issues/1318 var missingCoreDNSConfigMap bool if _, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get( context.TODO(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 11.3K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/plugins/DefaultPluginManagerTest.groovy
assert p.id == "foo" assert p.namespace == null assert p.name == "foo" } 0 * action._ } def "rules plugin is applied at most once"() { def action = Mock(Action) given: addPluginId("foo", rulesClass) manager.withPlugin("foo", action) when: manager.apply(rulesClass)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 16.1K bytes - Viewed (0) -
pkg/volume/volume.go
// self-determined directory path. The mount point and its // content should be owned by `fsUser` or 'fsGroup' so that it can be // accessed by the pod. This may be called more than once, so // implementations must be idempotent. // It could return following types of errors: // - TransientOperationFailure // - UncertainProgressError
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
} private: bool first_call_ = true; }; // After the graph pass is registered, it takes effect globally and can affect // other test cases. Define a static variable to switch it on and off. bool GraphErrorInjectionPass::enabled_ = false; // Test to ensure that a registered graph optimization pass is only executed
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 15 09:49:45 UTC 2024 - 23.5K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver_test.go
in: []string{"testIssuer", mockCertURL}, expectedJwtPubkey: test.JwtPubKey1, }, { in: []string{"testIssuer", mockCertURL}, // Send two same request, mock server is expected to hit only once because of the cache. expectedJwtPubkey: test.JwtPubKey1, }, } for _, c := range cases { pk, err := r.GetPublicKey(c.in[0], c.in[1], testRequestTimeout) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{Name: "test"}, // TODO: once we if the add pod bug, re-enable this and remove the patch below // Labels: map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient}, } client := kube.NewFakeClient(ns, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
hack/make-rules/test.sh
# support collecting coverage across multiple packages at once, so we must issue # separate 'go test' commands for each package and then combine at the end. # To speed things up considerably, we can at least use xargs -P to run multiple # 'go test' commands at once. # To properly parse the test results if generating a JUnit test report, we
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 22:40:10 UTC 2024 - 10.8K bytes - Viewed (0) -
internal/event/target/amqp.go
"encoding/json" "errors" "fmt" "net" "net/url" "os" "path/filepath" "sync" "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" "github.com/rabbitmq/amqp091-go" ) // AMQPArgs - AMQP target arguments. type AMQPArgs struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
// is to race thread creation with v.fn(want) // being executed. Via the once boolean we // also encourage one in 5 waiters to return // locked after participating in only one // question response sequence. This allows the // test to race thread destruction too. once := routines%5 == 4 go waiter(question, response, once) // Keep a count of how many goroutines are // going to participate in the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0)