Struct MongoConnector

flow/connectors/mongo/mongo.go:62–71

) (ChangeStream, error)

type MongoConnector struct {
	logger             log.Logger
	metadataStore      metadataStore
	config             *protos.MongoConfig
	client             *mongo.Client
	ssh                *utils.SSHTunnel
	createChangeStream createChangeStreamFunc
	totalBytesRead     atomic.Int64
	deltaBytesRead     atomic.Int64
}

func NewMongoConnector(ctx context.Context, config *protos.MongoConfig) (*MongoConnector, error) {
	logger := internal.LoggerFromCtx(ctx)