- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 152 for Hatch (0.31 sec)
-
cmd/object-api-listobjects_test.go
Prefixes: []string{"dir/day_id=2017-10-10/"}, }, // ListObjectsResult-37 list with prefix match 2 levels deep 37: { IsTruncated: false, Objects: []ObjectInfo{ {Name: "foo/201910/1112"}, {Name: "foo/201910/1122"}, }, }, // ListObjectsResult-38 list with prefix match 1 level deep 38: { IsTruncated: false, Objects: []ObjectInfo{ {Name: "foo/201910/1112"},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/format-erasure.go
if len(reference.Erasure.Sets) != len(format.Erasure.Sets) { return fmt.Errorf("Expected number of sets %d, got %d", len(reference.Erasure.Sets), len(format.Erasure.Sets)) } // Make sure that the sets match. for i := range reference.Erasure.Sets { if len(reference.Erasure.Sets[i]) != len(format.Erasure.Sets[i]) { return fmt.Errorf("Each set should be of same size, expected %d got %d",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/api-response.go
u.Path = path.Join(SlashSeparator, object) break } } return u.String() } // generates ListBucketsResponse from array of BucketInfo which can be // serialized to match XML and JSON API spec output. func generateListBucketsResponse(buckets []BucketInfo) ListBucketsResponse { listbuckets := make([]Bucket, 0, len(buckets)) data := ListBucketsResponse{} owner := Owner{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
internal/grid/muxclient.go
if !m.closed { gridLogIf(m.ctx, m.sendLocked(message{Op: OpUnblockSrvMux, MuxID: m.MuxID})) } m.respMu.Unlock() case <-m.ctx.Done(): // Client canceled. Don't block. // Next loop will catch it. } case <-pingTimer: if time.Since(time.Unix(atomic.LoadInt64(&m.LastPong), 0)) > clientPingInterval*2 { m.addErrorNonBlockingClose(respHandler, ErrDisconnected) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/handler-utils.go
return matches[1] } return "unknown" } func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) { return errorResponseHandler } // If none of the http routes match respond with appropriate errors func errorResponseHandler(w http.ResponseWriter, r *http.Request) { if r.Method == http.MethodOptions { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
cmd/streaming-signature-v4.go
signingKey := getSigningKey(cred.SecretKey, signV4Values.Credential.scope.date, region, serviceS3) // Calculate signature. newSignature := getSignature(signingKey, stringToSign) // Verify if signature match. if !compareSignatureV4(newSignature, signV4Values.Signature) { return cred, "", "", time.Time{}, ErrSignatureDoesNotMatch } // Return calculated signature. return cred, newSignature, region, date, ErrNone
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/iam-store.go
} // iamStorageWatcher is implemented by `IAMStorageAPI` implementers that // additionally support watching storage for changes. type iamStorageWatcher interface { watch(ctx context.Context, keyPath string) <-chan iamWatchEvent } // Set default canned policies only if not already overridden by users. func setDefaultCannedPolicies(policies map[string]PolicyDoc) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/common-main.go
if err != nil { logger.Fatal(err, "Failed to load KES client certificate") } certificate.Watch(context.Background(), 15*time.Minute, syscall.SIGHUP) certificate.Notify(reloadCertEvents) kmsConf = kms.Config{ Endpoints: endpoints, DefaultKeyID: env.Get(kms.EnvKESKeyName, ""),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
istioctl/pkg/writer/compare/comparator_test.go
} expected := []string{"Clusters Match", "Listeners Match", "Routes Match"} for _, exp := range expected { if !bytes.Contains(outputBuffer.Bytes(), []byte(exp)) { t.Errorf("Expected %s, but it was not found", exp) } } } // TestComparatorMismatchedConfigs tests the scenario where Istiod and Envoy configurations do not match func TestComparatorMismatchedConfigs(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/event/target/kafka.go
if err := target.init(); err != nil { return err } // If batch is enabled, the event will be batched in memory // and will be committed once the batch is full. if target.batch != nil { return target.addToBatch(key) } eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0)