- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 586 for match1 (0.08 sec)
-
internal/event/target/mysql.go
if IsConnErr(err) { return store.ErrNotConnected } return err } } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/erasure-metadata.go
// We have removed this check to allow reading objects with different DataDir // values in a few drives (due to a rebalance-stop race bug) // provided their their etags or ModTimes match. if !meta.Deleted && meta.Size != 0 { fmt.Fprintf(h, "%v+%v", meta.Erasure.DataBlocks, meta.Erasure.ParityBlocks) fmt.Fprintf(h, "%v", meta.Erasure.Distribution) } if meta.IsRemote() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 21.2K bytes - Viewed (0) -
gorm.go
DisableNestedTransaction bool // AllowGlobalUpdate allow global update AllowGlobalUpdate bool // QueryFields executes the SQL query with all fields of the table QueryFields bool // CreateBatchSize default create batch size CreateBatchSize int // TranslateError enabling error translation TranslateError bool // PropagateUnscoped propagate Unscoped to every other nested statement PropagateUnscoped bool
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Wed Oct 09 11:29:48 UTC 2024 - 12.1K bytes - Viewed (0) -
internal/event/target/nats.go
return err } _, err := target.isActive() if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/admin-router.go
// -- Health API -- adminRouter.Methods(http.MethodGet).Path(adminVersion + "/healthinfo"). HandlerFunc(adminMiddleware(adminAPI.HealthInfoHandler)) } // If none of the routes match add default error handler routes adminRouter.NotFoundHandler = httpTraceAll(errorResponseHandler) adminRouter.MethodNotAllowedHandler = httpTraceAll(methodNotAllowedHandler("Admin"))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Sep 21 11:35:40 UTC 2024 - 26.2K bytes - Viewed (0) -
cmd/admin-handlers.go
return } // 3. Compare generated key with decrypted key if subtle.ConstantTimeCompare(key.Plaintext, decryptedKey) != 1 { response.DecryptionErr = "The generated and the decrypted data key do not match" resp, err := json.Marshal(response) if err != nil { writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL) return } writeSuccessResponseJSON(w, resp)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
helm-releases/minio-4.0.11.tgz
"minio.name" . }} spec: maxUnavailable: {{ .Values.podDisruptionBudget.maxUnavailable }} selector: matchLabels: app: {{ template "minio.name" . }} {{- end }} minio/templates/post-install-create-bucket-job.yaml {{- if .Values.buckets }} apiVersion: batch/v1 kind: Job metadata: name: {{ template "minio.fullname" . }}-make-bucket-job namespace: {{ .Release.Namespace | quote }} labels: app: {{ template "minio.name" . }}-make-bucket-job chart: {{ template "minio.chart" . }} release: {{ .Release.Name }}...
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 07 05:41:47 UTC 2022 - 19.2K bytes - Viewed (0) -
helm-releases/minio-5.0.0.tgz
"minio.name" . }} spec: maxUnavailable: {{ .Values.podDisruptionBudget.maxUnavailable }} selector: matchLabels: app: {{ template "minio.name" . }} {{- end }} minio/templates/post-install-create-bucket-job.yaml {{- if .Values.buckets }} apiVersion: batch/v1 kind: Job metadata: name: {{ template "minio.fullname" . }}-make-bucket-job namespace: {{ .Release.Namespace | quote }} labels: app: {{ template "minio.name" . }}-make-bucket-job chart: {{ template "minio.chart" . }} release: {{ .Release.Name }}...
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 25 10:20:22 UTC 2022 - 19.8K bytes - Viewed (0) -
cmd/site-replication.go
return true } // isIAMPolicyReplicated returns true if count of replicated IAM policies matches total // number of sites and IAM policies are identical. func isIAMPolicyReplicated(cntReplicated, total int, policies []*policy.Policy) bool { if cntReplicated > 0 && cntReplicated != total { return false } // check if policies match between sites var prev *policy.Policy for i, p := range policies { if i == 0 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
src/archive/tar/writer_test.go
var buf bytes.Buffer tw := NewWriter(&buf) if err := tw.AddFS(fsys); err != nil { t.Fatal(err) } if err := tw.Close(); err != nil { t.Fatal(err) } // Add subfolder into fsys to match what we'll read from the tar. fsys["subfolder"] = &fstest.MapFile{Mode: 0o555 | os.ModeDir} // Test that we can get the files back from the archive tr := NewReader(&buf)
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 39.4K bytes - Viewed (0)