vadimartynov
8aae82dd71
Added context for the MasterClient's methods to avoid endless loops ( #5628 )
* Added context for the MasterClient's methods to avoid endless loops
* Returned WithClient function. Added WithClientCustomGetMaster function
* Hid unused ctx arguments
* Using a common context for the KeepConnectedToMaster and WaitUntilConnected functions
* Changed the context termination check in the tryConnectToMaster function
* Added a child context to the tryConnectToMaster function
* Added a common context for KeepConnectedToMaster and WaitUntilConnected functions in benchmark
8 months ago
chrislu
d218fe54fa
go fmt
9 months ago
chrislu
fcedf97e94
fix test
9 months ago
chrislu
664b704e30
add delay
9 months ago
chrislu
4e3701df77
reset last error
9 months ago
chrislu
30f8600a24
working
9 months ago
chrislu
7a9b115cc2
rename
9 months ago
chrislu
4a3e8869bb
subscriber can unmarshal the record
9 months ago
chrislu
1c5043baf7
rename
9 months ago
chrislu
f2f4630029
rename field types
9 months ago
chrislu
b8af997e41
consistent with protobuf data types
9 months ago
chrislu
0f35b3a4ea
add example to publish a record
9 months ago
chrislu
928a4e8dff
rename
9 months ago
chrislu
5bc1b70a4c
rename to WithField()
9 months ago
chrislu
b570e015ce
Update write_parquet_test.go
9 months ago
chrislu
5dc186ef01
record value API
9 months ago
chrislu
b166597c83
fix test
9 months ago
chrislu
189a7fc90e
record type begin and end
9 months ago
chrislu
0da1b7b0f9
improve api
9 months ago
chrislu
1a2332c257
rename api
9 months ago
chrislu
5ce8f50546
Delete schema_builder_test.go
9 months ago
chrislu
8a0e5b6d54
struct to schema correctly
9 months ago
chrislu
f37862bffe
compile test
9 months ago
chrislu
7310d022ad
recursive struct to schema
9 months ago
chrislu
a2a872ca03
rename
9 months ago
chrislu
60103171b6
rename
9 months ago
chrislu
72b50980f4
a little bit more efficient
9 months ago
chrislu
63036133ff
minor
9 months ago
chrislu
2a9b0a9332
use parquet levels to construct row
9 months ago
chrislu
977e7988e6
toRow conversion with levels info
9 months ago
chrislu
9cb9d27b5b
file rename
9 months ago
chrislu
313097aca0
printout test values
9 months ago
chrislu
827e293010
add visitor
9 months ago
chrislu
138a027a2e
add field types but without value
9 months ago
chrislu
30b5aef62e
record type is also optional
9 months ago
chrislu
ce4597c623
delete the generated file
9 months ago
chrislu
f91484ca07
add some notes
9 months ago
chrislu
f93c4cf48c
adjust test
9 months ago
chrislu
d88c1872ac
works with single level of list
9 months ago
chrislu
d7e5f6b2a5
fix ordering
9 months ago
chrislu
9ef238b610
has a bug
9 months ago
chrislu
cc1ce3de87
all record fields are optional by default
10 months ago
chrislu
384ed7a381
add test
10 months ago
chrislu
57949f9959
support list type
10 months ago
chrislu
05d18130b6
add schema builder
10 months ago
chrislu
0847a17484
convert to parquet schema and value
10 months ago
yudrywet
8833745fbc
chore: fix some typos in comments ( #5497 )
10 months ago
chrislu
68ade92d4f
publisher send schema
10 months ago
chrislu
8415476c2d
fix test
10 months ago
chrislu
5324e4288a
rename parameter
10 months ago