orgs

Documentation

Index

• func DumpAnalyticzCollections(uri *options.URI, org string, colls []string) error
• func FastFilteredCollections(uri *options.URI, queryField string, queryValue string, colls []string) error
• func ParseMongoURI(url string) (*options.URI, error)
• func RedisClient(ctx context.Context, addrs []string, masterName string, batchSize int64, ...) redisClient
• func RestoreCollections(dir string, uri *options.URI, dryRun bool) []mongorestore.Result
• func SlowFilteredCollections(uri *options.URI, queryField string, queryValue string, colls []string) error

Functions

func DumpAnalyticzCollections

func DumpAnalyticzCollections(uri *options.URI, org string, colls []string) error

func FastFilteredCollections

func FastFilteredCollections(uri *options.URI, queryField string, queryValue string, colls []string) error

FastFilteredCollections dumps collections concurrently

func ParseMongoURI

func ParseMongoURI(url string) (*options.URI, error)

ParseMongoURI can parse URLs like mongodb:///...

func RedisClient

func RedisClient(ctx context.Context, addrs []string, masterName string, batchSize int64, orgs []string, dir string) redisClient

func RestoreCollections

func RestoreCollections(dir string, uri *options.URI, dryRun bool) []mongorestore.Result

RestoreCollections will restore all the collections in dir

func SlowFilteredCollections

func SlowFilteredCollections(uri *options.URI, queryField string, queryValue string, colls []string) error

SlowFilteredCollections dumps collections sequentially