cassandra

Sep 23, 2024

Changes in this version

+ var DefaultMigrationsTable = "schema_migrations"

+ var DefaultMultiStatementMaxSize = 10 * 1 << 20

+ var ErrClosedSession = errors.New("session is closed")

+ var ErrDatabaseDirty = errors.New("database is dirty")

+ var ErrNilConfig = errors.New("no config")

+ var ErrNoKeyspace = errors.New("no keyspace provided")

+ func WithInstance(session *gocql.Session, config *Config) (database.Driver, error)

+ type Cassandra struct

+ func (c *Cassandra) Close() error

+ func (c *Cassandra) Drop() error

+ func (c *Cassandra) ListAppliedVersions() ([]int, 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) SetSourceDriver(sourceDrv source.Driver) error

+ func (c *Cassandra) SetVersion(version int, dirty bool, forced bool, knownDirection *source.Direction) (*source.Direction, error)

+ func (c *Cassandra) Unlock() error

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

+ type Config struct

+ KeyspaceName string

+ MigrationsTable string

+ MultiStatementEnabled bool

+ MultiStatementMaxSize int