var (
ErrNilConfig = errors.New("no config")
ErrNoKeyspace = errors.New("no keyspace provided")
ErrDatabaseDirty = errors.New("database is dirty")
ErrClosedSession = errors.New("session is closed")
)
var DefaultMigrationsTable = "schema_migrations"
var (
DefaultMultiStatementMaxSize = 10 * 1 << 20 // 10 MB
)
func WithInstance(session *gocql.Session, config *Config) (database.Driver, error)
type Cassandra struct {
// contains filtered or unexported fields
}
func (c *Cassandra) Close() error
func (c *Cassandra) Drop() error
func (c *Cassandra) Lock() error
func (c *Cassandra) Open(url string) (database.Driver, error)
func (c *Cassandra) Run(migration io.Reader) error
func (c *Cassandra) SetVersion(version int, dirty bool) error
func (c *Cassandra) Unlock() error
func (c *Cassandra) Version() (version int, dirty bool, err error)
Return current keyspace version
type Config struct {
MigrationsTable string
KeyspaceName string
MultiStatementEnabled bool
MultiStatementMaxSize int
}