cassandra

package

v3.2.0+incompatible Latest Latest Go to latest Published: Feb 21, 2018 License: MIT Imports: 8 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/basekit/migrate

Links

Open Source Insights

README ¶

Cassandra

Drop command will not work on Cassandra 2.X because it rely on system_schema table which comes with 3.X
Other commands should work properly but are not tested

Usage

cassandra://host:port/keyspace?param1=value&param2=value2

URL Query	Default value	Description
`x-migrations-table`	schema_migrations	Name of the migrations table
`port`	9042	The port to bind to
`consistency`	ALL	Migration consistency
`protocol`		Cassandra protocol version (3 or 4)
`timeout`	1 minute	Migration timeout
`username`	nil	Username to use when authenticating.
`password`	nil	Password to use when authenticating.

timeout is parsed using time.ParseDuration(s string)

Upgrading from v1

Write down the current migration version from schema_migrations
DROP TABLE schema_migrations
Download and install the latest migrate version.
Force the current migration version with migrate force <current_version>.

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNilConfig     = fmt.Errorf("no config")
	ErrNoKeyspace    = fmt.Errorf("no keyspace provided")
	ErrDatabaseDirty = fmt.Errorf("database is dirty")
)

View Source

var DefaultMigrationsTable = "schema_migrations"

Functions ¶

This section is empty.

Types ¶

type Cassandra ¶

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

func (*Cassandra) Close ¶

func (p *Cassandra) Close() error

func (*Cassandra) Drop ¶

func (p *Cassandra) Drop() error

func (*Cassandra) Lock ¶

func (p *Cassandra) Lock() error

func (*Cassandra) Open ¶

func (p *Cassandra) Open(url string) (database.Driver, error)

func (*Cassandra) Run ¶

func (p *Cassandra) Run(migration io.Reader) error

func (*Cassandra) SetVersion ¶

func (p *Cassandra) SetVersion(version int, dirty bool) error

func (*Cassandra) Unlock ¶

func (p *Cassandra) Unlock() error

func (*Cassandra) Version ¶

func (p *Cassandra) Version() (version int, dirty bool, err error)

Return current keyspace version

type Config ¶

type Config struct {
	MigrationsTable string
	KeyspaceName    string
}

Source Files ¶

View all Source files

cassandra.go

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