Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for vertices (0.15 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/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)
  3. 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)
  4. 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