connector

Jan 20, 2024

Changes in this version

+ var ErrCollNameMissing = errors.New("invalid option: `collName` is missing")

+ var ErrDbNameMissing = errors.New("invalid option: `dbName` is missing")

+ var ErrInvalidCollSizeInBytes = errors.New("invalid option: `collSizeInBytes` must be greater than 0")

+ var ErrInvalidDbAndCollNames = errors.New(...)

+ type CollectionOption func(*collection) error

+ func WithChangeStreamPreAndPostImages() CollectionOption

+ func WithStreamName(streamName string) CollectionOption

+ func WithTokensCollCapped(collSizeInBytes int64) CollectionOption

+ func WithTokensCollName(tokensCollName string) CollectionOption

+ func WithTokensDbName(tokensDbName string) CollectionOption

+ type Connector struct

+ func New(opts ...Option) (*Connector, error)

+ func (c *Connector) Run() error

+ type Option func(*Options) error

+ func WithCollection(dbName, collName string, opts ...CollectionOption) Option

+ func WithContext(ctx context.Context) Option

+ func WithLogLevel(logLevel string) Option

+ func WithMongoUri(mongoUri string) Option

+ func WithNatsUrl(natsUrl string) Option

+ func WithServerAddr(serverAddr string) Option

+ type Options struct