- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 47 for Marshall (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
else -> null } } fun CookieJar.receiveHeaders( url: HttpUrl, headers: Headers, ) { if (this === CookieJar.NO_COOKIES) return val cookies = Cookie.parseAll(url, headers) if (cookies.isEmpty()) return saveFromResponse(url, cookies) } /** * Returns true if the response headers and status indicate that this response has a (possibly
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/config-migrate.go
for _, cfgFile := range configFiles { if _, err = Load(cfgFile, cfg); err != nil { if !osIsNotExist(err) && !osIsPermission(err) { return nil, err } continue } data, _ = json.Marshal(cfg) break } if osIsPermission(err) { logger.Info("Older config found but is not readable %s, proceeding to read config from other places", err) } if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
icp := &xds.IstioControlPlaneInstance{ Component: "istiod", ID: istiodID, Info: istioversion.BuildInfo{ Version: "1.1", }, } identifier, _ := json.Marshal(icp) resources := make([]*anypb.Any, 0) for _, input := range configInputs { resources = append(resources, protoconv.MessageToAny(newXdsClientConfig(input))) } return &discovery.DiscoveryResponse{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/data-usage.go
func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) { attempts := 1 for dataUsageInfo := range dui { json := jsoniter.ConfigCompatibleWithStandardLibrary dataUsageJSON, err := json.Marshal(dataUsageInfo) if err != nil { scannerLogIf(ctx, err) continue } if attempts > 10 { saveConfig(ctx, objAPI, dataUsageObjNamePath+".bkp", dataUsageJSON) // Save a backup every 10th update.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/logger/target/console/console.go
func (c *Target) Send(e interface{}) error { entry, ok := e.(log.Entry) if !ok { return fmt.Errorf("Uexpected log entry structure %#v", e) } if logger.IsJSON() { logJSON, err := json.Marshal(&entry) if err != nil { return err } fmt.Fprintln(c.output, string(logJSON)) return nil } if entry.Level == logger.EventKind { fmt.Fprintln(c.output, entry.Message) return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/kms/kms.go
// as JSON. func (d DEK) MarshalText() ([]byte, error) { type JSON struct { KeyID string `json:"keyid"` Ciphertext []byte `json:"ciphertext"` } return json.Marshal(JSON{ KeyID: d.KeyID, Ciphertext: d.Ciphertext, }) } // UnmarshalText tries to decode text as JSON representation // of a DEK and sets DEK's key ID and ciphertext to the // decoded values.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/handler-utils_test.go
createExpectedRequest := func(req *http.Request, location string) *http.Request { createBucketConfig := createBucketLocationConfiguration{} createBucketConfig.Location = location createBucketConfigBytes, _ := xml.Marshal(createBucketConfig) createBucketConfigBuffer := bytes.NewReader(createBucketConfigBytes) req.Body = io.NopCloser(createBucketConfigBuffer) req.ContentLength = int64(createBucketConfigBuffer.Len()) return req }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
if o == nil { return false, nil } // Access Management Plugin Input body := make(map[string]interface{}) body["input"] = args inputBytes, err := json.Marshal(body) if err != nil { return false, err } req, err := http.NewRequest(http.MethodPost, o.args.URL.String(), bytes.NewReader(inputBytes)) if err != nil { return false, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/event/target/nsq.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}}) if err != nil { return err } return target.producer.Publish(target.args.Topic, data) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
internal/config/policy/opa/config.go
func (o *Opa) IsAllowed(args policy.Args) (bool, error) { if o == nil { return false, nil } // OPA input body := make(map[string]interface{}) body["input"] = args inputBytes, err := json.Marshal(body) if err != nil { return false, err } req, err := http.NewRequest(http.MethodPost, o.args.URL.String(), bytes.NewReader(inputBytes)) if err != nil { return false, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1)