Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for initGlobalGrid (0.23 sec)

  1. cmd/grid.go

    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  2. cmd/lock-rest-client_test.go

    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	err = initGlobalGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	lkClient := newlockRESTClient(endpoint)
    	if lkClient.IsOnline() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 2K bytes
    - Viewed (0)
  3. cmd/server-main.go

    	}
    
    	var getCert certs.GetCertificateFunc
    	if globalTLSCerts != nil {
    		getCert = globalTLSCerts.GetCertificate
    	}
    
    	// Initialize gridn
    	bootstrapTrace("initGrid", func() {
    		logger.FatalIf(initGlobalGrid(GlobalContext, globalEndpoints), "Unable to configure server grid RPC services")
    	})
    
    	// Configure server.
    	bootstrapTrace("configureServer", func() {
    		handler, err := configureServerHandler(globalEndpoints)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
Back to top