Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Chander (0.18 sec)

  1. internal/grid/handlers_string.go

    // Code generated by "stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go handlers.go"; DO NOT EDIT.
    
    package grid
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[handlerInvalid-0]
    	_ = x[HandlerLockLock-1]
    	_ = x[HandlerLockRLock-2]
    	_ = x[HandlerLockUnlock-3]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    func metricsBucketHandler() http.Handler {
    	return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket")
    }
    
    func metricsServerHandler() http.Handler {
    	registry := prometheus.NewRegistry()
    
    	// Report all other metrics
    	logger.CriticalIf(GlobalContext, registry.Register(clusterCollector))
    
    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)
  3. cmd/object-handlers.go

    // This implementation of the PUT operation adds an object to a bucket
    // while reading the object from another source.
    // Notice: The S3 client can send secret keys in headers for encryption related jobs,
    // the handler should ensure to remove these keys before sending them to the object layer.
    // Currently these keys are:
    //   - X-Amz-Server-Side-Encryption-Customer-Key
    //   - X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    // DeleteObject - deletes an object, this call doesn't necessary reply
    // any error as it is not necessary for the handler to reply back a
    // response to the client request.
    func (er erasureObjects) DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	if !opts.NoAuditLog {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. cmd/metrics-v3-handler.go

    	for _, val := range v {
    		s = append(s, fmt.Sprintf("%v", val))
    	}
    	err := fmt.Errorf("metrics handler error: %v", strings.Join(s, " "))
    	metricsLogIf(GlobalContext, err)
    }
    
    type metricsV3Server struct {
    	registry *prometheus.Registry
    	opts     promhttp.HandlerOpts
    	authFn   func(http.Handler) http.Handler
    
    	metricsData *metricsV3Collection
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  6. cmd/post-policy_test.go

    	req.Header.Set("Content-Type", contentTypeHdr)
    	req.Header.Set("User-Agent", "Mozilla")
    
    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to execute the handler.
    	apiRouter.ServeHTTP(rec, req)
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    	}
    
    	// We fake a local and remote server.
    	remoteHost := remote.HostName()
    	handler := NewStream[*testRequest, *testRequest, *testResponse](handlerTest, newTestRequest, newTestRequest, newTestResponse)
    	handler.InCapacity = 1
    	handler.OutCapacity = 1
    	const payloads = 10
    
    	// 1: Echo
    	register := func(manager *Manager) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    			logger.FatalIf(storageReadAllRPC.Register(gm, server.ReadAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageWriteAllRPC.Register(gm, server.WriteAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageRenameFileRPC.Register(gm, server.RenameFileHandler, endpoint.Path), "unable to register handler")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  9. cmd/bucket-versioning-handler.go

    Harshavardhana <******@****.***> 1713808170 -0700
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5K bytes
    - Viewed (0)
  10. internal/grid/handlers.go

    	HandlerRenameData2
    
    	// Add more above here ^^^
    	// If all handlers are used, the type of Handler can be changed.
    	// Handlers have no versioning, so non-compatible handler changes must result in new IDs.
    	handlerTest
    	handlerTest2
    	handlerLast
    )
    
    // handlerPrefixes are prefixes for handler IDs used for tracing.
    // If a handler is not listed here, it will be traced with "grid" prefix.
    var handlerPrefixes = [handlerLast]string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
Back to top