MCPcopy
hub / github.com/PeerDB-io/peerdb / GetRecords

Method GetRecords

flow/model/cdc_stream.go:121–123  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

119}
120
121func (r *CDCStream[T]) GetRecords() <-chan Record[T] {
122 return r.records
123}
124
125func (r *CDCStream[T]) ChannelLen() int {
126 return len(r.records)

Callers 15

AttachToCdcStreamFunction · 0.45
syncRecordsViaAvroMethod · 0.45
RecordsToRawTableStreamFunction · 0.45
syncRecordsCoreFunction · 0.45
drainMongoCDCRecordsAsyncFunction · 0.45
TestMySQLSSHKeepaliveCDCHangFunction · 0.45
TestMySQLSSHKeepaliveCDCCloseHangFunction · 0.45
TestMySQLBinlogStalenessThresholdFunction · 0.45
SyncRecordsMethod · 0.45
SyncRecordsMethod · 0.45
processBatchMethod · 0.45
SyncRecordsMethod · 0.45

Calls

no outgoing calls

Tested by 4

drainMongoCDCRecordsAsyncFunction · 0.36
TestMySQLSSHKeepaliveCDCHangFunction · 0.36
TestMySQLSSHKeepaliveCDCCloseHangFunction · 0.36
TestMySQLBinlogStalenessThresholdFunction · 0.36