MReader - Code Search

cmd/object-handlers.go

		// Validate the SSE-C Key set in the header.
		if _, err = crypto.SSEC.UnsealObjectKey(r.Header, objInfo.UserDefined, bucket, object); err != nil {
			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
			return
		}
		w.Header().Set(xhttp.AmzServerSideEncryptionCustomerAlgorithm, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerAlgorithm))

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri Jun 14 13:28:35 UTC 2024

- 124.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-datatypes_gen.go

func (z BaseOptions) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 0
	_ = z
	err = en.Append(0x80)
	if err != nil {
		return
	}
	return
}

// MarshalMsg implements msgp.Marshaler
func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
	o = msgp.Require(b, z.Msgsize())
	// map header, size 0
	_ = z
	o = append(o, 0x80)
	return
}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Mon Jun 10 15:51:27 UTC 2024

- 130.6K bytes

- Viewed (0)

github.com/golang/go

src/net/http/server.go

	// aren't encoded in ASCII anyway).
	return false
}

func (w *response) Header() Header {
	if w.cw.header == nil && w.wroteHeader && !w.cw.wroteHeader {
		// Accessing the header between logically writing it
		// and physically writing it means we need to allocate
		// a clone to snapshot the logically written state.
		w.cw.header = w.handlerHeader.Clone()
	}
	w.calledHeader = true
	return w.handlerHeader
}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 123.4K bytes

- Viewed (0)

github.com/golang/go

src/net/http/serve_test.go

func testServerNoHeader(t *testing.T, mode testMode, header string) {
	cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
		w.Header()[header] = nil
		io.WriteString(w, "<html>foo</html>") // non-empty
	}))
	res, err := cst.c.Get(cst.ts.URL)
	if err != nil {
		t.Fatal(err)
	}
	res.Body.Close()
	if got, ok := res.Header[header]; ok {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 202K bytes

- Viewed (0)

github.com/minio/minio

cmd/data-usage-cache_gen.go

func (z *allTierStats) MarshalMsg(b []byte) (o []byte, err error) {
	o = msgp.Require(b, z.Msgsize())
	// map header, size 1
	// string "ts"
	o = append(o, 0x81, 0xa2, 0x74, 0x73)
	o = msgp.AppendMapHeader(o, uint32(len(z.Tiers)))
	for za0001, za0002 := range z.Tiers {
		o = msgp.AppendString(o, za0001)
		// map header, size 3
		// string "ts"
		o = append(o, 0x83, 0xa2, 0x74, 0x73)
		o = msgp.AppendUint64(o, za0002.TotalSize)

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Thu Mar 21 17:21:35 UTC 2024

- 100.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CacheTest.kt

    assertThat(response1.header("Alpha")).isEqualTo("α")
    assertThat(response1.header("β")).isEqualTo("Beta")
    assertThat(response1.body.string()).isEqualTo("abcd")
    val response2 = get(server.url("/"))
    assertThat(response2.header("Alpha")).isEqualTo("α")
    assertThat(response2.header("β")).isEqualTo("Beta")
    assertThat(response2.header("Gamma")).isEqualTo("Γ")

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 108.6K bytes

- Viewed (0)

github.com/golang/go

src/net/http/transport_test.go

			},
			wantErr: `nil Request.URL`,
		},
		{
			name: "invalid header key",
			req: &Request{
				Method: "GET",
				Header: Header{"💡": {"emoji"}},
				URL:    u,
			},
			wantErr: `invalid header field name "💡"`,
		},
		{
			name: "invalid header value",
			req: &Request{
				Method: "POST",
				Header: Header{"key": {"\x19"}},
				URL:    u,
			},

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Jun 06 21:59:21 UTC 2024

- 192.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication.go

			return err
		}

		cHeader := http.Header{}
		cHeader.Add(xhttp.MinIOSourceReplicationRequest, "true")
		if !isSSEC {
			crc := getCRCMeta(objInfo, partInfo.Number, nil) // No SSE-C keys here.
			for k, v := range crc {
				cHeader.Add(k, v)
			}
		}
		popts := minio.PutObjectPartOptions{
			SSE:          opts.ServerSideEncryption,
			CustomHeader: cHeader,
		}

		if isSSEC {

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Thu Jun 13 06:56:12 UTC 2024

- 114.4K bytes

- Viewed (0)

github.com/istio/istio

tests/integration/pilot/common/routing.go

    jwksUri: "https://raw.githubusercontent.com/istio/istio/master/tests/common/jwt/jwks.json"
    outputClaimToHeaders:
    - header: "x-jwt-nested-key"
      claim: "nested.nested-2.key2"
    - header: "x-jwt-iss"
      claim: "iss"
    - header: "x-jwt-wrong-header"
      claim: "wrong_claim"
---
`
	matchers := []match.Matcher{match.And(

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Wed May 08 21:52:51 UTC 2024

- 135.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/admin-handlers.go

							r.URL.Path, w.Header().Get(xhttp.AmzRequestID),
							w.Header().Get(xhttp.AmzRequestHostID)))
					} else {
						errorRespJSON = encodeResponseJSON(APIErrorResponse{
							Code:      hr.apiErr.Code,
							Message:   hr.errBody,
							Resource:  r.URL.Path,
							RequestID: w.Header().Get(xhttp.AmzRequestID),
							HostID:    globalDeploymentID(),
						})

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 98K bytes

- Viewed (0)

Search Options