Versions in this module Expand all Collapse all v1 v1.1.0 Apr 24, 2019 v1.0.0 Apr 22, 2019 Changes in this version + func ConvertJSONtoBSON(document string) interface + func ObjectIDToString(oid primitive.ObjectID) string + func ObjectIDsToString(oids []interface{}) []string + type MongoDocument struct + Hostname string + Id string + Timestamp int64 + type MongoLoad struct + func (m *MongoLoad) Init(ctx context.Context, opts *MongoLoadOptions) error + func (m *MongoLoad) InsertDocument(document interface{}) (string, bool) + func (m *MongoLoad) InsertDocuments(documents []interface{}) ([]string, bool) + func (m *MongoLoad) InsertOneRoutine(docs chan interface{}, waitGroup *sync.WaitGroup) + func (m *MongoLoad) ReadDocument(id string) bson.Raw + func (m *MongoLoad) ReadOneRoutine(waitGroup *sync.WaitGroup) + type MongoLoadOptions struct + Collection string + ConnectionString string + ConnectionTimeout time.Duration + Database string + EnableJournal bool + MaxPoolSize uint16 + PrometheusRegistry *prometheus.Registry + Queue *queue.Queue + ReadPreference string + ServerConnectTimeout time.Duration + SocketTimeout time.Duration + TestDuration time.Duration + Version string + WriteAcks int
Go to main page