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

Interface QRepStreamCloser

flow/activities/flowable.go:56–59  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

54}
55
56type QRepStreamCloser interface {
57 HandleQRepSyncError(error)
58 Close(error)
59}
60
61func cdcIdleTimeout(value int) time.Duration {
62 if value == 0 {

Callers 7

replicateQRepPartitionFunction · 0.65
replicateXminPartitionFunction · 0.65
TestPostgresQueryCancelledErrorShouldBeNotifyConnectivityFunction · 0.65
getRuntimeInfoMethod · 0.65
CloseSlotKeepAliveMethod · 0.65
replicateQRepPartitionFunction · 0.65
replicateXminPartitionFunction · 0.65

Implementers 3

QObjectStreamflow/model/qobject_stream.go
QRecordStreamflow/model/qrecord_stream.go
PgCopyWriterflow/connectors/postgres/sink_pg.go

Calls

no outgoing calls

Tested by

no test coverage detected