- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 131 for headers (0.19 sec)
-
internal/http/server.go
// If server is in shutdown. if atomic.LoadUint32(&srv.inShutdown) != 0 { // To indicate disable keep-alive, server is shutting down. w.Header().Set("Connection", "close") // Add 1 minute retry header, incase-client wants to honor it w.Header().Set(RetryAfter, "60") w.WriteHeader(http.StatusServiceUnavailable) w.Write([]byte(http.ErrServerClosed.Error())) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/signature-v2_test.go
}, } for i, testCase := range testCases { t.Run(fmt.Sprintf("Case %d AuthStr \"%s\".", i+1, testCase.authString), func(t *testing.T) { req := &http.Request{ Header: make(http.Header), URL: &url.URL{}, } req.Header.Set("Authorization", testCase.authString) _, actualErrCode := validateV2AuthHeader(req) if testCase.expectedError != actualErrCode {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 8K bytes - Viewed (0) -
internal/config/browser/browser.go
const ( // browserCSPPolicy setting name for Content-Security-Policy response header value browserCSPPolicy = "csp_policy" // browserHSTSSeconds setting name for Strict-Transport-Security response header, amount of seconds for 'max-age' browserHSTSSeconds = "hsts_seconds" // browserHSTSIncludeSubdomains setting name for Strict-Transport-Security response header 'includeSubDomains' flag (true or false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/grid/grid_types_msgp_test.go
if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z testRequest) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Num" err = en.Append(0x82, 0xa3, 0x4e, 0x75, 0x6d) if err != nil { return } err = en.WriteInt(z.Num) if err != nil { err = msgp.WrapError(err, "Num") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 8.1K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
func (x *xlMetaInlineData) replace(key string, value []byte) { in := x.afterVersion() sz, buf, _ := msgp.ReadMapHeaderBytes(in) keys := make([][]byte, 0, sz+1) vals := make([][]byte, 0, sz+1) // Version plus header... plSize := 1 + msgp.MapHeaderSize replaced := false for i := uint32(0); i < sz; i++ { var found, foundVal []byte var err error found, buf, err = msgp.ReadMapKeyZC(buf) if err != nil { break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/event/target/webhook.go
// authToken as is instead of adding 'Bearer' tokens := strings.Fields(target.args.AuthToken) switch len(tokens) { case 2: req.Header.Set("Authorization", target.args.AuthToken) case 1: req.Header.Set("Authorization", "Bearer "+target.args.AuthToken) } req.Header.Set("Content-Type", "application/json") resp, err := target.httpClient.Do(req) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
values.Set("grant_type", "client_credentials") req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode())) if err != nil { return err } req.Header.Set("Content-Type", "application/x-www-form-urlencoded") resp, err := k.client.Do(req) if err != nil { return err } defer resp.Body.Close() var accessToken Token
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
docs/extensions/s3zip/examples/minio-go/main.go
Creds: credentials.NewStaticV4("access-key", "secret-key", ""), }) if err != nil { log.Fatalln(err) } var opts minio.GetObjectOptions // Add extract header to request: opts.Set("x-minio-extract", "true") // Download API.md from the archive rd, err := s3Client.GetObject(context.Background(), "your-bucket", "path/to/file.zip/data.csv", opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 14 18:04:14 GMT 2021 - 694 bytes - Viewed (0) -
internal/bucket/replication/datatypes.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package replication //go:generate msgp -file=$GOFILE // StatusType of Replication for x-amz-replication-status header type StatusType string // Type - replication type enum type Type int const ( // Pending - replication is pending. Pending StatusType = "PENDING" // Completed - replication completed ok.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/tier-journal.go
return nil } var err error jd.file, err = OpenFile(jd.JournalPath(), os.O_APPEND|os.O_CREATE|os.O_WRONLY|writeMode, 0o666) if err != nil { return err } // write journal version header if active journal is empty fi, err := jd.file.Stat() if err != nil { return err } if fi.Size() == 0 { var data [tierJournalHdrLen]byte binary.LittleEndian.PutUint16(data[:], tierJournalVersion)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0)