Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1141 - 1150 of 1,605 for var1 (0.04 sec)

  1. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

    import okhttp3.sse.EventSource
    import okhttp3.sse.EventSourceListener
    
    class EventSourceRecorder : EventSourceListener() {
      private val events = LinkedBlockingDeque<Any>()
      private var cancel = false
    
      fun enqueueCancel() {
        cancel = true
      }
    
      override fun onOpen(
        eventSource: EventSource,
        response: Response,
      ) {
        get().log("[ES] onOpen", Platform.INFO, null)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. api/go1.10.txt

    pkg time, func LoadLocationFromTZData(string, []uint8) (*Location, error)
    pkg unicode, const Version = "10.0.0"
    pkg unicode, var Masaram_Gondi *RangeTable
    pkg unicode, var Nushu *RangeTable
    pkg unicode, var Regional_Indicator *RangeTable
    pkg unicode, var Soyombo *RangeTable
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Feb 06 05:00:01 UTC 2018
    - 30.1K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    		return FileInfo{}, reducedErr
    	}
    
    	// List all the file commit ids from parts metadata.
    	modTimes := listObjectModtimes(partsMetadata, errs)
    
    	// Count all latest updated FileInfo values
    	var count int
    	var latestFileInfo FileInfo
    
    	// Reduce list of UUIDs to a single common value - i.e. the last updated Time
    	modTime := commonTime(modTimes, expectedRQuorum)
    
    	if modTime.IsZero() || modTime.Equal(timeSentinel) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  4. cmd/admin-router.go

    func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc {
    	// Collect all flags with bitwise-OR and assign operator
    	var handlerFlags hFlag
    	for _, flag := range flags {
    		handlerFlags |= flag
    	}
    
    	// Get name of the handler using reflection.
    	handlerName := getHandlerName(f, "adminAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		// Update request context with `logger.ReqInfo`.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/SocksProxyTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    
    class SocksProxyTest {
      @RegisterExtension
      val platform = PlatformRule()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private lateinit var server: MockWebServer
      private val socksProxy = SocksProxy()
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        socksProxy.play()
      }
    
      @AfterEach
      fun tearDown() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. cmd/etcd.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    
    	etcd "go.etcd.io/etcd/client/v3"
    )
    
    var errEtcdUnreachable = errors.New("etcd is unreachable, please check your endpoints")
    
    func etcdErrToErr(err error, etcdEndpoints []string) error {
    	if err == nil {
    		return nil
    	}
    	switch err {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. cmd/api-errors_test.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"testing"
    
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/hash"
    )
    
    var toAPIErrorTests = []struct {
    	err     error
    	errCode APIErrorCode
    }{
    	{err: hash.BadDigest{}, errCode: ErrBadDigest},
    	{err: hash.SHA256Mismatch{}, errCode: ErrContentSHA256Mismatch},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 15:13:08 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  8. internal/lock/lock.go

    // open file descriptor.
    package lock
    
    import (
    	"errors"
    	"os"
    	"sync"
    )
    
    // ErrAlreadyLocked is returned if the underlying fd is already locked.
    var ErrAlreadyLocked = errors.New("file already locked")
    
    // RLockedFile represents a read locked file, implements a special
    // closer which only closes the associated *os.File when the ref count.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. internal/config/identity/openid/rsa-sha3_contrib.go

    	// Needed for SHA3 to work - See: https://golang.org/src/crypto/crypto.go?s=1034:1288
    	_ "golang.org/x/crypto/sha3" // There is no SHA-3 FIPS-140 2 compliant implementation
    )
    
    // Specific instances for RS256 and company
    var (
    	SigningMethodRS3256 *jwt.SigningMethodRSA
    	SigningMethodRS3384 *jwt.SigningMethodRSA
    	SigningMethodRS3512 *jwt.SigningMethodRSA
    )
    
    func init() {
    	// RS3256
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  10. internal/config/policy/opa/help.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package opa
    
    import "github.com/minio/minio/internal/config"
    
    // Help template for OPA policy feature.
    var (
    	defaultHelpPostfix = func(key string) string {
    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         URL,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 23 14:45:27 UTC 2023
    - 1.6K bytes
    - Viewed (0)
Back to top