- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 32 for heddle (0.17 sec)
-
cmd/routers.go
// Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load()) // Register distributed namespace lock routers. registerLockRESTHandlers() // Add grid to router router.Handle(grid.RoutePath, adminMiddleware(globalGrid.Load().Handler(), noGZFlag, noObjLayerFlag)) } // List of some generic middlewares which are applied for all incoming requests. var globalMiddlewares = []mux.MiddlewareFunc{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
internal/config/certsinfo.go
package config import ( "crypto/x509" "crypto/x509/pkix" "fmt" "net/http" "strings" color "github.com/minio/minio/internal/color" ) // Extra ASN1 OIDs that we may need to handle var ( oidEmailAddress = []int{1, 2, 840, 113549, 1, 9, 1} ) // printName prints the fields of a distinguished name, which include such // things as its common name and locality.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 3.1K bytes - Viewed (0) -
cmd/os_windows.go
if err != nil { return errInvalidArgument } data := &syscall.Win32finddata{} handle, err := syscall.FindFirstFile(globAllP, data) if err != nil { if err = syscallErrToFileErr(dirPath, err); err == errFileNotFound { return nil } return err } defer syscall.FindClose(handle) for ; ; err = syscall.FindNextFile(handle, data) { if err != nil { if err == syscall.ERROR_NO_MORE_FILES { break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/grid/muxserver.go
RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c, LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }() return &m } func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/grid/connection_test.go
// 1: Block forever h1 := func(payload []byte) ([]byte, *RemoteErr) { gotCall <- struct{}{} <-cleanReqs return nil, nil } // 2: Also block, but with streaming. h2 := StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { gotCall <- struct{}{} select { case <-ctx.Done(): gotCall <- struct{}{} case <-cleanReqs:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 6K bytes - Viewed (0) -
internal/crypto/sse-s3.go
"github.com/minio/minio/internal/kms" "github.com/minio/minio/internal/logger" ) type sses3 struct{} var ( // S3 represents AWS SSE-S3. It provides functionality to handle // SSE-S3 requests. S3 = sses3{} _ Type = S3 ) // String returns the SSE domain as string. For SSE-S3 the // domain is "SSE-S3". func (sses3) String() string { return "SSE-S3" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.5K bytes - Viewed (0) -
internal/handlers/forwarder.go
// ServeHTTP forwards HTTP traffic using the configured transport func (f *Forwarder) ServeHTTP(w http.ResponseWriter, inReq *http.Request) { outReq := new(http.Request) *outReq = *inReq // includes shallow copies of maps, but we handle this in Director revproxy := httputil.ReverseProxy{ Director: func(req *http.Request) { f.modifyRequest(req, inReq.URL) }, BufferPool: newBufPool(128 << 10), Transport: f.RoundTripper,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
internal/crypto/header.go
h.Del(xhttp.AmzMetaUnencryptedContentLength) h.Del(xhttp.AmzMetaUnencryptedContentMD5) } // SSECopy represents AWS SSE-C for copy requests. It provides // functionality to handle SSE-C copy requests. var SSECopy = ssecCopy{} type ssecCopy struct{} // IsRequested returns true if the HTTP headers contains // at least one SSE-C copy header. Regular SSE-C headers // are ignored.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
} // UnmarshalXML decodes NoncurrentVersionExpiration func (n *NoncurrentVersionExpiration) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error { // To handle xml with MaxNoncurrentVersions from older MinIO releases. // note: only one of MaxNoncurrentVersions or NewerNoncurrentVersions would be present. type noncurrentExpiration struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 14 17:41:44 GMT 2021 - 5.3K bytes - Viewed (1) -
internal/crypto/sse-c.go
"net/http" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" ) type ssec struct{} var ( // SSEC represents AWS SSE-C. It provides functionality to handle // SSE-C requests. SSEC = ssec{} _ Type = SSEC ) // String returns the SSE domain as string. For SSE-C the // domain is "SSE-C". func (ssec) String() string { return "SSE-C" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0)