(sql string, accessType string)
| 175 | } |
| 176 | |
| 177 | func broadcast(sql string, accessType string) { |
| 178 | if !isDML(sql) { |
| 179 | return |
| 180 | } |
| 181 | |
| 182 | if accessType == "admin" { |
| 183 | p2pChans.adminPubSub.Outbound <- sql |
| 184 | logrus.Infof("Outbound admin sql: %s", sql) |
| 185 | } else { |
| 186 | // Readonly nodes don't broadcast writes |
| 187 | logrus.Infof("Readonly node attempted to broadcast write: %s", sql) |
| 188 | } |
| 189 | } |
no test coverage detected