mongodb

Documentation

Index

• func SetDefaultTimeout(t time.Duration)
• type BackupInputMongodb
  • func (m *BackupInputMongodb) Close() error
  • func (m *BackupInputMongodb) GetConfig() interface{}
  • func (m *BackupInputMongodb) GetGroup() core.ModuleGroup
  • func (m *BackupInputMongodb) GetName() string
  • func (m *BackupInputMongodb) GetType() core.ModuleType
  • func (m *BackupInputMongodb) InitModule(cfg interface{}) error
  • func (m *BackupInputMongodb) InitPipe(w io.Writer, r io.Reader) error
  • func (m *BackupInputMongodb) Run(ctx context.Context) error
• type MongoConfig

Functions

func SetDefaultTimeout

func SetDefaultTimeout(t time.Duration)

SetDefaultTimeout sets default timeout used for operations

Types

type BackupInputMongodb

type BackupInputMongodb struct {
	core.Module
	// contains filtered or unexported fields
}

BackupInputMongodb represents struct for dumping mongo

func (*BackupInputMongodb) Close

func (m *BackupInputMongodb) Close() error

Close disconnects from the server

func (*BackupInputMongodb) GetConfig

func (m *BackupInputMongodb) GetConfig() interface{}

GetConfig returns config

func (*BackupInputMongodb) GetGroup

func (m *BackupInputMongodb) GetGroup() core.ModuleGroup

GetGroup returns group

func (*BackupInputMongodb) GetName

func (m *BackupInputMongodb) GetName() string

GetName returns name

func (*BackupInputMongodb) GetType

func (m *BackupInputMongodb) GetType() core.ModuleType

GetType returns type

func (*BackupInputMongodb) InitModule

func (m *BackupInputMongodb) InitModule(cfg interface{}) error

InitModule initializes module

func (*BackupInputMongodb) InitPipe

func (m *BackupInputMongodb) InitPipe(w io.Writer, r io.Reader) error

InitPipe initializes pipes

func (*BackupInputMongodb) Run

func (m *BackupInputMongodb) Run(ctx context.Context) error

Run runs module

type MongoConfig

type MongoConfig struct {
	DSN string
}

MongoConfig represents configuration for mongo backup