如何在 gocql 中应用读写一致性？

Question

我正在使用https://github.com/gocql/gocql。 我想设置cassandra的读写一致性

cluster := gocql.NewCluster(hosts...)
cluster.Consistency = gocql.ParseConsistency(consistency)

如果像上面那样应用一致性设置，是否应用了读/写一致性？ 或者有没有办法单独应用读写一致性？

Answer 1

您可以设置全局一致性：

    cluster.Consistency = gocql.LocalQuorum

这将适用于读取和写入。无法使用 GoCQL 驱动程序为只读或只写配置不同的 CL。

作为替代方案，您可以使用

Consistency()

或

SetConsistency()

设置会话的一致性或仅查询。例如：

    session.Query(query, ...).Consistency(gocql.One)

有效的一致性常数是：

    Any
    One
    Two
    Three
    Quorum
    All
    LocalQuorum
    EachQuorum
    LocalOne

请注意，一般建议是在几乎所有情况下都使用本地仲裁。干杯！