mongo

Documentation

Index

• Constants
• func SnapshotRepository(ctx context.Context, aggregateConfig cqrs.AggregateConfig, opts ...Option) (cqrs.SnapshotRepository, error)
• func WithSnapshotRepositoryFactory(options ...Option) setup.Option
• type Config
• type Option
  • func ClientOptions(options ...*options.ClientOptions) Option
  • func CreateIndexes() Option
  • func Database(name string) Option
  • func URI(uri string) Option

Constants

const (
	// DefaultURI ...
	DefaultURI = "mongodb://localhost:27017"
)

Functions

func SnapshotRepository

func SnapshotRepository(ctx context.Context, aggregateConfig cqrs.AggregateConfig, opts ...Option) (cqrs.SnapshotRepository, error)

SnapshotRepository ...

func WithSnapshotRepositoryFactory

func WithSnapshotRepositoryFactory(options ...Option) setup.Option

WithSnapshotRepositoryFactory ...

Types

type Config

type Config struct {
	URI           string
	Database      string
	CreateIndexes bool
	ClientOptions []*options.ClientOptions
}

Config ...

type Option

type Option func(*Config)

Option ...

func ClientOptions

func ClientOptions(options ...*options.ClientOptions) Option

ClientOptions ...

func CreateIndexes

func CreateIndexes() Option

CreateIndexes ...

func Database

func Database(name string) Option

Database ...

func URI

func URI(uri string) Option

URI ...