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

Struct PubSubConnector

flow/connectors/pubsub/pubsub.go:27–31  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

25)
26
27type PubSubConnector struct {
28 *metadataStore.PostgresMetadata
29 client *pubsub.Client
30 logger log.Logger
31}
32
33func NewPubSubConnector(
34 ctx context.Context,

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected