- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 148 for Marshal (0.08 sec)
-
internal/config/lambda/target/webhook.go
defer func() { if err != nil { atomic.AddInt64(&target.failedRequests, 1) } }() if err = target.init(); err != nil { return nil, err } data, err := json.Marshal(eventData) if err != nil { return nil, err } req, err := http.NewRequest(http.MethodPost, target.args.Endpoint.String(), bytes.NewReader(data)) if err != nil { return nil, err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 08 21:39:49 UTC 2024 - 6.7K bytes - Viewed (0) -
tests/soft_delete_test.go
t.Errorf("Can't find permanently deleted record") } } func TestDeletedAtUnMarshal(t *testing.T) { expected := &gorm.Model{} b, _ := json.Marshal(expected) result := &gorm.Model{} _ = json.Unmarshal(b, result) if result.DeletedAt != expected.DeletedAt {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Feb 01 06:40:55 UTC 2023 - 5.7K 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) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/store/queuestore.go
return } // write - writes an item to the directory. func (store *QueueStore[I]) write(key Key, item I) error { // Marshalls the item. eventData, err := json.Marshal(item) if err != nil { return err } return store.writeBytes(key, eventData) } // writeBytes - writes bytes to the directory. func (store *QueueStore[I]) writeBytes(key Key, b []byte) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.6K bytes - Viewed (0) -
tests/embedded_struct_test.go
Content interface{} `gorm:"type:String"` } func (c Content) Value() (driver.Value, error) { // mssql driver with issue on handling null bytes https://github.com/denisenkom/go-mssqldb/issues/530, b, err := json.Marshal(c) return string(b[:]), err } func (c *Content) Scan(src interface{}) error { var value Content str, ok := src.(string) if !ok { byt, ok := src.([]byte) if !ok {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed May 08 04:07:58 UTC 2024 - 7.3K bytes - Viewed (0) -
internal/event/name.go
if err != nil { return err } *name = eventName return nil } // MarshalJSON - encodes to JSON data. func (name Name) MarshalJSON() ([]byte, error) { return json.Marshal(name.String()) } // UnmarshalJSON - decodes JSON data. func (name *Name) UnmarshalJSON(data []byte) error { var s string if err := json.Unmarshal(data, &s); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 01:11:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/xl-storage-format-v1.go
Hash string `json:"hash,omitempty"` } // MarshalJSON marshals the ChecksumInfo struct func (c ChecksumInfo) MarshalJSON() ([]byte, error) { info := checksumInfoJSON{ Name: fmt.Sprintf("part.%d", c.PartNumber), Algorithm: c.Algorithm.String(), Hash: hex.EncodeToString(c.Hash), } return json.Marshal(info) } // UnmarshalJSON - custom checksum info unmarshaller
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/s3select/select.go
s3Select.recordReader, err = parquet.NewParquetReader(rsc, &s3Select.Input.ParquetArgs) return err } return fmt.Errorf("unknown input format '%v'", s3Select.Input.format) } func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error { switch s3Select.Output.format { case csvFormat: // Use bufio Writer to prevent csv.Writer from allocating a new buffer. bufioWriter := bufioWriterPool.Get().(*bufio.Writer)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
RunE: func(cmd *cobra.Command, args []string) error { gw, err := makeGateway(false) if err != nil { return fmt.Errorf("failed to create gateway: %v", err) } b, err := yaml.Marshal(gw) if err != nil { return err } // strip junk res := strings.ReplaceAll(string(b), ` creationTimestamp: null `, "") res = strings.ReplaceAll(res, `status: {} `, "")
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 19.6K bytes - Viewed (0) -
logger/sql_test.go
return nil, nil } return json.RawMessage(j).MarshalJSON() } type ExampleStruct struct { Name string Val string } func (s ExampleStruct) Value() (driver.Value, error) { return json.Marshal(s) } func format(v []byte, escaper string) string { return escaper + strings.ReplaceAll(string(v), escaper, escaper+escaper) + escaper } func TestExplainSQL(t *testing.T) { type role string
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Mar 21 08:00:02 UTC 2024 - 8.4K bytes - Viewed (0)