Method makeSystemValues

proxycore/mockcluster.go:301–315

(version primitive.ProtocolVersion, address net.IP, hostID, schemaVersion *primitive.UUID)

}

func (c *MockClient) makeSystemValues(version primitive.ProtocolVersion, address net.IP, hostID, schemaVersion *primitive.UUID) map[string]message.Column {
	values := map[string]message.Column{
		"rpc_address":     encodeTypeFatal(version, datatype.Inet, address),
		"data_center":     encodeTypeFatal(version, datatype.Varchar, "dc1"),
		"rack":            encodeTypeFatal(version, datatype.Varchar, "rack1"),
		"tokens":          encodeTypeFatal(version, datatype.NewList(datatype.Varchar), []string{"0"}),
		"release_version": encodeTypeFatal(version, datatype.Varchar, "3.11.10"),
		"host_id":         encodeTypeFatal(version, datatype.Uuid, hostID),
		"schema_version":  encodeTypeFatal(version, datatype.Uuid, schemaVersion),
	}
	if len(c.server.DseVersion) > 0 {
		values["dse_version"] = encodeTypeFatal(version, datatype.Varchar, c.server.DseVersion)
	}
	return values
}

func (c *MockClient) Closing(_ error) {
	c.server.clients.Delete(c)