Documentation ¶
Index ¶
- Variables
- func GetRecordById(db string, collection string, objectIDHex string) (map[string]interface{}, error)
- func Initialise(config ConfigurationModels.ApplicationConfiguration, ...) error
- func MongoOplogProcessor(doc *map[string]interface{}) (CommonDatabaseModels.OplogMessage, error)
- func UpdateLastOperationDetails(sender string, lastTimestamp primitive.Timestamp)
Constants ¶
This section is empty.
Variables ¶
View Source
var LastOperation CommonDatabaseModels.LastOperation
Functions ¶
func GetRecordById ¶
func Initialise ¶
func Initialise(config ConfigurationModels.ApplicationConfiguration, outputChannel *chan CommonDatabaseModels.OplogMessage, healthCheckChannel *chan CommonDatabaseModels.LastOperation) error
func MongoOplogProcessor ¶
func MongoOplogProcessor(doc *map[string]interface{}) (CommonDatabaseModels.OplogMessage, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.