Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 1,214 for Func (0.02 sec)

  1. android/guava-tests/test/com/google/common/hash/ChecksumHashFunctionTest.java

        checksum.update(bytes, 0, bytes.length);
        long value = checksum.getValue();
    
        String toString = "name";
        HashFunction func = new ChecksumHashFunction(supplier, 32, toString);
        assertEquals(toString, func.toString());
        assertEquals(value, func.hashBytes(bytes).padToLong());
      }
    
      private static void assertHash32(
          int expected, ImmutableSupplier<Checksum> supplier, String input) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 30 14:33:12 UTC 2018
    - 3.1K bytes
    - Viewed (0)
  2. internal/jwt/parser.go

    // If nil an empty string will be returned.
    func (c *MapClaims) GetAccessKey() string {
    	if c == nil {
    		return ""
    	}
    	return c.AccessKey
    }
    
    // NewStandardClaims - initializes standard claims
    func NewStandardClaims() *StandardClaims {
    	return &StandardClaims{}
    }
    
    // SetIssuer sets issuer for these claims
    func (c *StandardClaims) SetIssuer(issuer string) {
    	c.Issuer = issuer
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. internal/config/browser/browser.go

    	}
    
    	return cfg, nil
    }
    
    // GetCSPolicy - Get the Content security Policy
    func (browseCfg *Config) GetCSPolicy() string {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.CSPPolicy
    }
    
    // GetHSTSSeconds - Get the Content security Policy
    func (browseCfg *Config) GetHSTSSeconds() int {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.HSTSSeconds
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cache.go

    		clusterDriveMetrics: newClusterStorageInfoCache(),
    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. cmd/update_test.go

    			t.Fatalf("result: expected: %v, got: %v", testCase.expectedResult, result)
    		}
    	}
    }
    
    func TestDownloadReleaseData(t *testing.T) {
    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. internal/s3select/sql/parser_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package sql
    
    import (
    	"bytes"
    	"testing"
    
    	"github.com/alecthomas/participle"
    	"github.com/alecthomas/participle/lexer"
    )
    
    func TestJSONPathElement(t *testing.T) {
    	p := participle.MustBuild(
    		&JSONPathElement{},
    		participle.Lexer(sqlLexer),
    		participle.CaseInsensitive("Keyword"),
    		participle.CaseInsensitive("Timeword"),
    	)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    	getMemInfoRPC                  = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.MemInfo]](grid.HandlerGetMemInfo, grid.NewMSS, madminMemInfo.NewJSON)
    	getMetacacheListingRPC         = grid.NewSingleHandler[*listPathOptions, *metacache](grid.HandlerGetMetacacheListing, func() *listPathOptions { return &listPathOptions{} }, func() *metacache { return &metacache{} })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  8. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    	if !sys.HasLogListeners() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/event/target/mysql.go

    	quitCh chan struct{}
    }
    
    // ID - returns target ID.
    func (target *MySQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *MySQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *MySQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. src/bytes/reader_test.go

    }
    
    var UnreadRuneErrorTests = []struct {
    	name string
    	f    func(*Reader)
    }{
    	{"Read", func(r *Reader) { r.Read([]byte{0}) }},
    	{"ReadByte", func(r *Reader) { r.ReadByte() }},
    	{"UnreadRune", func(r *Reader) { r.UnreadRune() }},
    	{"Seek", func(r *Reader) { r.Seek(0, io.SeekCurrent) }},
    	{"WriteTo", func(r *Reader) { r.WriteTo(&Buffer{}) }},
    }
    
    func TestUnreadRuneError(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
Back to top