MCPcopy
hub / github.com/alibaba/MongoShake / installModules

Method installModules

collector/write_controller.go:79–89  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

77}
78
79func (controller *WriteController) installModules() bool {
80 for _, m := range orderedModuleList {
81 if m.IsRegistered() {
82 if !m.Install() {
83 return false
84 }
85 controller.moduleList = append(controller.moduleList, m)
86 }
87 }
88 return true
89}
90
91func (controller *WriteController) Send(logs []*oplog.GenericOplog, tag uint32) int64 {
92 // all tunnel message which contain empty logs will be considered as

Callers 1

NewWriteControllerFunction · 0.95

Calls 2

IsRegisteredMethod · 0.65
InstallMethod · 0.65

Tested by

no test coverage detected