shared

Documentation

Index

• func AddCodeCommentToQuery(query *mgo.Query) *mgo.Query
• func LoadCaFrom(pemFile string) (*x509.CertPool, error)
• func LoadKeyPairFrom(pemFile string, privateKeyPemFile string) (tls.Certificate, error)
• func MongoSession(opts *MongoSessionOpts) *mgo.Session
• func MongoSessionNodeType(session *mgo.Session) (string, error)
• func MongoSessionServerVersion(session *mgo.Session) (string, error)
• func RedactMongoUri(uri string) string
• func TestConnection(opts MongoSessionOpts) ([]byte, error)
• type MongoSessionOpts

Functions

func AddCodeCommentToQuery

func AddCodeCommentToQuery(query *mgo.Query) *mgo.Query

AddCodeCommentToQuery adds location of the caller in the source code (e.g. "oplog_status.go:91") to the given query as a comment.

func LoadCaFrom

func LoadCaFrom(pemFile string) (*x509.CertPool, error)

func LoadKeyPairFrom

func LoadKeyPairFrom(pemFile string, privateKeyPemFile string) (tls.Certificate, error)

func MongoSession

func MongoSession(opts *MongoSessionOpts) *mgo.Session

MongoSession connects to MongoDB and returns ready to use MongoDB session.

func MongoSessionNodeType

func MongoSessionNodeType(session *mgo.Session) (string, error)

func MongoSessionServerVersion

func MongoSessionServerVersion(session *mgo.Session) (string, error)

func RedactMongoUri

func RedactMongoUri(uri string) string

func TestConnection

func TestConnection(opts MongoSessionOpts) ([]byte, error)

TestConnection connects to MongoDB and returns BuildInfo.

Types

type MongoSessionOpts

type MongoSessionOpts struct {
	URI                   string
	TLSConnection         bool
	TLSCertificateFile    string
	TLSPrivateKeyFile     string
	TLSCaFile             string
	TLSHostnameValidation bool
	PoolLimit             int
	SocketTimeout         time.Duration
	SyncTimeout           time.Duration
	AuthentificationDB    string
}