- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 86 for Clulow (0.16 sec)
-
cmd/policy_test.go
Statements: []policy.BPStatement{ policy.NewBPStatement("", policy.Allow, policy.NewPrincipal("*"), policy.NewActionSet(policy.GetBucketLocationAction), policy.NewResourceSet(policy.NewResource("mybucket")), condition.NewFunctions(), ), policy.NewBPStatement("", policy.Allow, policy.NewPrincipal("*"), policy.NewActionSet(policy.PutObjectAction),
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 8.9K bytes - Viewed (0) -
internal/bucket/lifecycle/expiration.go
return err } // While AWS documentation mentions that the date specified // must be present in ISO 8601 format, in reality they allow // users to provide RFC 3339 compliant dates. expDate, err := time.Parse(time.RFC3339, dateStr) if err != nil { return errLifecycleInvalidDate } // Allow only date timestamp specifying midnight GMT hr, min, sec := expDate.Clock() nsec := expDate.Nanosecond() loc := expDate.Location()
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Wed Feb 21 20:28:34 GMT 2024 - 6.6K bytes - Viewed (1) -
cmd/bucket-notification-handlers.go
config.QueueList = append(config.QueueList[:i], config.QueueList[i+1:]...) } // This is a one time activity we shall do this // here and allow stale ARN to be removed. We shall // never reach a stage where we will have stale // notification configs. } } else { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
manager, err := certs.NewManager(context.Background(), args.ClientCert, args.ClientKey, tls.LoadX509KeyPair) if err != nil { return err } manager.ReloadOnSignal(syscall.SIGHUP) // allow reloads upon SIGHUP transport.TLSClientConfig.GetClientCertificate = manager.GetClientCertificate } target.httpClient = &http.Client{Transport: transport} yes, err := target.isActive() if err != nil {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0) -
cmd/api-headers.go
) // Returns a hexadecimal representation of time at the // time response is sent to the client. func mustGetRequestID(t time.Time) string { return fmt.Sprintf("%X", t.UnixNano()) } // setEventStreamHeaders to allow proxies to avoid buffering proxy responses func setEventStreamHeaders(w http.ResponseWriter) { w.Header().Set(xhttp.ContentType, "text/event-stream") w.Header().Set(xhttp.CacheControl, "no-cache") // nginx to turn off buffering
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
cmd/erasure-healing-common.go
modTime = commonTime(modTimes, quorum) if modTime.IsZero() || modTime.Equal(timeSentinel) { etags := listObjectETags(partsMetadata, errs, quorum) etag = commonETag(etags, quorum) if etag != "" { // allow this fallback only if a non-empty etag is found. for index, e := range etags { if partsMetadata[index].IsValid() && e == etag { onlineDisks[index] = disks[index] } else { onlineDisks[index] = nil
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.8K bytes - Viewed (0) -
cmd/erasure-healing.go
disks = disks[:expectedDisks] // How to resolve partial results. resolver := metadataResolutionParams{ dirQuorum: 1, objQuorum: 1, bucket: bucket, strict: false, // Allow less strict matching. } path := baseDirFromPrefix(prefix) filterPrefix := strings.Trim(strings.TrimPrefix(prefix, path), slashSeparator) if path == prefix { filterPrefix = "" }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 09:26:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/server-main.go
globalLocalNodeNameHex = hex.EncodeToString(nodeNameSum[:]) // Initialize, see which NIC the service is running on, and save it as global value setGlobalInternodeInterface(ctxt.Interface) // allow transport to be HTTP/1.1 for proxying. globalProxyTransport = NewCustomHTTPProxyTransport()() globalProxyEndpoints = GetProxyEndpoints(globalEndpoints)
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 32.8K bytes - Viewed (1) -
internal/config/policy/opa/config.go
// form http://localhost:8181/v1/data/httpapi/authz type opaResultAllow struct { Result struct { Allow bool `json:"allow"` } `json:"result"` } // Handle simpler OPA responses when OPA URL is of // form http://localhost:8181/v1/data/httpapi/authz/allow type opaResult struct { Result bool `json:"result"` } respBody := bytes.NewReader(opaRespBytes)
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
internal/disk/fdatasync_linux.go
package disk import ( "os" "syscall" "golang.org/x/sys/unix" ) // Fdatasync - fdatasync() is similar to fsync(), but does not flush modified metadata // unless that metadata is needed in order to allow a subsequent data retrieval // to be correctly handled. For example, changes to st_atime or st_mtime // (respectively, time of last access and time of last modification; see inode(7))
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Wed Sep 29 23:40:28 GMT 2021 - 1.8K bytes - Viewed (0)