Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for myTask (0.14 sec)

  1. internal/event/name.go

    		}
    		return res
    	default:
    		return []Name{name}
    	}
    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    	if name < objectSingleTypesEnd {
    		return 1 << (name - 1)
    	}
    	var mask uint64
    	for _, n := range name.Expand() {
    		mask |= 1 << (n - 1)
    	}
    	return mask
    }
    
    // String - returns string representation of event type.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. cmd/globals.go

    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    	globalConsoleSys *HTTPConsoleLoggerSys
    
    	// All unique drives for this deployment
    	globalEndpoints EndpointServerPools
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		n = 10
    
    	default:
    		return ws.ErrHeaderLengthUnexpected
    	}
    
    	if f.Header.Masked {
    		bts[1] |= bit0
    		n += copy(bts[n:], f.Header.Mask[:])
    	}
    
    	if _, err := w.Write(bts[:n]); err != nil {
    		return err
    	}
    
    	_, err := w.Write(f.Payload)
    	return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top