- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 559 for Content (0.16 sec)
-
internal/event/target/webhook.go
return store.ErrNotConnected } return nil } // NewWebhookTarget - creates new Webhook target. func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) { ctx, cancel := context.WithCancel(ctx) var queueStore store.Store[event.Event] if args.QueueDir != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
return r.ongoing } // OnDisk returns true if restored object contents exist in MinIO. Otherwise returns false. // The restore operation could be in one of the following states, // - in progress (no content on MinIO's disks yet) // - completed // - completed but expired (again, no content on MinIO's disks) func (r restoreObjStatus) OnDisk() bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/http/transports.go
return tr } // NewHTTPTransportWithClientCerts returns a new http configuration used for // communicating with client cert authentication. func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) { transport := s.NewHTTPTransportWithTimeout(1 * time.Minute) if clientCert != "" && clientKey != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
tests/migrate_test.go
// sqlserver driver treats NULL and 'NULL' the same t.Skip("skip sqlserver") } type NullModel struct { ID uint Content string `gorm:"default:null"` } type NullStringModel struct { ID uint Content string `gorm:"default:'null'"` Active bool `gorm:"default:false"` } tableName := "null_string_model" DB.Migrator().DropTable(tableName)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Mar 18 11:24:16 GMT 2024 - 56.2K bytes - Viewed (0) -
cmd/metrics.go
tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if ok { tc.FuncName = "handler.MetricsLegacy" tc.ResponseRecorder.LogErrBody = true } mfs, err := gatherers.Gather() if err != nil { if len(mfs) == 0 { writeErrorResponseJSON(r.Context(), w, toAdminAPIErr(r.Context(), err), r.URL) return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
rpt.SetStatus(bucket, fileName, fmt.Errorf("%s", errorCodes[ErrKMSNotConfigured].Description)) continue } kmsKey := encConfig.KeyID() if kmsKey != "" { kmsContext := kms.Context{"MinIO admin API": "ServerInfoHandler"} // Context for a test key operation _, err := GlobalKMS.GenerateKey(ctx, kmsKey, kmsContext) if err != nil { if errors.Is(err, kes.ErrKeyNotFound) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/globals.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/metrics-v2.go
} mg.RegisterRead(func(ctx context.Context) []MetricV2 { return getHistogramMetrics(bucketHTTPRequestsDuration, getBucketTTFBDistributionMD(), true) }) return mg } func getS3TTFBMetric() *MetricsGroupV2 { mg := &MetricsGroupV2{ cacheInterval: 10 * time.Second, } mg.RegisterRead(func(ctx context.Context) []MetricV2 { return getHistogramMetrics(httpRequestsDuration,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
src/archive/tar/writer.go
if tw.err != nil { return 0, tw.err } n, err := tw.curr.Write(b) if err != nil && err != ErrWriteTooLong { tw.err = err } return n, err } // readFrom populates the content of the current file by reading from r. // The bytes read must match the number of remaining bytes in the current file. // // If the current file is sparse and r is an io.ReadSeeker,
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
internal/s3select/sql/value.go
// InferBytesType will attempt to infer the data type of bytes. // Will fail if value type is not bytes or it would result in invalid utf8. // ORDER: int, float, bool, JSON (object or array), timestamp, string // If the content is valid JSON, the type will still be bytes. func (v *Value) InferBytesType() (err error) { b, ok := v.ToBytes() if !ok { return fmt.Errorf("InferByteType: Input is not bytes, but %v", v.GetTypeString()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0)