Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for vertices (0.16 sec)

  1. internal/s3select/message.go

    	// https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/internal/eventstreaming/MessageDecoder.java#L26
    	// but we must make sure there is always space to add 256 bytes:
    	// https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/model/SelectObjectContentEventStream.java#L197
    	maxRecordMessageLength = (128 << 10) - 256
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	info := madmin.GetSysConfig(context.Background(), globalLocalNodeName)
    	return madminSysConfig.NewJSONWith(&info), nil
    }
    
    // GetSysServicesHandler - returns system services information.
    // (only the services that are of concern to minio)
    func (s *peerRESTServer) GetSysServicesHandler(_ *grid.MSS) (*grid.JSON[madmin.SysServices], *grid.RemoteErr) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	testServer.AccessKey = credentials.AccessKey
    	testServer.SecretKey = credentials.SecretKey
    
    	httpHandler, err := configureServerHandler(testServer.Disks)
    	if err != nil {
    		t.Fatalf("Failed to configure one of the RPC services <ERROR> %s", err)
    	}
    
    	// Run TestServer.
    	testServer.Server = httptest.NewUnstartedServer(setCriticalErrorHandler(corsHandler(httpHandler)))
    
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    			DrivesPerSet:     backendInfo.DrivesPerSet,
    		}
    
    		if pools {
    			poolsInfo, _ = getPoolsInfo(ctx, allDisks)
    		}
    	}
    
    	domain := globalDomainNames
    	services := madmin.Services{
    		KMS:           fetchKMSStatus(),
    		KMSStatus:     fetchKMSStatusV2(ctx),
    		LDAP:          ldap,
    		Logger:        log,
    		Audit:         audit,
    		Notifications: notifyTarget,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. cmd/admin-handlers_test.go

    	globalPolicySys = NewPolicySys()
    	objLayer, err := newErasureServerPools(ctx, endpoints)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	// Make objLayer available to all internal services via globalObjectAPI.
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    	globalObjLayerMutex.Unlock()
    	return objLayer, erasureDirs, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  6. cmd/notification.go

    	for index, err := range g.Wait() {
    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetSysServices - Get information about system services
    // (only the services that are of concern to minio)
    func (sys *NotificationSys) GetSysServices(ctx context.Context) []madmin.SysServices {
    	reply := make([]madmin.SysServices, len(sys.peerClients))
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  7. internal/config/dns/types.go

    	// TargetStrip > 0 we strip the left most TargetStrip labels from the
    	// DNS name.
    	TargetStrip int `json:"targetstrip,omitempty"`
    
    	// Group is used to group (or *not* to group) different services
    	// together. Services with an identical Group are returned in
    	// the same answer.
    	Group string `json:"group,omitempty"`
    
    	// Key carries the original key used during Put().
    	Key string `json:"-"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	})
    
    	// Configure server.
    	bootstrapTrace("configureServer", func() {
    		handler, err := configureServerHandler(globalEndpoints)
    		if err != nil {
    			logger.Fatal(config.ErrUnexpectedError(err), "Unable to configure one of server's RPC services")
    		}
    		// Allow grid to start after registering all services.
    		xioutil.SafeClose(globalGridStart)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
Back to top