- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 378 for geturl (0.17 sec)
-
internal/store/batch.go
b.Lock() defer b.Unlock() if b.isFull() { return ErrBatchFull } if _, ok := b.items[key]; !ok { b.keys = append(b.keys, key) } b.items[key] = item return nil } // GetAll fetches the items and resets the batch // Returned items are not referenced by the batch func (b *Batch[K, T]) GetAll() (orderedKeys []K, orderedItems []T, err error) { b.Lock() defer b.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
cmd/tier-journal_gen.go
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
cmd/signature-v4-parser.go
if !isValidRegion(sRegion, region) { return ch, ErrAuthorizationHeaderMalformed } if credElements[2] != string(stype) { if stype == serviceSTS { return ch, ErrInvalidServiceSTS } return ch, ErrInvalidServiceS3 } cred.scope.service = credElements[2] if credElements[3] != "aws4_request" { return ch, ErrInvalidRequestVersion } cred.scope.request = credElements[3]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/object-api-input-checks.go
if len(object) == 0 { return ObjectNameInvalid{Bucket: bucket, Object: object} } if !IsValidObjectPrefix(object) { return ObjectNameInvalid{Bucket: bucket, Object: object} } if runtime.GOOS == globalWindowsOSName && strings.Contains(object, "\\") { // Objects cannot be contain \ in Windows and is listed as `Characters to Avoid`. return ObjectNameInvalid{Bucket: bucket, Object: object} } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.7K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
if len(args) != 0 { return nil, cobra.ShellCompDirectiveNoFileComp } client, err := ctx.CLIClient() if err != nil { return nil, cobra.ShellCompDirectiveNoFileComp } nsName, err := getNamespacesName(client, toComplete) if err != nil { return nil, cobra.ShellCompDirectiveNoFileComp } return nsName, cobra.ShellCompDirectiveNoFileComp }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/bucket/replication/rule.go
if err := r.validateID(); err != nil { return err } if err := r.validateStatus(); err != nil { return err } if err := r.validateFilter(); err != nil { return err } if err := r.DeleteMarkerReplication.Validate(); err != nil { return err } if err := r.DeleteReplication.Validate(); err != nil { return err } if err := r.SourceSelectionCriteria.Validate(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 23:22:20 GMT 2022 - 8.3K bytes - Viewed (0) -
internal/kms/single-key.go
if err != nil { return DEK{}, err } aead, err = cipher.NewGCM(block) if err != nil { return DEK{}, err } case algorithmChaCha20Poly1305: var sealingKey []byte sealingKey, err = chacha20.HChaCha20(kms.key, iv) if err != nil { return DEK{}, err } aead, err = chacha20poly1305.New(sealingKey) if err != nil { return DEK{}, err } default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/event/config.go
rule := filterRule{} if err := d.DecodeElement(&rule, &start); err != nil { return err } if rule.Name != "prefix" && rule.Name != "suffix" { return &ErrInvalidFilterName{rule.Name} } if err := ValidateFilterRuleValue(filter.Value); err != nil { return err } *filter = FilterRule(rule) return nil } // FilterRuleList - represents multiple <FilterRule>...</FilterRule>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/event/target/mqtt.go
return false, err } return target.isActive() } func (target *MQTTTarget) isActive() (bool, error) { if !target.client.IsConnectionOpen() { return false, store.ErrNotConnected } return true, nil } // send - sends an event to the mqtt. func (target *MQTTTarget) send(eventData event.Event) error { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
callbacks.go
} func (cs *callbacks) Create() *processor { return cs.processors["create"] } func (cs *callbacks) Query() *processor { return cs.processors["query"] } func (cs *callbacks) Update() *processor { return cs.processors["update"] } func (cs *callbacks) Delete() *processor { return cs.processors["delete"] } func (cs *callbacks) Row() *processor { return cs.processors["row"] }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 26 03:33:36 GMT 2024 - 8.6K bytes - Viewed (1)