cassandra

README

Manage Cassandra schema

Documentation

Index

• func CreateKeyspace(c *gocql.ClusterConfig, ks string, rs string, rf int) error
• func CreateKeyspaceWithNetworkTopologyStrategy(c *gocql.ClusterConfig, ks string, rfmap map[string]uint) error
• func CreateRequiredTables(c *gocql.ClusterConfig, rt []CTable) error
• func CreateRequiredTypes(c *gocql.ClusterConfig, rt []UDT) error
• func CreateTable(c *gocql.ClusterConfig, t CTable) error
• func CreateUDT(c *gocql.ClusterConfig, u UDT) error
• func DropKeyspace(c *gocql.ClusterConfig, ks string) error
• func GetKeyspaces(c *gocql.ClusterConfig) ([]string, error)
• func GetTables(c *gocql.ClusterConfig) ([]string, error)
• type CTable
• type UDT

Functions

func CreateKeyspace

func CreateKeyspace(c *gocql.ClusterConfig, ks string, rs string, rf int) error

CreateKeyspace creates a keyspace if necessary ks -> keyspace name rs -> replication strategy class rf -> replication factor

func CreateKeyspaceWithNetworkTopologyStrategy

func CreateKeyspaceWithNetworkTopologyStrategy(c *gocql.ClusterConfig, ks string, rfmap map[string]uint) error

CreateKeyspaceWithNetworkTopologyStrategy creates a keyspace if necesary with NetworkTopologyStrategy ks -> keyspace name rfmap -> map of datacenter name to replication factor for that DC

func CreateRequiredTables

func CreateRequiredTables(c *gocql.ClusterConfig, rt []CTable) error

CreateRequiredTables ensures all the tables passed in are created if necessary

func CreateRequiredTypes

func CreateRequiredTypes(c *gocql.ClusterConfig, rt []UDT) error

CreateRequiredTypes ensures all the types passed in are created if necessary

func CreateTable

func CreateTable(c *gocql.ClusterConfig, t CTable) error

CreateTable creates a table

func CreateUDT

func CreateUDT(c *gocql.ClusterConfig, u UDT) error

CreateUDT creates a user-defined type

func DropKeyspace

func DropKeyspace(c *gocql.ClusterConfig, ks string) error

DropKeyspace deletes a keyspace and all data associated with it

func GetKeyspaces

func GetKeyspaces(c *gocql.ClusterConfig) ([]string, error)

GetKeyspaces returns all extant keyspaces

func GetTables

func GetTables(c *gocql.ClusterConfig) ([]string, error)

GetTables returns all tables in configured keyspace

Types

type CTable

type CTable struct {
	Name    string
	Columns []string
	Options string
}

CTable is a Cassandra table definition

type UDT

type UDT struct {
	Name    string
	Columns []string
}

UDT is a user-defined type