diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-02 08:52:10 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-02 08:52:10 -0700 |
| commit | b8af997e41ffcc12bd7ba696b980cae58bc106cc (patch) | |
| tree | 32eee113d5ed322d7e5f4943dfa297ff001ceb56 /weed/mq/client/cmd | |
| parent | 0f35b3a4eab7785501b47239f7bf5866df672f6c (diff) | |
| download | seaweedfs-b8af997e41ffcc12bd7ba696b980cae58bc106cc.tar.xz seaweedfs-b8af997e41ffcc12bd7ba696b980cae58bc106cc.zip | |
consistent with protobuf data types
Diffstat (limited to 'weed/mq/client/cmd')
| -rw-r--r-- | weed/mq/client/cmd/weed_pub_record/publisher_record.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/weed/mq/client/cmd/weed_pub_record/publisher_record.go b/weed/mq/client/cmd/weed_pub_record/publisher_record.go index 8e8e6b21c..ca2545f88 100644 --- a/weed/mq/client/cmd/weed_pub_record/publisher_record.go +++ b/weed/mq/client/cmd/weed_pub_record/publisher_record.go @@ -73,10 +73,10 @@ func (r *MyRecord) ToRecordValue() *schema_pb.RecordValue { SetBytes("key", r.Key). SetBytes("field1", r.Field1). SetString("field2", r.Field2). - SetInt("field3", int32(r.Field3)). - SetLong("field4", r.Field4). - SetFloat("field5", r.Field5). - SetDouble("field6", r.Field6). + SetInt32("field3", int32(r.Field3)). + SetInt64("field4", r.Field4). + SetFloat32("field5", r.Field5). + SetFloat64("field6", r.Field6). SetBool("field7", r.Field7). RecordEnd() } @@ -88,10 +88,10 @@ func main() { WithField("key", schema.TypeBytes). WithField("field1", schema.TypeBytes). WithField("field2", schema.TypeString). - WithField("field3", schema.TypeInteger). - WithField("field4", schema.TypeLong). - WithField("field5", schema.TypeFloat). - WithField("field6", schema.TypeDouble). + WithField("field3", schema.TypeInt32). + WithField("field4", schema.Type64). + WithField("field5", schema.TypeFloat32). + WithField("field6", schema.TypeFloat64). WithField("field7", schema.TypeBoolean). RecordTypeEnd() |