rqlite

Documentation

Index

• func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.RqliteTableIndex) string
• func BuildAlterIndexStatements(r *RqliteConnection, tableName string, ...) ([]string, error)
• func CreateTableStatements(tableName string, tableSchema *schemasv1alpha4.RqliteTableSchema) ([]string, error)
• func DeployRqliteStatements(url string, statements []string) error
• func DropColumnStatement(tableName string, existingColumn types.Column) (string, error)
• func HostnameFromURL(url string) (string, error)
• func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha4.RqliteTableColumn) (string, error)
• func PasswordFromURL(url string) (string, error)
• func PlanRQLiteView(url string, viewName string, ...) ([]string, error)
• func PlanRqliteTable(url string, tableName string, ...) ([]string, error)
• func PortFromURL(url string) (string, error)
• func RecreateTableStatements(tableName string, rqliteTableSchema *schemasv1alpha4.RqliteTableSchema) ([]string, error)
• func RemoveIndexStatement(tableName string, index *types.Index) string
• func SeedDataStatements(tableName string, seedData *schemasv1alpha4.SeedData) ([]string, error)
• func UsernameFromURL(url string) (string, error)
• type RqliteConnection
  • func Connect(url string) (*RqliteConnection, error)
  • func (s RqliteConnection) Close() error
  • func (m *RqliteConnection) DatabaseName() string
  • func (p *RqliteConnection) EngineVersion() string
  • func (r *RqliteConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)
  • func (r *RqliteConnection) GetTablePrimaryKeyColumns(tableName string) ([]string, error)
  • func (r *RqliteConnection) GetTableSchema(tableName string) ([]*types.Column, error)
  • func (r *RqliteConnection) IndexIsAConstraint(tableName string, indexName string) (bool, error)
  • func (r *RqliteConnection) ListTableForeignKeys(_ string, tableName string) ([]*types.ForeignKey, error)
  • func (r *RqliteConnection) ListTableIndexes(_ string, tableName string) ([]*types.Index, error)
  • func (r *RqliteConnection) ListTables() ([]*types.Table, error)

Functions

func AddIndexStatement

func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.RqliteTableIndex) string

func BuildAlterIndexStatements

func BuildAlterIndexStatements(r *RqliteConnection, tableName string, rqliteTableSchema *schemasv1alpha4.RqliteTableSchema) ([]string, error)

func CreateTableStatements

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

func DeployRqliteStatements

func DeployRqliteStatements(url string, statements []string) error

func DropColumnStatement

func DropColumnStatement(tableName string, existingColumn types.Column) (string, error)

func HostnameFromURL

func HostnameFromURL(url string) (string, error)

func InsertColumnStatement

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

func PasswordFromURL

func PasswordFromURL(url string) (string, error)

func PlanRQLiteView

func PlanRQLiteView(url string, viewName string, rqliteViewSchema *schemasv1alpha4.NotImplementedViewSchema) ([]string, error)

func PlanRqliteTable

func PlanRqliteTable(url string, tableName string, rqliteTableSchema *schemasv1alpha4.RqliteTableSchema, seedData *schemasv1alpha4.SeedData) ([]string, error)

func PortFromURL

func PortFromURL(url string) (string, error)

func RecreateTableStatements

func RecreateTableStatements(tableName string, rqliteTableSchema *schemasv1alpha4.RqliteTableSchema) ([]string, error)

func RemoveIndexStatement

func RemoveIndexStatement(tableName string, index *types.Index) string

func SeedDataStatements

func SeedDataStatements(tableName string, seedData *schemasv1alpha4.SeedData) ([]string, error)

func UsernameFromURL

func UsernameFromURL(url string) (string, error)

Types

type RqliteConnection

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

func Connect

func Connect(url string) (*RqliteConnection, error)

func (RqliteConnection) Close

func (s RqliteConnection) Close() error

func (*RqliteConnection) DatabaseName

func (m *RqliteConnection) DatabaseName() string

func (*RqliteConnection) EngineVersion

func (p *RqliteConnection) EngineVersion() string

func (*RqliteConnection) GetTablePrimaryKey

func (r *RqliteConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)

func (*RqliteConnection) GetTablePrimaryKeyColumns

func (r *RqliteConnection) GetTablePrimaryKeyColumns(tableName string) ([]string, error)

func (*RqliteConnection) GetTableSchema

func (r *RqliteConnection) GetTableSchema(tableName string) ([]*types.Column, error)

func (*RqliteConnection) IndexIsAConstraint

func (r *RqliteConnection) IndexIsAConstraint(tableName string, indexName string) (bool, error)

func (*RqliteConnection) ListTableForeignKeys

func (r *RqliteConnection) ListTableForeignKeys(_ string, tableName string) ([]*types.ForeignKey, error)

func (*RqliteConnection) ListTableIndexes

func (r *RqliteConnection) ListTableIndexes(_ string, tableName string) ([]*types.Index, error)

func (*RqliteConnection) ListTables

func (r *RqliteConnection) ListTables() ([]*types.Table, error)