(version primitive.ProtocolVersion, schemaVersion *primitive.UUID)
| 281 | } |
| 282 | |
| 283 | func (c *MockClient) makeSystemLocalValues(version primitive.ProtocolVersion, schemaVersion *primitive.UUID) map[string]message.Column { |
| 284 | ip := net.ParseIP(c.server.local.IP) |
| 285 | values := c.makeSystemValues(version, ip, c.server.local.HostID, schemaVersion) |
| 286 | values["key"] = encodeTypeFatal(version, datatype.Varchar, "local") |
| 287 | values["partitioner"] = encodeTypeFatal(version, datatype.Varchar, "") |
| 288 | values["cluster_name"] = encodeTypeFatal(version, datatype.Varchar, "cql-proxy") |
| 289 | values["cql_version"] = encodeTypeFatal(version, datatype.Varchar, "3.4.5") |
| 290 | values["native_protocol_version"] = encodeTypeFatal(version, datatype.Varchar, version.String()) |
| 291 | return values |
| 292 | } |
| 293 | |
| 294 | func (c *MockClient) makeSystemPeerValues(version primitive.ProtocolVersion, address string, hostID, schemaVersion *primitive.UUID) map[string]message.Column { |
| 295 | ip := net.ParseIP(address) |
no test coverage detected