- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,079 for Make (0.17 sec)
-
src/Make.dist
Russ Cox <******@****.***> 1328732807 -0500
Plain Text - Registered: Tue Apr 16 11:13:10 GMT 2024 - Last Modified: Wed Feb 08 20:26:47 GMT 2012 - 553 bytes - Viewed (0) -
internal/event/rules_test.go
rulesCase1 := make(Rules) rules2Case1 := make(Rules) expectedResultCase1 := make(Rules) rulesCase2 := make(Rules) rules2Case2 := make(Rules) rules2Case2.Add(NewPattern("*", "*"), TargetID{"1", "webhook"}) expectedResultCase2 := make(Rules) rulesCase3 := make(Rules) rulesCase3.Add(NewPattern("*", "*"), TargetID{"1", "webhook"}) rules2Case3 := make(Rules) expectedResultCase3 := make(Rules)
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.8K bytes - Viewed (0) -
internal/config/notify/config.go
func NewConfig() Config { // Make sure to initialize notification targets cfg := Config{ NSQ: make(map[string]target.NSQArgs), AMQP: make(map[string]target.AMQPArgs), MQTT: make(map[string]target.MQTTArgs), NATS: make(map[string]target.NATSArgs), Redis: make(map[string]target.RedisArgs), MySQL: make(map[string]target.MySQLArgs),
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.8K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
t.Fatalf("want %d subscribers, got %d", want, got) } } func TestSubscribeExceedingLimit(t *testing.T) { ps := New[Maskable, Maskable](2) ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) }
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/notification.go
} // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats { errs := make([]error, len(sys.allPeerClients)) lastDayStats := make([]DailyAllTierStats, len(sys.allPeerClients)) var wg sync.WaitGroup for index := range sys.peerClients { if sys.peerClients[index] == nil { continue } wg.Add(1)
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_test.go
m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details) test1Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: 0} test1Want2 := make(map[BucketOptions]Details) test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 4.3K bytes - Viewed (0) -
CONTRIBUTING.md
Getting Started --------------- + Make sure you have a [JIRA account](https://issues.apache.org/jira/). + Make sure you have a [GitHub account](https://github.com/signup/free). + If you're planning to implement a new feature, it makes sense to discuss your changes on the [dev list](https://maven.apache.org/mailing-lists.html) first. This way you can make sure you're not wasting your time on something that isn't
Plain Text - Registered: Sun Apr 14 03:35:08 GMT 2024 - Last Modified: Sun Oct 10 09:48:27 GMT 2021 - 4.7K bytes - Viewed (0) -
src/bytes/compare_test.go
func TestCompareBytes(t *testing.T) { lengths := make([]int, 0) // lengths to test in ascending order for i := 0; i <= 128; i++ { lengths = append(lengths, i) } lengths = append(lengths, 256, 512, 1024, 1333, 4095, 4096, 4097) if !testing.Short() { lengths = append(lengths, 65535, 65536, 65537, 99999) } n := lengths[len(lengths)-1] a := make([]byte, n+1) b := make([]byte, n+1) for _, len := range lengths {
Go - Registered: Tue Apr 16 11:13:10 GMT 2024 - Last Modified: Thu Jul 13 23:11:42 GMT 2023 - 6.8K bytes - Viewed (0) -
cmd/peer-s3-client.go
return nil }, idx) } errs := g.Wait() // The list of buckets in a map to avoid duplication resultMap := make(map[string]BucketInfo) for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ { perPoolErrs := make([]error, 0, len(sys.peerClients)) for i, client := range sys.peerClients { if slices.Contains(client.GetPools(), poolIdx) {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/data-usage-cache.go
e.ObjVersions.add(summary.versions) if e.ReplicationStats == nil { e.ReplicationStats = &replicationAllStats{ Targets: make(map[string]replicationStats), } } else if e.ReplicationStats.Targets == nil { e.ReplicationStats.Targets = make(map[string]replicationStats) } e.ReplicationStats.ReplicaSize += uint64(summary.replicaSize) e.ReplicationStats.ReplicaCount += uint64(summary.replicaCount)
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 41.3K bytes - Viewed (1)