Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for rest (0.05 sec)

  1. cmd/peer-rest-server.go

    	res := make([]*MetricV2, 0, len(resourceMetricsGroups))
    	populateAndPublish(resourceMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  2. pom.xml

    				<activeByDefault>true</activeByDefault>
    			</activation>
    			<properties>
    				<test.include.path>**/*Test.java</test.include.path>
    				<test.command.args>--illegal-access=permit</test.command.args>
    			</properties>
    		</profile>
    		<profile>
    			<id>integrationTests</id>
    			<properties>
    				<test.include.path>**/*Tests.java</test.include.path>
    				<test.command.args />
    			</properties>
    		</profile>
    	</profiles>
    	<build>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Sep 04 05:22:58 UTC 2025
    - 49.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbTransportImpl.java

            final ServerMessageBlock2Response resp = (ServerMessageBlock2Response) response;
            synchronized (resp) {
                if (resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0) {
                    resp.setAsyncHandled(true);
                    final boolean first = !req.isAsync();
                    req.setAsyncId(resp.getAsyncId());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  4. src/bytes/bytes_test.go

    		{"a☺b☻c☹d", "b", len("a☺")},               // non-ascii
    	}
    	for _, test := range testCases {
    		actual := LastIndexByte([]byte(test.a), test.b[0])
    		if actual != test.i {
    			t.Errorf("LastIndexByte(%q,%c) = %v; want %v", test.a, test.b[0], actual, test.i)
    		}
    	}
    }
    
    // test a larger buffer with different sizes and alignments
    func TestIndexByteBig(t *testing.T) {
    	var n = 1024
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Jul 28 18:13:58 UTC 2025
    - 62.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

      //
      // A consequence of these requirements is that the delegate futures cannot be stored in
      // final fields.
      //
      // For simplicity the rest of this description will discuss Futures.catching since it is the
      // simplest instance, though very similar descriptions apply to many other classes in this file.
      //
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/testdata/amd64enc_extra.s

    	SHA256MSG2 (R11), X11    // 450f38cd1b
    	SHA256MSG2 X2, X11       // 440f38cdda
    	SHA256MSG2 X11, X11      // 450f38cddb
    	// Test VPERMQ with both uint8 and int8 immediate args
    	VPERMQ $-40, Y8, Y8 // c443fd00c0d8
    	VPERMQ $216, Y8, Y8 // c443fd00c0d8
    	// Test that VPERMPD that shares ytab list with VPERMQ continues to work too.
    	VPERMPD $-40, Y7, Y7 // c4e3fd01ffd8
    	VPERMPD $216, Y7, Y7 // c4e3fd01ffd8
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Feb 20 11:20:03 UTC 2025
    - 57.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Sets.java

       * which the elements are provided to the method.
       *
       * @param anElement one of the elements the set should contain
       * @param otherElements the rest of the elements the set should contain
       * @return an immutable set containing those elements, minus duplicates
       */
      public static <E extends Enum<E>> ImmutableSet<E> immutableEnumSet(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/HttpUrlTest.kt

    import assertk.assertions.hasMessage
    import assertk.assertions.isEqualTo
    import assertk.assertions.isNull
    import kotlin.test.Ignore
    import kotlin.test.Test
    import kotlin.test.assertEquals
    import kotlin.test.assertFailsWith
    import kotlin.test.fail
    import okhttp3.HttpUrl.Companion.toHttpUrl
    import okhttp3.UrlComponentEncodingTester.Encoding
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Aug 04 07:38:48 UTC 2025
    - 69.9K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2.go

    // the current journal entry type other types might be nil based
    // on what Type field carries, it is imperative for the caller
    // to verify which journal type first before accessing rest of the fields.
    type xlMetaV2Version struct {
    	Type             VersionType           `json:"Type" msg:"Type"`
    	ObjectV1         *xlMetaV1Object       `json:"V1Obj,omitempty" msg:"V1Obj,omitempty"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  10. cmd/iam.go

    	// Policies were found, evaluate all of them.
    	return sys.GetCombinedPolicy(policy).IsAllowed(args)
    }
    
    // IsAllowed - checks given policy args is allowed to continue the Rest API.
    func (sys *IAMSys) IsAllowed(args policy.Args) bool {
    	// If opa is configured, use OPA always.
    	if authz := newGlobalAuthZPluginFn(); authz != nil {
    		ok, err := authz.IsAllowed(args)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
Back to top