- Sort Score
- Num 10 results
- Language All
Results 451 - 460 of 1,309 for var0 (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/streaming-v4-unsigned.go
func (cr *s3UnsignedChunkedReader) readTrailers() error { var valueBuffer bytes.Buffer // Read value for { v, err := cr.reader.ReadByte() if err != nil { if err == io.EOF { return io.ErrUnexpectedEOF } } if v != '\r' { valueBuffer.WriteByte(v) continue } // Must end with \r\n\r\n var tmp [3]byte _, err = io.ReadFull(cr.reader, tmp[:]) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Apr 03 14:55:52 GMT 2025 - 6.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.kt
import org.junit.jupiter.api.extension.RegisterExtension @Burst class SessionReuseTest { @JvmField @RegisterExtension var platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val handshakeCertificates = platform.localhostHandshakeCertificates() var client = clientTestRule.newClient() @StartStop private val server = MockWebServer() @BeforeEachCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 5.9K bytes - Click Count (1) -
internal/config/subnet/config.go
xnet "github.com/minio/pkg/v3/net" ) const ( baseURL = "https://subnet.min.io" baseURLDev = "http://localhost:9000" ) // DefaultKVS - default KV config for subnet settings var DefaultKVS = config.KVS{ config.KV{ Key: config.License, // Deprecated Dec 2021 Value: "", }, config.KV{ Key: config.APIKey, Value: "", }, config.KV{ Key: config.Proxy, Value: "",
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/jwt/parser_test.go
"fmt" "testing" "time" "github.com/golang-jwt/jwt/v4" ) var ( defaultKeyFunc = func(claim *MapClaims) ([]byte, error) { return []byte("HelloSecret"), nil } emptyKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, nil } errorKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, fmt.Errorf("error loading key") } ) var jwtTestData = []struct { name string tokenString string
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
internal/bucket/lifecycle/evaluator_test.go
import ( "fmt" "testing" "time" "github.com/google/uuid" ) func TestNewerNoncurrentVersions(t *testing.T) { prepLifecycleCfg := func(tagKeys []string, retainVersions []int) Lifecycle { var lc Lifecycle for i := range retainVersions { ruleID := fmt.Sprintf("rule-%d", i) tag := Tag{ Key: tagKeys[i], Value: "minio", } lc.Rules = append(lc.Rules, Rule{ ID: ruleID,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 08 15:41:24 GMT 2025 - 5K bytes - Click Count (0) -
api/go1.9.txt
pkg database/sql, type Out struct, In bool pkg database/sql, var ErrConnDone error pkg database/sql/driver, type NamedValueChecker interface { CheckNamedValue } pkg database/sql/driver, type NamedValueChecker interface, CheckNamedValue(*NamedValue) error pkg database/sql/driver, var ErrRemoveArgument error pkg encoding/asn1, const TagNull = 5 pkg encoding/asn1, const TagNull ideal-int pkg encoding/asn1, var NullBytes []uint8Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Click Count (0) -
cmd/update.go
return env.Get("KUBERNETES_SERVICE_HOST", "") != "" } // IsBOSH returns true if minio is deployed from a bosh package func IsBOSH() bool { // "/var/vcap/bosh" exists in BOSH deployed instance. _, err := os.Stat("/var/vcap/bosh") if osIsNotExist(err) { return false } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.9K bytes - Click Count (0) -
internal/config/bool-flag_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package config import ( "testing" ) // Test BoolFlag.String() func TestBoolFlagString(t *testing.T) { var bf BoolFlag testCases := []struct { flag BoolFlag expectedResult string }{ {bf, "off"}, {BoolFlag(true), "on"}, {BoolFlag(false), "off"}, } for _, testCase := range testCases {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.5K bytes - Click Count (0) -
cmd/handler-utils.go
// of MinIO server. func isValidLocation(location string) bool { region := globalSite.Region() return region == "" || region == location } // Supported headers that needs to be extracted. var supportedHeaders = []string{ "content-type", "cache-control", "content-language", "content-encoding", "content-disposition", "x-amz-storage-class", xhttp.AmzStorageClass, xhttp.AmzObjectTagging,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.4K bytes - Click Count (1) -
cmd/erasure-server-pool-decom.go
// add that many extra workers. workerSize += len(pool.sets) wk, err := workers.New(workerSize) if err != nil { return err } var vc *versioning.Versioning var lc *lifecycle.Lifecycle var lr objectlock.Retention var rcfg *replication.Config if bi.Name != minioMetaBucket { vc, err = globalBucketVersioningSys.Get(bi.Name) if err != nil { return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1)