|
@@ -12,6 +12,7 @@ import (
|
|
|
"log"
|
|
"log"
|
|
|
"net"
|
|
"net"
|
|
|
"runtime"
|
|
"runtime"
|
|
|
|
|
+ "strings"
|
|
|
"sync"
|
|
"sync"
|
|
|
"time"
|
|
"time"
|
|
|
)
|
|
)
|
|
@@ -179,6 +180,31 @@ func (c Consistency) String() string {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+func ParseConsistency(s string) Consistency {
|
|
|
|
|
+ switch strings.ToUpper(s) {
|
|
|
|
|
+ case "ANY":
|
|
|
|
|
+ return Any
|
|
|
|
|
+ case "ONE":
|
|
|
|
|
+ return One
|
|
|
|
|
+ case "TWO":
|
|
|
|
|
+ return Two
|
|
|
|
|
+ case "THREE":
|
|
|
|
|
+ return Three
|
|
|
|
|
+ case "QUORUM":
|
|
|
|
|
+ return Quorum
|
|
|
|
|
+ case "ALL":
|
|
|
|
|
+ return All
|
|
|
|
|
+ case "LOCAL_QUORUM":
|
|
|
|
|
+ return LocalQuorum
|
|
|
|
|
+ case "EACH_QUORUM":
|
|
|
|
|
+ return EachQuorum
|
|
|
|
|
+ case "LOCAL_ONE":
|
|
|
|
|
+ return LocalOne
|
|
|
|
|
+ default:
|
|
|
|
|
+ panic("invalid consistency: " + s)
|
|
|
|
|
+ }
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
type SerialConsistency uint16
|
|
type SerialConsistency uint16
|
|
|
|
|
|
|
|
const (
|
|
const (
|