mongoclient

Documentation

Index

• Constants
• func Connect(log logrus.FieldLogger, config *Config) (*mongo.Client, error)
• func ConnectWithOptions(log logrus.FieldLogger, replSet string, servers []string, opts ...Option) (*mongo.Client, error)
• func LoadCAFromFiles(cafiles []string) (*x509.CertPool, error)
• func LoadCAFromValue(ca string) (*x509.CertPool, error)
• func LoadCertFromFiles(certFile, keyFile string) (tls.Certificate, error)
• func LoadCertFromValues(certPEM, keyPEM string) (tls.Certificate, error)
• type Auth
• type Config
• type Option
  • func AppName(name string) Option
  • func AuthOption(config Auth) Option
  • func ConnectionTimeout(dur time.Duration) Option
  • func SecondaryPreferred() Option
  • func TLSOption(log logrus.FieldLogger, config TLSConfig) Option
• type TLSConfig
  • func (cfg TLSConfig) TLSConfig() (*tls.Config, error)

Constants

const (
	CollectionBlobs         = "blobs"
	CollectionResellers     = "resellers"
	CollectionUsers         = "users"
	CollectionSubscriptions = "bb_subscriptions"
	CollectionSites         = "projects"
)

Functions

func Connect

func Connect(log logrus.FieldLogger, config *Config) (*mongo.Client, error)

Connect connects to MongoDB

func ConnectWithOptions

func ConnectWithOptions(log logrus.FieldLogger, replSet string, servers []string, opts ...Option) (*mongo.Client, error)

func LoadCAFromFiles

func LoadCAFromFiles(cafiles []string) (*x509.CertPool, error)

func LoadCAFromValue

func LoadCAFromValue(ca string) (*x509.CertPool, error)

func LoadCertFromFiles

func LoadCertFromFiles(certFile, keyFile string) (tls.Certificate, error)

func LoadCertFromValues

func LoadCertFromValues(certPEM, keyPEM string) (tls.Certificate, error)

Types

type Auth

type Auth struct {
	Username string
	Password string
	Source   string
}

type Config

type Config struct {
	AppName            string
	TLS                *TLSConfig
	Servers            []string
	ReplSetName        string
	ConnTimeout        time.Duration
	Auth               *Auth
	SecondaryPreferred bool
}

type Option

type Option func(opt *options.ClientOptions) error

func AppName

func AppName(name string) Option

func AuthOption

func AuthOption(config Auth) Option

func ConnectionTimeout

func ConnectionTimeout(dur time.Duration) Option

func SecondaryPreferred

func SecondaryPreferred() Option

func TLSOption

func TLSOption(log logrus.FieldLogger, config TLSConfig) Option

type TLSConfig

type TLSConfig struct {
	CAFiles  []string `mapstructure:"ca_files" envconfig:"ca_files" json:"ca_files" yaml:"ca_files"`
	KeyFile  string   `mapstructure:"key_file" split_words:"true" json:"key_file" yaml:"key_file"`
	CertFile string   `mapstructure:"cert_file" split_words:"true" json:"cert_file" yaml:"cert_file"`

	Cert string `mapstructure:"cert"`
	Key  string `mapstructure:"key"`
	CA   string `mapstructure:"ca"`

	Insecure bool `default:"false"`
	Enabled  bool `default:"false"`
}

func (TLSConfig) TLSConfig

func (cfg TLSConfig) TLSConfig() (*tls.Config, error)