Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1331 - 1340 of 1,387 for funcs (0.13 sec)

  1. cmd/metrics-v3-cluster-iam.go

    	syncSuccessesMD                          = NewCounterMD(syncSuccesses, "Number of successful IAM data syncs since server start.")
    )
    
    // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
    func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds)))
    	pluginAuthNMetrics := globalAuthNPlugin.Metrics()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. tests/joins_table_test.go

    	DeletedAt gorm.DeletedAt
    }
    
    type Address struct {
    	ID   uint
    	Name string
    }
    
    type PersonAddress struct {
    	PersonID  int
    	AddressID int
    	CreatedAt time.Time
    	DeletedAt gorm.DeletedAt
    }
    
    func TestOverrideJoinTable(t *testing.T) {
    	DB.Migrator().DropTable(&Person{}, &Address{}, &PersonAddress{})
    
    	if err := DB.SetupJoinTable(&Person{}, "Addresses", &PersonAddress{}); err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Sep 10 13:46:18 UTC 2020
    - 3.5K bytes
    - Viewed (1)
  3. cmd/metrics-v3.go

    	bucketMGMap map[collectorPath]*MetricsGroup
    
    	// Gatherers for non-bucket MetricsGroup's
    	mgGatherers map[collectorPath]prometheus.Gatherer
    
    	collectorPaths []collectorPath
    }
    
    func newMetricGroups(r *prometheus.Registry) *metricsV3Collection {
    	// Create all metric groups.
    	apiRequestsMG := NewMetricsGroup(apiRequestsCollectorPath,
    		[]MetricDescriptor{
    			apiRejectedAuthTotalMD,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 00:55:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  4. cmd/bucket-replication_test.go

    			ReplicationStatus: replication.Completed,
    			VersionID:         "a3348c34-c352-4498-82f0-1098e8b34df9",
    		},
    		rcfg:         replicationConfig{Config: &configs[0]},
    		expectedSync: false,
    	},
    }
    
    func TestReplicationResync(t *testing.T) {
    	ctx := context.Background()
    	for i, test := range replicationConfigTests {
    		if sync := test.rcfg.Resync(ctx, test.info, test.dsc, test.tgtStatuses); sync.mustResync() != test.expectedSync {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  5. docs/distributed/DESIGN.md

    - Choosing an erasure set for the object is decided during `PutObject()`, object names are used to find the right erasure set using the following pseudo code.
    
    ```go
    // hashes the key returning an integer.
    func sipHashMod(key string, cardinality int, id [16]byte) int {
            if cardinality <= 0 {
                    return -1
            }
            sip := siphash.New(id[:])
            sip.Write([]byte(key))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/hash/HashingTest.java

        for (Cell<HashFunction, String, String> cell : KNOWN_HASHES.cellSet()) {
          HashFunction func = cell.getRowKey();
          String input = cell.getColumnKey();
          String expected = cell.getValue();
          assertEquals(
              String.format(Locale.ROOT, "Known hash for hash(%s, UTF_8) failed", input),
              expected,
              func.hashString(input, UTF_8).toString());
        }
      }
    
      public void testNullPointers() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 09 17:40:09 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/ViewHelper.java

            public ActionResponse godHandPrologue(final ActionRuntime runtime, final Function<ActionRuntime, ActionResponse> func) {
                return func.apply(runtime);
            }
    
            public ActionResponse godHandMonologue(final ActionRuntime runtime, final Function<ActionRuntime, ActionResponse> func) {
                return func.apply(runtime);
            }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 40.2K bytes
    - Viewed (0)
  8. cmd/bucket-encryption_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"testing"
    )
    
    func TestValidateBucketSSEConfig(t *testing.T) {
    	testCases := []struct {
    		inputXML    string
    		expectedErr error
    		shouldPass  bool
    	}{
    		// MinIO supported XML
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 14 07:59:05 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  9. docs/debugging/inspect/decrypt-v1.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"encoding/binary"
    	"encoding/hex"
    	"fmt"
    	"hash/crc32"
    	"io"
    
    	"github.com/secure-io/sio-go"
    )
    
    func extractInspectV1(keyHex string, r io.Reader, w io.Writer, okMsg string) error {
    	id, err := hex.DecodeString(keyHex[:8])
    	if err != nil {
    		return err
    	}
    	key, err := hex.DecodeString(keyHex[8:])
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 11 21:22:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. cmd/fmt-gen.go

         {{.Prompt}} {{.HelpName}} http://node{1...32}.example.com/mnt/export{1...32}
    
    `,
    }
    
    func fmtGenMain(ctxt *cli.Context) {
    	deploymentID := ctxt.String("deployment-id")
    	err := buildServerCtxt(ctxt, &globalServerCtxt)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	handleCommonArgs(globalServerCtxt)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
Back to top