- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewMatch (0.16 sec)
-
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/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)