- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 284 for map (0.15 sec)
-
internal/config/notify/config.go
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), Kafka: make(map[string]target.KafkaArgs), Webhook: make(map[string]target.WebhookArgs), PostgreSQL: make(map[string]target.PostgreSQLArgs),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.8K bytes - Viewed (0) -
internal/bucket/object/lock/lock_test.go
}, expected: map[string]string{}, filterRetention: true, }, { metadata: map[string]string{ "x-amz-object-lock-legal-hold": "off", }, expected: map[string]string{}, filterLegalHold: true, }, { metadata: map[string]string{ "x-amz-object-lock-legal-hold": "on", }, expected: map[string]string{"x-amz-object-lock-legal-hold": "on"},
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 17.1K bytes - Viewed (0) -
cmd/data-usage-cache.go
nidx++ continue } h[nidx] += v[oidx] oidx++ nidx++ } } // toMap returns the map to a map[string]uint64. func (h *sizeHistogram) toMap() map[string]uint64 { res := make(map[string]uint64, dataUsageBucketLen) var splCount uint64 for i, count := range h { szInt := ObjectsHistogramIntervals[i] switch {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/bucket/bandwidth/monitor_test.go
type fields struct { activeBuckets map[BucketOptions]*bucketMeasurement endTime time.Time update2 uint64 endTime2 time.Time } start := time.Now() m0 := newBucketMeasurement(start) m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/config/config_test.go
keys []string expectedFields map[string]struct{} }{ // No keys present { input: "", keys: []string{"comment"}, expectedFields: map[string]struct{}{}, }, // No keys requested for tokenizing { input: `comment="Hi this is my comment ="`, keys: []string{}, expectedFields: map[string]struct{}{}, }, // Single key requested and present
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Aug 18 22:55:17 GMT 2022 - 4.2K bytes - Viewed (0) -
internal/config/config.go
} return s.String() } // Merge environment values with on disk KVS, environment values overrides // anything on the disk. func Merge(cfgKVS map[string]KVS, envname string, defaultKVS KVS) map[string]KVS { newCfgKVS := make(map[string]KVS) for _, e := range env.List(envname) { tgt := strings.TrimPrefix(e, envname+Default) if tgt == envname { tgt = Default } newCfgKVS[tgt] = defaultKVS
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/config/lambda/parse.go
return err } } } return nil } // GetLambdaWebhook - returns a map of registered notification 'webhook' targets func GetLambdaWebhook(webhookKVS map[string]config.KVS, transport *http.Transport) ( map[string]target.WebhookArgs, error, ) { webhookTargets := make(map[string]target.WebhookArgs) for k, kv := range config.Merge(webhookKVS, target.EnvWebhookEnable, DefaultWebhookKVS) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/object-api-options.go
argumentValue = tag valid = false return } } return } func parseObjectAttributes(h http.Header) (attributes map[string]struct{}) { attributes = make(map[string]struct{}) for _, v := range strings.Split(strings.TrimSpace(h.Get(xhttp.AmzObjectAttributes)), ",") { if v != "" { attributes[v] = struct{}{} } } return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/admin-handlers.go
} func getPoolsInfo(ctx context.Context, allDisks []madmin.Disk) (map[int]map[int]madmin.ErasureSetInfo, error) { objectAPI := newObjectLayerFn() if objectAPI == nil { return nil, errServerNotInitialized } z, ok := objectAPI.(*erasureServerPools) if !ok { return nil, errServerNotInitialized } poolsInfo := make(map[int]map[int]madmin.ErasureSetInfo) for _, d := range allDisks {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/bucket-replication-utils_gen.go
func (z *MRFReplicateEntries) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 2 // string "e" o = append(o, 0x82, 0xa1, 0x65) o = msgp.AppendMapHeader(o, uint32(len(z.Entries))) for za0001, za0002 := range z.Entries { o = msgp.AppendString(o, za0001) // map header, size 3 // string "b" o = append(o, 0x83, 0xa1, 0x62) o = msgp.AppendString(o, za0002.Bucket)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0)