- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for geturl (0.16 sec)
-
internal/event/target/kafka.go
return nil } return err } msg, err := target.toProducerMessage(eventData) if err != nil { return err } if err = target.batch.Add(key.Name, msg); err != nil { return err } } // commit the batch if the key is the last one present in the store. if key.IsLast || target.batch.IsFull() { return target.commitBatch() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/name.go
return "s3:ObjectAccessed:Head" case ObjectAccessedAttributes: return "s3:ObjectAccessed:Attributes" case ObjectCreatedAll: return "s3:ObjectCreated:*" case ObjectCreatedCompleteMultipartUpload: return "s3:ObjectCreated:CompleteMultipartUpload" case ObjectCreatedCopy: return "s3:ObjectCreated:Copy" case ObjectCreatedPost: return "s3:ObjectCreated:Post" case ObjectCreatedPut: return "s3:ObjectCreated:Put"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/site-replication-metrics_gen.go
if err != nil { return } err = en.WriteInt64(z.ReplicatedCount) if err != nil { err = msgp.WrapError(err, "ReplicatedCount") return } // write "Failed" err = en.Append(0xa6, 0x46, 0x61, 0x69, 0x6c, 0x65, 0x64) if err != nil { return } err = z.Failed.EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "Failed") return } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 40.6K bytes - Viewed (0) -
cmd/batch-job-common-types_gen.go
if err != nil { return } err = en.WriteString(z.Endpoint) if err != nil { err = msgp.WrapError(err, "Endpoint") return } // write "Token" err = en.Append(0xa5, 0x54, 0x6f, 0x6b, 0x65, 0x6e) if err != nil { return } err = en.WriteString(z.Token) if err != nil { err = msgp.WrapError(err, "Token") return } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 21.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
return p.storage.LastConn() } func (p *xlStorageDiskIDCheck) IsLocal() bool { return p.storage.IsLocal() } func (p *xlStorageDiskIDCheck) Endpoint() Endpoint { return p.storage.Endpoint() } func (p *xlStorageDiskIDCheck) Hostname() string { return p.storage.Hostname() } func (p *xlStorageDiskIDCheck) Healing() *healingTracker { return p.storage.Healing() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/metacache-set_gen.go
return } // write "pool" err = en.Append(0xa4, 0x70, 0x6f, 0x6f, 0x6c) if err != nil { return } err = en.WriteInt(z.pool) if err != nil { err = msgp.WrapError(err, "pool") return } // write "set" err = en.Append(0xa3, 0x73, 0x65, 0x74) if err != nil { return } err = en.WriteInt(z.set) if err != nil { err = msgp.WrapError(err, "set") return } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/object-api-errors.go
if len(params) >= 1 { apiErr.Bucket = params[0] } return apiErr case errVolumeExists.Error(): apiErr := BucketExists{} if len(params) >= 1 { apiErr.Bucket = params[0] } return apiErr case errDiskFull.Error(): return StorageFull{} case errTooManyOpenFiles.Error(): return SlowDown{} case errFileAccessDenied.Error(): apiErr := PrefixAccessDenied{} if len(params) >= 1 { apiErr.Bucket = params[0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/hash/checksum.go
} return "" } // RawByteLen returns the size of the un-encoded checksum. func (c ChecksumType) RawByteLen() int { switch { case c.Is(ChecksumCRC32): return 4 case c.Is(ChecksumCRC32C): return 4 case c.Is(ChecksumSHA1): return sha1.Size case c.Is(ChecksumSHA256): return sha256.Size } return 0 } // IsSet returns whether the type is valid and known.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/auth-handler.go
return authTypeStreamingUnsignedTrailer } else if isRequestSignatureV4(r) { return authTypeSigned } else if isRequestPresignedSignatureV4(r) { return authTypePresigned } else if isRequestJWT(r) { return authTypeJWT } else if isRequestPostPolicySignatureV4(r) { return authTypePostPolicy } else if _, ok := r.Form[xhttp.Action]; ok { return authTypeSTS } else if _, ok := r.Header[xhttp.Authorization]; !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
cmd/kms-handlers.go
return } writeSuccessResponseJSON(w, res) return } defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objectAPI, _ := validateAdminReq(ctx, w, r, policy.KMSListKeysAction) if objectAPI == nil { return } if GlobalKMS == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrKMSNotConfigured), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 20.7K bytes - Viewed (0)