| 25 | ) |
| 26 | |
| 27 | type PubSubConnector struct { |
| 28 | *metadataStore.PostgresMetadata |
| 29 | client *pubsub.Client |
| 30 | logger log.Logger |
| 31 | } |
| 32 | |
| 33 | func NewPubSubConnector( |
| 34 | ctx context.Context, |
nothing calls this directly
no outgoing calls
no test coverage detected