- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for still (0.19 sec)
-
internal/store/batch_test.go
} if len(keys) != int(limit) { t.Fatalf("Expected length of the batch keys to be %v but got %v", limit, len(items)) } batchLen = batch.Len() if batchLen != 0 { t.Fatalf("expected batch to be empty but still left with %d items", batchLen) } // Add duplicate entries for i := 0; i < 10; i++ { if err := batch.Add(99, 99); err != nil { t.Fatalf("failed to add duplicate item %v to batch after Get; %v", i, err) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 3.8K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
// The auth package provides support for checking the authentication and authorization policy applied // in the mesh. It aims to increase the debuggability and observability of auth policies. // Note: this is still under active development and is not ready for real use. package authz import ( "fmt" "io" envoy_admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
tests/named_polymorphic_test.go
t.Errorf("Hamster's preferred toy should be cleared with Clear") } if DB.Model(&hamster2).Association("OtherToy").Count() != 1 { t.Errorf("Hamster's other toy should be still available") } DB.Model(&hamster).Association("OtherToy").Clear() if DB.Model(&hamster).Association("OtherToy").Count() != 0 { t.Errorf("Hamster's other toy should be cleared with Clear") }
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Wed Jul 08 09:59:40 GMT 2020 - 4.2K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
kubeClient, client, err := KubernetesClients(cliClient, l) if err != nil { l.LogAndFatal(err) } // If the user is performing purge but also specified a revision, we should warn // that the purge will still remove all resources if orArgs.purge && orArgs.revision != "" { orArgs.revision = "" l.LogAndPrint("Purge remove will remove all Istio operator controller, ignoring the specified revision\n") } var installed bool
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
} taggedNamespaces, err := GetNamespacesWithTag(ctx, kubeClient, tagName) if err != nil { return fmt.Errorf("failed to retrieve namespaces dependent on tag %q", tagName) } // warn user if deleting a tag that still has namespaces pointed to it if len(taggedNamespaces) > 0 && !skipConfirmation { if !util.Confirm(buildDeleteTagConfirmation(tagName, taggedNamespaces), w) { fmt.Fprintf(w, "Aborting operation.\n") return nil }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
} }(index, c) } // Wait until we have either // // a) received all refresh responses // b) received too many refreshed for quorum to be still possible // c) timed out // lockNotFound, lockRefreshed := 0, 0 done := false for i := 0; i < len(restClnts); i++ { select { case refreshResult := <-ch: if refreshResult.offline {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err) } return envoyConfig, nil } // AuthZ groups commands used for inspecting and interacting the authorization policy. // Note: this is still under active development and is not ready for real use. func AuthZ(ctx cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "authz", Short: "Inspect Istio AuthorizationPolicy", }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
cmd/signature-v4.go
if errMetaCode != ErrNone { return errMetaCode } // If the host which signed the request is slightly ahead in time (by less than globalMaxSkewTime) the // request should still be allowed. if pSignValues.Date.After(UTCNow().Add(globalMaxSkewTime)) { return ErrRequestNotReadyYet } if UTCNow().Sub(pSignValues.Date) > pSignValues.Expires { return ErrExpiredPresignRequest }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/postpolicyform.go
// (http://docs.aws.amazon.com/AmazonS3/latest/API/sigv4-HTTPPOSTConstructPolicy.html) func checkPostPolicy(formValues http.Header, postPolicyForm PostPolicyForm) error { // Check if policy document expiry date is still not reached if !postPolicyForm.Expiration.After(UTCNow()) { return fmt.Errorf("Invalid according to Policy: Policy expired") }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0)