()
| 471 | } |
| 472 | |
| 473 | func (p *Proxy) buildLocalRow() { |
| 474 | p.systemLocalValues = map[string]message.Column{ |
| 475 | "key": p.encodeTypeFatal(datatype.Varchar, "local"), |
| 476 | "data_center": p.encodeTypeFatal(datatype.Varchar, p.localNode.dc), |
| 477 | "rack": p.encodeTypeFatal(datatype.Varchar, "rack1"), |
| 478 | "tokens": p.encodeTypeFatal(datatype.NewList(datatype.Varchar), p.localNode.tokens), |
| 479 | "release_version": p.encodeTypeFatal(datatype.Varchar, p.cluster.Info.ReleaseVersion), |
| 480 | "partitioner": p.encodeTypeFatal(datatype.Varchar, p.cluster.Info.Partitioner), |
| 481 | "cluster_name": p.encodeTypeFatal(datatype.Varchar, "cql-proxy"), |
| 482 | "cql_version": p.encodeTypeFatal(datatype.Varchar, p.cluster.Info.CQLVersion), |
| 483 | "schema_version": p.encodeTypeFatal(datatype.Uuid, schemaVersion), // TODO: Make this match the downstream cluster(s) |
| 484 | "native_protocol_version": p.encodeTypeFatal(datatype.Varchar, p.cluster.NegotiatedVersion.String()), |
| 485 | "dse_version": p.encodeTypeFatal(datatype.Varchar, p.cluster.Info.DSEVersion), |
| 486 | } |
| 487 | } |
| 488 | |
| 489 | func (p *Proxy) encodeTypeFatal(dt datatype.DataType, val interface{}) []byte { |
| 490 | encoded, err := codecs.EncodeType(dt, p.cluster.NegotiatedVersion, val) |
no test coverage detected