Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Cassandra ¶
func Cassandra(cfg CassandraCfg) (*cas, error)
Cassandra produces a cassandra object with session
func CassandraFromCfg ¶
CassandraFromCfg takes a configuration map
func NewTokenGenerator ¶
NewTokenGenerator returns a configured tok used for generating tokens
Types ¶
type Ack ¶
type Ack struct { Version int `json:"ack_version"` Agent string `json:"agent"` Uuid string `json:"ack_uuid"` RequestUuid string `json:"req_uuid"` DateTime string `json:"date_time"` Success bool `json:"success"` ServerCode int `json:"server_code"` Location string `json:"location"` PayloadType string `json:"payload_type"` Payload interface{} `json:"payload"` Duration string `json:"duration"` // contains filtered or unexported fields }
Ack
type CasRows ¶
type CasRows []map[string]interface{}
CasRows used for simple result sets not bound to a specific type
type CassandraCfg ¶
type CassandraCfg struct { Cluster []string `yaml:"cluster"` Keyspace string `yaml:"keyspace"` Username string `yaml:"username"` Password string `yaml:"password"` NumConns int `yaml:"numConns"` }
Cassandra wrapper
type Cfg ¶
type Cfg map[interface{}]interface{}
ServiceCfg used for all service wrappers requiring configuration such as cas and tok
Click to show internal directories.
Click to hide internal directories.