cassandra

Documentation

Index

• func AlterColumnStatements(keyspace string, tableName string, ...) ([]string, error)
• func CreateTableStatements(keyspace string, tableName string, ...) ([]string, error)
• func CreateTypeStatement(keyspace string, typeName string, ...) (string, error)
• func DeployCassandraStatements(hosts []string, username string, password string, keyspace string, ...) error
• func InsertColumnStatement(keyspace string, tableName string, ...) (string, error)
• func PlanCassandraTable(hosts []string, username string, password string, keyspace string, ...) ([]string, error)
• func PlanCassandraType(hosts []string, username string, password string, keyspace string, ...) ([]string, error)
• func PlanCassandraView(hosts []string, username string, password string, keyspace string, ...) ([]string, error)
• type CassandraConnection
  • func Connect(hosts []string, username string, password string, keyspace string) (*CassandraConnection, error)
  • func (c *CassandraConnection) Close()

Functions

func AlterColumnStatements

func AlterColumnStatements(keyspace string, tableName string, desiredColumns []*schemasv1alpha4.CassandraColumn, existingColumn *types.Column) ([]string, error)

func CreateTableStatements

func CreateTableStatements(keyspace string, tableName string, tableSchema *schemasv1alpha4.CassandraTableSchema) ([]string, error)

func CreateTypeStatement

func CreateTypeStatement(keyspace string, typeName string, typeSchema *schemasv1alpha4.CassandraDataTypeSchema) (string, error)

func DeployCassandraStatements

func DeployCassandraStatements(hosts []string, username string, password string, keyspace string, statements []string) error

func InsertColumnStatement

func InsertColumnStatement(keyspace string, tableName string, desiredColumn *schemasv1alpha4.CassandraColumn) (string, error)

func PlanCassandraTable

func PlanCassandraTable(hosts []string, username string, password string, keyspace string, tableName string, cassandraTableSchema *schemasv1alpha4.CassandraTableSchema, seedData *schemasv1alpha4.SeedData) ([]string, error)

func PlanCassandraType

func PlanCassandraType(hosts []string, username string, password string, keyspace string, typeName string, cassandraTypeSchema *schemasv1alpha4.CassandraDataTypeSchema) ([]string, error)

func PlanCassandraView

func PlanCassandraView(hosts []string, username string, password string, keyspace string, viewName string, cassandraViewSchema *schemasv1alpha4.NotImplementedViewSchema) ([]string, error)

Types

type CassandraConnection

type CassandraConnection struct {
	// contains filtered or unexported fields
}

func Connect

func Connect(hosts []string, username string, password string, keyspace string) (*CassandraConnection, error)

func (*CassandraConnection) Close

func (c *CassandraConnection) Close()