- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for sale (0.13 sec)
-
internal/logger/logrotate.go
// may fall on the same timestamp. // Eg. // 2020-03-28_15-00-945-<random-hash>.log // When FileNameFunc is not specified, DefaultFilenameFunc will be used. FileNameFunc func() string // Compress specify if you want the logs to be compressed after rotation. Compress bool } // Writer is a concurrency-safe writer with file rotation. type Writer struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/config/crypto.go
"github.com/secure-io/sio-go" "github.com/secure-io/sio-go/sioutil" ) // EncryptBytes encrypts the plaintext with a key managed by KMS. // The context is bound to the returned ciphertext. // // The same context must be provided when decrypting the // ciphertext. func EncryptBytes(k kms.KMS, plaintext []byte, context kms.Context) ([]byte, error) { ciphertext, err := Encrypt(k, bytes.NewReader(plaintext), context) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
clusterDump, err := w.GetClusterConfigDump() if err != nil { return nil, err } dac := clusterDump.GetDynamicActiveClusters() // Allow sorting to work even if we don't have the exact same type for i := range dac { dac[i].Cluster.TypeUrl = v3.ClusterType } sort.Slice(dac, func(i, j int) bool { cluster := &cluster.Cluster{} err = dac[i].Cluster.UnmarshalTo(cluster) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
grpc.WithTransportCredentials(credentials.NewTLS( &tls.Config{ // Always skip verifying, because without it we always get "certificate signed by unknown authority". // We don't set the XDSSAN for the same reason. InsecureSkipVerify: true, })), grpc.WithPerRPCCredentials(k8sCreds), }, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/auth/credentials_test.go
if err != nil { t.Fatalf("Failed to get a new credential: %v", err) } testCases := []struct { cred Credentials ccred Credentials expectedResult bool }{ // Same Credentialss. {cred, cred, true}, // Empty credentials to compare. {cred, Credentials{}, false}, // Empty credentials. {Credentials{}, cred, false}, // Two different credentialss
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/kms/kms.go
// // The KMS may use a default key if the key ID is empty. // GenerateKey returns an error if the referenced key does // not exist. // // The context is associated and tied to the generated DEK. // The same context must be provided when the generated key // should be decrypted. Therefore, it is the callers // responsibility to remember the corresponding context for // a particular DEK. The context may be nil.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
tests/soft_delete_test.go
"errors" "regexp" "testing" "github.com/jinzhu/now" "gorm.io/gorm" . "gorm.io/gorm/utils/tests" ) func TestSoftDelete(t *testing.T) { user := *GetUser("SoftDelete", Config{}) DB.Save(&user) var count int64 var age uint if DB.Model(&User{}).Where("name = ?", user.Name).Count(&count).Error != nil || count != 1 { t.Errorf("Count soft deleted record, expects: %v, got: %v", 1, count) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 5.7K bytes - Viewed (0) -
internal/bucket/replication/rule.go
errInvalidDeleteMarkerReplicationStatus = Errorf("Delete marker replication status is invalid") errDestinationSourceIdentical = Errorf("Destination bucket cannot be the same as the source bucket.") errDeleteReplicationMissing = Errorf("Delete replication must be specified") errInvalidDeleteReplicationStatus = Errorf("Delete replication is either enable|disable")
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) -
docs/debugging/s3-verify/main.go
} // If source doesn't have objects anymore, comparison becomes obvious if srcEOF { fmt.Printf("only in target: %s\n", tgtCtnt.Key) tgtCtnt, tgtOk = <-tgtCh continue } // The same for target if tgtEOF { fmt.Printf("only in source: %s\n", srcCtnt.Key) srcCtnt, srcOk = nextObject(srcCh) continue } if srcCtnt.Key < tgtCtnt.Key {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
maxStaleRetries := 10 msInterval := 10 retries := 0 var ambientPod *corev1.Pod var err error log.Debugf("Checking pod: %s in ns: %s is enabled for ambient", addCmd.PodName, addCmd.PodNamespace) // The plugin already consulted the k8s API - but on this end handler caches may be stale, so retry a few times if we get no pod.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0)