ddl

package

v0.0.5 Latest Latest Go to latest Published: Apr 28, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/datastax/cassandra-data-apis

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AlterTableAdd(routes []graphql.Route, ksName string, tableName string, columnTypes []string)
func AlterTableDrop(routes []graphql.Route, ksName string, tableName string, columns []string)
func BuildColumnResult(columnName string, columnTypes []map[string]interface{}, ...) []interface{}
func CreateKeyspace(routes []graphql.Route, name string)
func CreateKeyspaceIfNotExists(routes []graphql.Route, name string, ifNotExists bool) schemas.ResponseBody
func CreateTable(routes []graphql.Route, ksName string, tableName string, columnTypes []string)
func CreateTableIfNotExists(routes []graphql.Route, ksName string, tableName string, columnTypes []string, ...) schemas.ResponseBody
func DropKeyspace(routes []graphql.Route, name string)
func DropTable(routes []graphql.Route, ksName string, tableName string)
func Keyspace(routes []graphql.Route, ksName string) schemas.ResponseBody
func Keyspaces(routes []graphql.Route) schemas.ResponseBody
func SortColumns(response schemas.ResponseBody)
func Table(routes []graphql.Route, ksName string, tableName string) schemas.ResponseBody
func Tables(routes []graphql.Route, ksName string) schemas.ResponseBody
func TextColumn(columnName string) map[string]interface{}
func WaitUntilColumnExists(columnName string, queryFunc func() schemas.ResponseBody) schemas.ResponseBody
func WaitUntilColumnIsGone(columnName string, queryFunc func() schemas.ResponseBody) schemas.ResponseBody
func WaitUntilExists(queryFunc func() schemas.ResponseBody) schemas.ResponseBody
func WaitUntilGone(queryFunc func() schemas.ResponseBody)

Constants ¶

This section is empty.

Variables ¶

View Source

var ColumnTypes = []string{
	"{ basic: TEXT }",
	"{ basic: ASCII }",
	"{ basic: VARCHAR }",
	"{ basic: TEXT }",
	"{ basic: BOOLEAN }",
	"{ basic: FLOAT }",
	"{ basic: DOUBLE }",
	"{ basic: TINYINT }",

	"{ basic: INT }",
	"{ basic: BIGINT }",
	"{ basic: VARINT }",
	"{ basic: DECIMAL }",
	"{ basic: UUID }",
	"{ basic: TIMEUUID }",
	"{ basic: TIME }",

	"{ basic: TIMESTAMP }",
	"{ basic: BLOB }",
	"{ basic: INET }",
	"{ basic: LIST, info: { subTypes: [ { basic: TEXT } ] } }",
	"{ basic: SET, info: { subTypes: [ { basic: TEXT } ] } }",
	"{ basic: MAP, info: { subTypes: [ { basic: TEXT }, { basic: INT } ] } }",
}

View Source

var ColumnTypesResult = []map[string]interface{}{
	{"basic": "TEXT"},
	{"basic": "ASCII"},
	{"basic": "TEXT"},
	{"basic": "TEXT"},
	{"basic": "BOOLEAN"},
	{"basic": "FLOAT"},
	{"basic": "DOUBLE"},
	{"basic": "TINYINT"},

	{"basic": "INT"},
	{"basic": "BIGINT"},
	{"basic": "VARINT"},
	{"basic": "DECIMAL"},
	{"basic": "UUID"},
	{"basic": "TIMEUUID"},
	{"basic": "TIME"},

	{"basic": "TIMESTAMP"},
	{"basic": "BLOB"},
	{"basic": "INET"},
	{"basic": "LIST", "info": map[string]interface{}{"subTypes": []interface{}{map[string]interface{}{"basic": "TEXT"}}}},
	{"basic": "SET", "info": map[string]interface{}{"subTypes": []interface{}{map[string]interface{}{"basic": "TEXT"}}}},
	{"basic": "MAP", "info": map[string]interface{}{"subTypes": []interface{}{map[string]interface{}{"basic": "TEXT"}, map[string]interface{}{"basic": "INT"}}}},
}

View Source

var DCsResult = []interface{}{
	map[string]interface{}{
		"name":     "dc1",
		"replicas": float64(3),
	},
}

Functions ¶

func AlterTableAdd ¶

func AlterTableAdd(routes []graphql.Route, ksName string, tableName string, columnTypes []string)

func AlterTableDrop ¶

func AlterTableDrop(routes []graphql.Route, ksName string, tableName string, columns []string)

func BuildColumnResult ¶

func BuildColumnResult(columnName string, columnTypes []map[string]interface{}, columns ...map[string]interface{}) []interface{}

func CreateKeyspace ¶

func CreateKeyspace(routes []graphql.Route, name string)

func CreateKeyspaceIfNotExists ¶

func CreateKeyspaceIfNotExists(routes []graphql.Route, name string, ifNotExists bool) schemas.ResponseBody

func CreateTable ¶

func CreateTable(routes []graphql.Route, ksName string, tableName string, columnTypes []string)

func CreateTableIfNotExists ¶

func CreateTableIfNotExists(routes []graphql.Route, ksName string, tableName string,
	columnTypes []string, ifNotExists bool) schemas.ResponseBody

func DropKeyspace ¶

func DropKeyspace(routes []graphql.Route, name string)

func DropTable ¶

func DropTable(routes []graphql.Route, ksName string, tableName string)

func Keyspace ¶

func Keyspace(routes []graphql.Route, ksName string) schemas.ResponseBody

func Keyspaces ¶

func Keyspaces(routes []graphql.Route) schemas.ResponseBody

func SortColumns ¶

func SortColumns(response schemas.ResponseBody)

func Table ¶

func Table(routes []graphql.Route, ksName string, tableName string) schemas.ResponseBody

func Tables ¶

func Tables(routes []graphql.Route, ksName string) schemas.ResponseBody

func TextColumn ¶

func TextColumn(columnName string) map[string]interface{}

func WaitUntilColumnExists ¶

func WaitUntilColumnExists(columnName string, queryFunc func() schemas.ResponseBody) schemas.ResponseBody

func WaitUntilColumnIsGone ¶

func WaitUntilColumnIsGone(columnName string, queryFunc func() schemas.ResponseBody) schemas.ResponseBody

func WaitUntilExists ¶

func WaitUntilExists(queryFunc func() schemas.ResponseBody) schemas.ResponseBody

func WaitUntilGone ¶

func WaitUntilGone(queryFunc func() schemas.ResponseBody)

Types ¶

This section is empty.

Source Files ¶

View all Source files

ddl.go

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