cassandra

package
v0.17.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.15.0

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL