- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 423 for Buckets (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsRoleTypeCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 49K bytes - Click Count (0) -
cmd/rebalance-admin.go
import ( "context" "time" ) type rebalPoolProgress struct { NumObjects uint64 `json:"objects"` NumVersions uint64 `json:"versions"` Bytes uint64 `json:"bytes"` Bucket string `json:"bucket"` Object string `json:"object"` Elapsed time.Duration `json:"elapsed"` ETA time.Duration `json:"eta"` } type rebalancePoolStatus struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.8K bytes - Click Count (0) -
cmd/object-handlers-common_test.go
expectedCode: 304, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { recorder := httptest.NewRecorder() request := httptest.NewRequest(http.MethodHead, "/bucket/a", bytes.NewReader([]byte{})) request.Header.Set(xhttp.IfNoneMatch, tc.ifNoneMatch) request.Header.Set(xhttp.IfModifiedSince, tc.ifModifiedSince) request.Header.Set(xhttp.IfMatch, tc.ifMatch)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.3K bytes - Click Count (0) -
src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java
h[2] = (byte) ((length >> 8) & 0xFF); h[3] = (byte) (length & 0xFF); return h; } /** * Creates a NetBIOS keep-alive header. * Keep-alive packets have type 0x85 and zero length. */ private static byte[] keepAliveHeader() { byte[] h = new byte[4]; h[0] = (byte) SessionServicePacket.SESSION_KEEP_ALIVE; h[1] = h[2] = h[3] = 0;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsJobLogCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 58.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsAccessTokenCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 15 06:53:53 GMT 2025 - 60K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingServerSocketFactory.kt
*/ package okhttp3 import java.io.IOException import java.net.InetAddress import java.net.ServerSocket import javax.net.ServerSocketFactory /** * A [ServerSocketFactory] that delegates calls. Sockets can be configured after creation by * overriding [.configureServerSocket]. */ open class DelegatingServerSocketFactory( private val delegate: ServerSocketFactory, ) : ServerSocketFactory() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt
package okhttp3 import javax.net.ssl.SSLSocket import javax.net.ssl.SSLSocketFactory import okhttp3.FallbackTestClientSocketFactory.Companion.TLS_FALLBACK_SCSV /** * An SSLSocketFactory that delegates calls. Sockets created by the delegate are wrapped with ones * that will not accept the [TLS_FALLBACK_SCSV] cipher, thus bypassing server-side fallback * checks on platforms that support it. Unfortunately this wrapping will disable any
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.net.Socket /** * The sockets and streams of an HTTP, HTTPS, or HTTPS+HTTP/2 connection. May be used for multiple * HTTP request/response exchanges. Connections may be direct to the origin server or via a proxy. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.3K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/SessionServicePacket.java
*/ package jcifs.smb1.netbios; import java.io.IOException; import java.io.InputStream; /** * Abstract base class for NetBIOS session service packets. * This class provides common functionality for session layer communication in SMB1. */ public abstract class SessionServicePacket { /** * Default constructor for SessionServicePacket.Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 5.2K bytes - Click Count (0)