Versions in this module Expand all Collapse all v1 v1.4.3 Nov 17, 2021 v1.4.2 Nov 17, 2021 Changes in this version + type BySize []*Intent + func (s BySize) Len() int + func (s BySize) Less(i, j int) bool + func (s BySize) Swap(i, j int) + type BySizeAndView []*Intent + func (s BySizeAndView) Len() int + func (s BySizeAndView) Less(i, j int) bool + func (s BySizeAndView) Swap(i, j int) + type DBHeap []*dbCounter + func (dbh *DBHeap) Pop() interface{} + func (dbh *DBHeap) Push(x interface{}) + func (dbh DBHeap) Len() int + func (dbh DBHeap) Less(i, j int) bool + func (dbh DBHeap) Swap(i, j int) + type DestinationConflictError struct + Dst string + Src string + func (e DestinationConflictError) Error() string + type FileNeedsIOBuffer interface + ReleaseIOBuffer func() + TakeIOBuffer func([]byte) + type Intent struct + BSONFile file + BSONSize int64 + C string + DB string + Location string + MetadataFile file + MetadataLocation string + Options bson.M + Size int64 + Type string + UUID string + func (it *Intent) DataCollection() string + func (it *Intent) DataNamespace() string + func (it *Intent) HasSimpleCollation() bool + func (it *Intent) IsAuthVersion() bool + func (it *Intent) IsOplog() bool + func (it *Intent) IsRoles() bool + func (it *Intent) IsSpecialCollection() bool + func (it *Intent) IsSystemIndexes() bool + func (it *Intent) IsSystemProfile() bool + func (it *Intent) IsTimeseries() bool + func (it *Intent) IsUsers() bool + func (it *Intent) IsView() bool + func (it *Intent) MergeIntent(newIt *Intent) + func (it *Intent) Namespace() string + type IntentPrioritizer interface + Finish func(*Intent) + Get func() *Intent + type Manager struct + func NewIntentManager() *Manager + func (mgr *Manager) AuthVersion() *Intent + func (mgr *Manager) Finalize(pType PriorityType) + func (mgr *Manager) Finish(intent *Intent) + func (mgr *Manager) GetDestinationConflicts() (errs []DestinationConflictError) + func (mgr *Manager) GetOplogConflict() bool + func (mgr *Manager) HasConfigDBIntent() bool + func (mgr *Manager) IntentForNamespace(ns string) *Intent + func (mgr *Manager) Intents() []*Intent + func (mgr *Manager) NormalIntents() []*Intent + func (mgr *Manager) Oplog() *Intent + func (mgr *Manager) Peek() *Intent + func (mgr *Manager) Pop() *Intent + func (mgr *Manager) Put(intent *Intent) + func (mgr *Manager) PutOplogIntent(intent *Intent, managerKey string) + func (mgr *Manager) PutWithNamespace(ns string, intent *Intent) + func (mgr *Manager) Roles() *Intent + func (mgr *Manager) SetSmartPickOplog(smartPick bool) + func (mgr *Manager) SystemIndexDBs() []string + func (mgr *Manager) SystemIndexes(dbName string) *Intent + func (mgr *Manager) UsePrioritizer(prioritizer IntentPrioritizer) + func (mgr *Manager) Users() *Intent + type PriorityType int + const Legacy + const LongestTaskFirst + const MultiDatabaseLTF