- Sort Score
- Result 10 results
- Languages All
Results 621 - 630 of 2,442 for okhttp (0.07 sec)
-
internal/etag/etag.go
return strconv.AppendInt(etag, n, 10) } // Set adds the ETag to the HTTP headers. It overwrites any // existing ETag entry. // // Due to legacy S3 clients, that make incorrect assumptions // about HTTP headers, Set should be used instead of // http.Header.Set(...). Otherwise, some S3 clients will not // able to extract the ETag. func Set(etag ETag, h http.Header) { // Some (broken) S3 clients expect the ETag header to
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 10 21:09:36 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/perf-tests.go
} result.Endpoint = rp.String() req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL.String(), reader) if err != nil { result.Error = err.Error() return } client := &http.Client{ Transport: globalRemoteTargetTransport, } resp, err := client.Do(req) if err != nil { result.Error = err.Error() return } defer xhttp.DrainBody(resp.Body)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// out of HTTP "chunked" format before returning it. // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies. func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.tls.internal.der import java.math.BigInteger import java.net.ProtocolException import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.ForwardingSource import okio.Source import okio.buffer /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.idn import okio.BufferedSink /** * An IDNA mapping table optimized for small code and data size. * * Code Points in Sections * ======================= * * The full range of code points is 0..0x10fffe. We can represent any of these code points with 21 * bits. *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Apr 02 11:39:58 UTC 2024 - 9K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.tls.internal.der import java.math.BigInteger import java.net.ProtocolException import java.text.ParseException import java.text.SimpleDateFormat import java.util.Date import java.util.TimeZone import kotlin.reflect.KClass import okio.ByteString /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 15K bytes - Viewed (0) -
cmd/encryption-v1.go
switch r.Method { case http.MethodGet, http.MethodHead: if crypto.S3.IsRequested(headers) || crypto.S3KMS.IsRequested(headers) { return false, errInvalidEncryptionParameters } } _, encrypted = crypto.IsEncrypted(info.UserDefined) if !encrypted && crypto.SSEC.IsRequested(headers) && r.Header.Get(xhttp.AmzCopySource) == "" { return false, errInvalidEncryptionParameters
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:06:08 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
toBeRestored := make(map[string]string) toBeRestored[xhttp.AmzRestore] = ongoingRestoreObj().String() restored := make(map[string]string) restored[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(time.Hour)).String() restoredExpired := make(map[string]string) restoredExpired[xhttp.AmzRestore] = completedRestoreObj(time.Now().UTC().Add(-time.Hour)).String()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Mar 08 17:50:48 UTC 2024 - 36.4K bytes - Viewed (0) -
cmd/erasure-object.go
userDefined["content-type"] = mimedb.TypeByExtension(path.Ext(object)) } // if storageClass is standard no need to save it as part of metadata. if userDefined[xhttp.AmzStorageClass] == storageclass.STANDARD { delete(userDefined, xhttp.AmzStorageClass) } // Fill all the necessary metadata. // Update `xl.meta` content on each disks. for index := range partsMetadata {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/iam.go
NewHTTPTransport(), xhttp.DrainBody, globalSite.Region()) if err != nil { iamLogIf(ctx, fmt.Errorf("Unable to initialize AuthNPlugin: %w", err), logger.WarningKind) } setGlobalAuthNPlugin(idplugin.New(GlobalContext, authNPluginCfg)) authZPluginCfg, err := polplugin.LookupConfig(s, GetDefaultConnSettings(), xhttp.DrainBody) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0)