aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
AgeCommit message (Expand)AuthorFilesLines
2024-04-28struct to schema correctlychrislu3-20/+152
2024-04-28compile testchrislu1-5/+5
2024-04-28recursive struct to schemachrislu2-8/+63
2024-04-27renamechrislu4-31/+31
2024-04-27renamechrislu2-22/+22
2024-04-25a little bit more efficientchrislu3-12/+14
2024-04-25minorchrislu1-1/+1
2024-04-25use parquet levels to construct rowchrislu1-28/+31
2024-04-25toRow conversion with levels infochrislu1-20/+18
2024-04-25file renamechrislu2-0/+0
2024-04-25printout test valueschrislu1-4/+8
2024-04-25add visitorchrislu2-0/+155
2024-04-24add field types but without valuechrislu1-1/+4
2024-04-24record type is also optionalchrislu1-0/+1
2024-04-24delete the generated filechrislu1-0/+4
2024-04-24add some noteschrislu1-0/+3
2024-04-24adjust testchrislu1-6/+10
2024-04-24works with single level of listchrislu4-60/+71
2024-04-24fix orderingchrislu1-1/+1
2024-04-22has a bugchrislu6-19/+317
2024-04-18all record fields are optional by defaultchrislu1-1/+4
2024-04-18add testchrislu2-9/+25
2024-04-18support list typechrislu1-10/+16
2024-04-18add schema builderchrislu2-0/+99
2024-04-17convert to parquet schema and valuechrislu3-15/+160
2024-04-15Merge branch 'master' into mq-subscribechrislu1-1/+1
2024-04-14chore: fix some typos in comments (#5497)yudrywet1-1/+1
2024-04-12publisher send schemachrislu3-0/+15
2024-04-12fix testchrislu1-13/+0
2024-04-12rename parameterchrislu3-11/+9
2024-04-12Create schema.gochrislu1-0/+32
2024-04-12save schema when configuring topicchrislu1-0/+10
2024-04-12add schema.protochrislu1-0/+98
2024-04-02refactorchrislu2-2/+2
2024-04-02comment out printlnchrislu3-11/+8
2024-04-01shutdown follower when leader stopschrislu1-6/+107
2024-04-01send flush message to follower before shutting down logBufferchrislu3-1/+33
2024-04-01renamingchrislu5-12/+12
2024-03-31purge old codechrislu1-2/+0
2024-03-31shutdown follower if no clients, not only publisherschrislu1-3/+1
2024-03-31add control message to data messagechrislu3-2/+7
2024-03-31send is_close message to brokerchrislu3-1/+20
2024-03-31add publisher name for debuggingchrislu5-10/+23
2024-03-30simplifychrislu3-17/+4
2024-03-30logschrislu2-2/+1
2024-03-27LocalPartition shutdownchrislu1-18/+18
2024-03-27simplifychrislu7-46/+23
2024-03-27change visibilitychrislu1-14/+14
2024-03-27publish and send to followerchrislu2-19/+23
2024-03-27MaybeShutdownLocalPartition refactorchrislu1-19/+19