- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 70 for Marshal (0.2 sec)
-
istioctl/pkg/util/proto/messageslice.go
// limitations under the License. package proto import ( "bytes" "google.golang.org/protobuf/proto" "istio.io/istio/pkg/util/protomarshal" ) // MessageSlice allows us to marshal slices of protobuf messages like clusters/listeners/routes/endpoints correctly type MessageSlice []proto.Message // MarshalJSON handles marshaling of slices of proto messages
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Oct 19 21:53:59 GMT 2021 - 1.3K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
} payload, _ := json.Marshal(valid) addEvent, err := processAddEvent(payload) assert.NoError(t, err) assert.Equal(t, valid, addEvent) } func TestProcessAddEventBadPayload(t *testing.T) { valid := CNIPluginAddEvent{ Netns: "/var/netns/foo", PodName: "pod-bingo", PodNamespace: "funkyns", } payload, _ := json.Marshal(valid) invalid := string(payload) + "funkyjunk"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 02 08:18:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/data-scanner_test.go
NewerNoncurrentVersions: 1, }, }, }, } lcXML, err := xml.Marshal(lc) if err != nil { t.Fatalf("Failed to marshal lifecycle config: %v", err) } vcfg := versioning.Versioning{ Status: "Enabled", } vcfgXML, err := xml.Marshal(vcfg) if err != nil { t.Fatalf("Failed to marshal versioning config: %v", err) } bucket := "bucket" obj := "obj-1" now := time.Now()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/util/clusters/wrapper.go
) // Wrapper is a wrapper around the Envoy Clusters // It has extra helper functions for handling any/struct/marshal protobuf pain type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0) -
internal/bucket/lifecycle/filter_test.go
string: "doc/", set: true, Unused: struct{}{}, }, ObjectSizeGreaterThan: 100 * humanize.MiByte, ObjectSizeLessThan: 100 * humanize.GiByte, } b, err := xml.Marshal(f1) if err != nil { t.Fatalf("Failed to marshal %v", f1) } var f2 Filter err = xml.Unmarshal(b, &f2) if err != nil { t.Fatalf("Failed to unmarshal %s", string(b)) } if f1.ObjectSizeLessThan != f2.ObjectSizeLessThan {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 00:01:20 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
expiryRuleRemoved = true } } } if bucketLifecycle.HasExpiry() || expiryRuleRemoved { currtime := time.Now() bucketLifecycle.ExpiryUpdatedAt = &currtime } configData, err := xml.Marshal(bucketLifecycle) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketLifecycleConfig, configData); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 17:48:06 GMT 2023 - 7K bytes - Viewed (0) -
internal/logger/console.go
func (f fatalMsg) json(msg string, args ...interface{}) { var message string if msg != "" { message = fmt.Sprintf(msg, args...) } else { message = fmt.Sprint(args...) } logJSON, err := json.Marshal(&log.Entry{ Level: FatalKind, Message: message, Time: time.Now().UTC(), Trace: &log.Trace{Message: message, Source: []string{getSource(6)}}, }) if err != nil { panic(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
soft_delete.go
func (n DeletedAt) Value() (driver.Value, error) { if !n.Valid { return nil, nil } return n.Time, nil } func (n DeletedAt) MarshalJSON() ([]byte, error) { if n.Valid { return json.Marshal(n.Time) } return json.Marshal(nil) } func (n *DeletedAt) UnmarshalJSON(b []byte) error { if string(b) == "null" { n.Valid = false return nil } err := json.Unmarshal(b, &n.Time) if err == nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 4.5K bytes - Viewed (0) -
internal/s3select/json/record.go
case nil: columnValue = "" case RawJSON: columnValue = string([]byte(val)) case []interface{}: b, err := json.Marshal(val) if err != nil { return err } columnValue = string(b) default: return fmt.Errorf("Cannot marshal unhandled type: %T", kv.Value) } csvRecord = append(csvRecord, columnValue) } w := csv.NewWriter(writer)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 5.2K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
Description: "A replication configuration is present on this bucket, bucket wide versioning cannot be suspended.", HTTPStatusCode: http.StatusBadRequest, }, r.URL) return } configData, err := xml.Marshal(v) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0)