shared

Documentation

Index

• func GetCallerLocation() string
• func LoadCaFrom(pemFile string) (*x509.CertPool, error)
• func LoadKeyPairFrom(pemFile string, privateKeyPemFile string) (tls.Certificate, error)
• func MongoClient(opts *MongoSessionOpts) *mongo.Client
• func MongoServerVersionLessThan(version string, client *mongo.Client) bool
• func MongoSessionNodeType(client *mongo.Client) (string, error)
• func MongoSessionServerVersion(client *mongo.Client) (string, error)
• func RedactMongoUri(uri string) string
• func TestConnection(opts MongoSessionOpts) ([]byte, error)
• type BuildInfo
  • func GetBuildInfo(client *mongo.Client) (info BuildInfo, err error)
• type MongoSessionOpts
• type SyncStringSet
  • func NewSyncStringSet() *SyncStringSet
  • func (l *SyncStringSet) Add(s string)
  • func (l *SyncStringSet) Contains(s string) bool
  • func (l *SyncStringSet) Delete(s string)
  • func (l *SyncStringSet) GetAll() []string

Functions

func GetCallerLocation

func GetCallerLocation() string

GetCallerLocation gets location of the caller in the source code (e.g. "oplog_status.go:91").

func LoadCaFrom

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

func LoadKeyPairFrom

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

func MongoClient

func MongoClient(opts *MongoSessionOpts) *mongo.Client

MongoClient connects to MongoDB and returns ready to use MongoDB client.

func MongoServerVersionLessThan

func MongoServerVersionLessThan(version string, client *mongo.Client) bool

func MongoSessionNodeType

func MongoSessionNodeType(client *mongo.Client) (string, error)

MongoSessionNodeType returns mongo node type.

func MongoSessionServerVersion

func MongoSessionServerVersion(client *mongo.Client) (string, error)

MongoSessionServerVersion returns mongo server version.

func RedactMongoUri

func RedactMongoUri(uri string) string

RedactMongoUri removes login and password from mongoUri.

func TestConnection

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

TestConnection connects to MongoDB and returns BuildInfo.

Types

type BuildInfo

type BuildInfo struct {
	Version        string
	VersionArray   []int  `bson:"versionArray"` // On MongoDB 2.0+; assembled from Version otherwise
	GitVersion     string `bson:"gitVersion"`
	OpenSSLVersion string `bson:"OpenSSLVersion"`
	SysInfo        string `bson:"sysInfo"` // Deprecated and empty on MongoDB 3.2+.
	Bits           int
	Debug          bool
	MaxObjectSize  int `bson:"maxBsonObjectSize"`
}

BuildInfo represents mongodb build info.

func GetBuildInfo

func GetBuildInfo(client *mongo.Client) (info BuildInfo, err error)

GetBuildInfo gets mongo build info.

type MongoSessionOpts

type MongoSessionOpts struct {
	URI string
}

type SyncStringSet

type SyncStringSet struct {
	// contains filtered or unexported fields
}

String set synchronized with sync.RWMutex

func NewSyncStringSet

func NewSyncStringSet() *SyncStringSet

NewSyncStringSet returns new SyncStringSet

func (*SyncStringSet) Add

func (l *SyncStringSet) Add(s string)

Add the value to the set.

func (*SyncStringSet) Contains

func (l *SyncStringSet) Contains(s string) bool

Contains check whether set contains the value

func (*SyncStringSet) Delete

func (l *SyncStringSet) Delete(s string)

Delete value from the set

func (*SyncStringSet) GetAll

func (l *SyncStringSet) GetAll() []string

GetAll returns slice of all values stored in the set