- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewMatch (0.26 sec)
-
src/cmd/go/internal/search/search.go
// If len(Pkgs) == 0 && len(Errs) == 0, the pattern is well-formed but did not // match any packages. } // NewMatch returns a Match describing the given pattern, // without resolving its packages or errors. func NewMatch(pattern string) *Match { return &Match{pattern: pattern} } // Pattern returns the pattern to be matched. func (m *Match) Pattern() string { return m.pattern }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 31 20:33:05 UTC 2023 - 15.4K bytes - Viewed (0) -
src/cmd/go/internal/modload/search.go
// against the standard library (std and cmd) in GOROOT/src. func MatchInModule(ctx context.Context, pattern string, m module.Version, tags map[string]bool) *search.Match { match := search.NewMatch(pattern) if m == (module.Version{}) { matchPackages(ctx, match, tags, includeStd, nil) } LoadModFile(ctx) // Sets Target, needed by fetch and matchPackages. if !match.IsLiteral() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:15 UTC 2023 - 7.9K bytes - Viewed (0) -
src/cmd/go/internal/modload/query.go
} match = func(mod module.Version, roots []string, isLocal bool) *search.Match { m := search.NewMatch(pattern) matchPackages(ctx, m, imports.AnyTags(), omitStd, []module.Version{mod}) return m } } else { match = func(mod module.Version, roots []string, isLocal bool) *search.Match { m := search.NewMatch(pattern) prefix := mod.Path if MainModules.Contains(mod.Path) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 11 22:29:11 UTC 2023 - 44.7K bytes - Viewed (0) -
src/cmd/go/internal/modload/load.go
} patterns = search.CleanPatterns(patterns) matches = make([]*search.Match, 0, len(patterns)) allPatternIsRoot := false for _, pattern := range patterns { matches = append(matches, search.NewMatch(pattern)) if pattern == "all" { allPatternIsRoot = true } } updateMatches := func(rs *Requirements, ld *loader) { for _, m := range matches { switch { case m.IsLocal():
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 84K bytes - Viewed (0) -
internal/store/batch.go
func (b *Batch[K, T]) IsFull() bool { b.Lock() defer b.Unlock() return b.isFull() } func (b *Batch[K, T]) isFull() bool { return len(b.items) >= int(b.limit) } // NewBatch creates a new batch func NewBatch[K key, T any](limit uint32) *Batch[K, T] { return &Batch[K, T]{ keys: make([]K, 0, limit), items: make(map[K]T, limit), limit: limit, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Oct 07 15:07:38 UTC 2023 - 2.5K bytes - Viewed (0) -
internal/store/batch_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package store import ( "errors" "sync" "testing" ) func TestBatch(t *testing.T) { var limit uint32 = 100 batch := NewBatch[int, int](limit) for i := 0; i < int(limit); i++ { if err := batch.Add(i, i); err != nil { t.Fatalf("failed to add %v; %v", i, err) } if _, ok := batch.GetByKey(i); !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Oct 07 15:07:38 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
// Later, you can issue a watch with the REST apis list.RV and end up earlier than the storage cacher. // The general working model is that if you get a "resourceVersion too old" message, you re-list and rewatch. // For this test, we'll actually cycle, "list/watch/create/delete" until we get an RV from list that observes the create and not an error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
internal/event/target/kafka.go
args: args, store: queueStore, loggerOnce: loggerOnce, quitCh: make(chan struct{}), } if target.store != nil { if args.BatchSize > 1 { target.batch = store.NewBatch[string, *sarama.ProducerMessage](args.BatchSize) } store.StreamItems(target.store, target, target.quitCh, target.loggerOnce) } return target, nil } func isKafkaConnErr(err error) bool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0)