- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 147 for silent (2.9 sec)
-
cmd/admin-handlers-config-kv.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } globalNotificationSys.SignalConfigReload(subSys) // Tell the client that dynamic config was applied. w.Header().Set(madmin.ConfigAppliedHeader, madmin.ConfigAppliedTrue) } type badConfigErr struct { Err error } // Error - return the error message
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
} return 0, cr.err } defer func() { if err != nil && err != io.EOF { if cr.debug { fmt.Println("Read err:", err) } } }() // First, if there is any unread data, copy it to the client // provided buffer. if cr.offset > 0 { n = copy(buf, cr.buffer[cr.offset:]) if n == len(buf) { cr.offset += n return n, nil } cr.offset = 0 buf = buf[n:] }
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/api-response.go
} var toRemove []string for k := range cleanMinioInternalMetadataKeys(m) { if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) { // Do not need to send any internal metadata // values to client. toRemove = append(toRemove, k) continue } // https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
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) -
cmd/bucket-targets.go
} } } // GetRemoteTargetClient returns minio-go client for replication target instance func (sys *BucketTargetSys) GetRemoteTargetClient(bucket, arn string) *TargetClient { sys.RLock() tgt := sys.arnRemotesMap[arn] sys.RUnlock() if tgt.Client != nil { return tgt.Client } defer func() { // lazy refresh remote targets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
internal/s3select/message.go
return genMessage(statsHeader, payload) } // endMessage - indicates that the request is complete, and no more messages will be sent. // You should not assume that the request is complete until the client receives an End message. // // Header specification: // End messages contain two headers, as follows:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
tests/table_test.go
} r = dryDB.Table("gorm.user").Select("name").Find(&User{}).Statement if !regexp.MustCompile("SELECT .name. FROM .gorm.\\..user. WHERE .user.\\..deleted_at. IS NULL").MatchString(r.Statement.SQL.String()) { t.Errorf("Table with escape character, got %v", r.Statement.SQL.String()) } r = dryDB.Select("name").Find(&UserWithTable{}).Statement
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sat Mar 09 09:31:28 GMT 2024 - 10.6K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
"k8s.io/apimachinery/pkg/runtime/serializer/versioning" utilruntime "k8s.io/apimachinery/pkg/util/runtime" _ "k8s.io/client-go/plugin/pkg/client/auth" // to avoid 'No Auth Provider found for name "gcp"' "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd/api" "k8s.io/client-go/tools/clientcmd/api/latest" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/util"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
internal/event/target/kafka.go
KafkaTLS = "tls" KafkaTLSSkipVerify = "tls_skip_verify" KafkaTLSClientAuth = "tls_client_auth" KafkaSASL = "sasl" KafkaSASLUsername = "sasl_username" KafkaSASLPassword = "sasl_password" KafkaSASLMechanism = "sasl_mechanism" KafkaClientTLSCert = "client_tls_cert" KafkaClientTLSKey = "client_tls_key" KafkaVersion = "version" KafkaBatchSize = "batch_size"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
RunE: func(cmd *cobra.Command, args []string) error { client, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } nslist, err := getNamespaces(context.Background(), client, ctx.IstioNamespace()) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
} // Generate generates the manifests for a revision tag pointed the given revision. func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) { // abort if there exists a revision with the target tag name revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag) if err != nil { return "", err } if !opts.Generate && !opts.Overwrite &&
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0)