Documentation ¶
Index ¶
- Constants
- func CreateSession(cfg config.Cassandra) (*gocql.Session, error)
- func NewCassandraCluster(cfg config.Cassandra) *gocql.ClusterConfig
- func NewCassandraDB(cfg config.Cassandra) (nosqlplugin.DB, error)
- func NewCassandraDBFromSession(session *gocql.Session) nosqlplugin.DB
- func RegionHostFilter(region string) gocql.HostFilter
Constants ¶
View Source
const (
// PluginName is the name of the plugin
PluginName = "cassandra"
)
Variables ¶
This section is empty.
Functions ¶
func CreateSession ¶
CreateSession creates a new session TODO this will be converted to private later, after all cassandra code moved to plugin pkg
func NewCassandraCluster ¶
func NewCassandraCluster(cfg config.Cassandra) *gocql.ClusterConfig
NewCassandraCluster creates a cassandra cluster from a given configuration
func NewCassandraDB ¶
func NewCassandraDB(cfg config.Cassandra) (nosqlplugin.DB, error)
NewCassandraDB return a new DB
func NewCassandraDBFromSession ¶
func NewCassandraDBFromSession(session *gocql.Session) nosqlplugin.DB
NewCassandraDBFromSession returns a DB from a session
func RegionHostFilter ¶
func RegionHostFilter(region string) gocql.HostFilter
RegionHostFilter returns a gocql host filter for the given region name
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.