aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/schema/schema_builder.go
AgeCommit message (Collapse)AuthorFilesLines
2024-11-04merge current message queue code changes (#6201)Chris Lu1-0/+7
* listing files to convert to parquet * write parquet files * save logs into parquet files * pass by value * compact logs into parquet format * can skip existing files * refactor * refactor * fix compilation * when no partition found * refactor * add untested parquet file read * rename package * refactor * rename files * remove unused * add merged log read func * parquet wants to know the file size * rewind by time * pass in stop ts * add stop ts * adjust log * minor * adjust log * skip .parquet files when reading message logs * skip non message files * Update subscriber_record.go * send messages * skip message data with only ts * skip non log files * update parquet-go package * ensure a valid record type * add new field to a record type * Update read_parquet_to_log.go * fix parquet file name generation * separating reading parquet and logs * add key field * add skipped logs * use in memory cache * refactor * refactor * refactor * refactor, and change compact log * refactor * rename * refactor * fix format * prefix v to version directory
2024-05-20go fmtchrislu1-3/+3
2024-05-02renamechrislu1-3/+3
2024-05-02rename field typeschrislu1-5/+5
2024-05-02consistent with protobuf data typeschrislu1-4/+4
2024-05-02rename to WithField()chrislu1-2/+2
2024-04-28record type begin and endchrislu1-4/+4
2024-04-28improve apichrislu1-18/+0
2024-04-28rename apichrislu1-13/+1
2024-04-28struct to schema correctlychrislu1-8/+12
2024-04-28recursive struct to schemachrislu1-8/+8
2024-04-27renamechrislu1-9/+9
2024-04-24fix orderingchrislu1-1/+1
2024-04-22has a bugchrislu1-0/+5
2024-04-18add schema builderchrislu1-0/+73