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

Method Close

flow/connectors/core.go:32–32  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

30
31type Connector interface {
32 Close() error
33 ConnectionActive(context.Context) error
34}
35

Callers 15

mainFunction · 0.65
AttachToCdcStreamFunction · 0.65
ReadFileToBytesFunction · 0.65
TestMongoDBAvroSizeComputationFunction · 0.65
runSizeSubtestFunction · 0.65
writeAvroFileCompressedFunction · 0.65
getActualUncompressedSizeFunction · 0.65
GetDestinationTableSchemaFunction · 0.65
GetCollectionNamesFunction · 0.65
CheckIfTablesEmptyAndEngineFunction · 0.65
storeColumnInfoForTableFunction · 0.65
TestNewS3StagingValidator_HappyPathFunction · 0.65

Implementers 11

BigQueryConnectorflow/connectors/bigquery/bigquery.go
PostgresConnectorflow/connectors/postgres/postgres.go
MongoConnectorflow/connectors/mongo/mongo.go
MySqlConnectorflow/connectors/mysql/mysql.go
S3Connectorflow/connectors/s3/s3.go
KafkaConnectorflow/connectors/kafka/kafka.go
EventHubConnectorflow/connectors/eventhub/eventhub.go
PubSubConnectorflow/connectors/pubsub/pubsub.go
ClickHouseConnectorflow/connectors/clickhouse/clickhouse.
ElasticsearchConnectorflow/connectors/elasticsearch/elastics
SnowflakeConnectorflow/connectors/snowflake/snowflake.go

Calls

no outgoing calls

Tested by 15

TestMongoDBAvroSizeComputationFunction · 0.52
runSizeSubtestFunction · 0.52
writeAvroFileCompressedFunction · 0.52
getActualUncompressedSizeFunction · 0.52
TestNewS3StagingValidator_HappyPathFunction · 0.52
TestNewS3StagingValidator_PutFailureFunction · 0.52
TestNewS3StagingValidator_DeleteFailureFunction · 0.52
TestNewS3StagingValidator_EmptyPrefixFunction · 0.52
newFakeGCSClientFunction · 0.52
TestNewGCSStagingValidator_HappyPathFunction · 0.52
TestNewGCSStagingValidator_UploadFailureFunction · 0.52
TestNewGCSStagingValidator_DeleteFailureFunction · 0.52