- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,139 for batches (0.19 sec)
-
pkg/config/mesh/kubemesh/watcher.go
}) go c.Run(stop) // Ensure the ConfigMap is initially loaded if present. if !client.WaitForCacheSync("configmap watcher", stop, c.HasSynced) { log.Error("failed to wait for cache sync") } return w } func AddUserMeshConfig(client kube.Client, watcher mesh.Watcher, namespace, key, userMeshConfig string, stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/testFixtures/kotlin/org/gradle/kotlin/dsl/fixtures/matchers.kt
package org.gradle.kotlin.dsl.fixtures import org.hamcrest.CoreMatchers.containsString import org.hamcrest.Matcher fun containsMultiLineString(string: String): Matcher<String> =
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 221 bytes - Viewed (0) -
pkg/test/framework/resource/matcher.go
"regexp" "strconv" "strings" ) // testFilter is a regex matcher on a test. It is split by / following go subtest format type testFilter []*regexp.Regexp type Matcher struct { filters []testFilter } // NewMatcher reimplements the logic of Go's -test.run. The code is mostly directly copied from Go's source. func NewMatcher(regexs []string) (*Matcher, error) { filters := []testFilter{} for _, regex := range regexs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 12 23:30:37 UTC 2021 - 3.2K bytes - Viewed (0) -
operator/pkg/patch/patch.go
} oys := string(oy) for _, overlay := range overlays { if overlayMatches(overlay, obj, defaultNamespace) { matches[overlay] = append(matches[overlay], obj) var errs2 util.Errors oys, errs2 = applyPatches(obj, overlay.Patches) errs = util.AppendErrs(errs, errs2) } } if _, err := ret.WriteString(oys + helm.YAMLSeparator); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
func NewFixedWatcher(mesh *meshconfig.MeshConfig) Watcher { iw := internalWatcher{} iw.MeshConfig.Store(mesh) return &iw } // NewFileWatcher creates a new Watcher for changes to the given mesh config file. Returns an error // if the given file does not exist or failed during parsing. func NewFileWatcher(fileWatcher filewatcher.FileWatcher, filename string, multiWatch bool) (Watcher, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/cel/matcher.go
Rita Zhang <******@****.***> 1709268932 -0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/cluster_patch.go
}) // In case the patches cause panic, use the clusters generated before to reduce the influence. out = c if efw == nil { return } for _, cp := range efw.Patches[networking.EnvoyFilter_CLUSTER] { applied := false if cp.Operation != networking.EnvoyFilter_Patch_MERGE { IncrementEnvoyFilterMetric(cp.Key(), Cluster, applied) continue } if commonConditionMatch(pctx, cp) && clusterMatch(c, cp, hosts) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 6.8K bytes - Viewed (0) -
pilot/pkg/model/envoyfilter_test.go
} if patches := cfilter.Patches[networking.EnvoyFilter_INVALID]; len(patches) != 1 { t.Fatalf("unexpected patches of %v: %v", networking.EnvoyFilter_INVALID, cfilter.Patches) } if patches := cfilter.Patches[networking.EnvoyFilter_HTTP_ROUTE]; len(patches) != 1 { // check num of invalid http route patches t.Fatalf("unexpected patches of %v: %v", networking.EnvoyFilter_HTTP_ROUTE, cfilter.Patches) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 27 04:20:28 UTC 2023 - 7.4K bytes - Viewed (0) -
src/internal/trace/batch.go
if err != nil { return batch{}, 0, err } exp = event.Experiment(e) } // Read the batch header: gen (generation), thread (M) ID, base timestamp // for the batch. gen, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch gen: %w", err) } m, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch M ID: %w", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/config/batch/batch.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package batch import ( "sync" "time" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v3/env" ) // Batch job environment variables const ( ReplicationWorkersWait = "replication_workers_wait" KeyRotationWorkersWait = "keyrotation_workers_wait"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0)