ksql

Documentation

Index

• Variables
• type Config
• type Ksql
  • func (s *Ksql) Close() error
  • func (s *Ksql) Drop() error
  • func (s *Ksql) Lock() error
  • func (s *Ksql) Open(url string) (database.Driver, error)
  • func (s *Ksql) Run(migration io.Reader) error
  • func (s *Ksql) SetVersion(version int, dirty bool) error
  • func (s *Ksql) Unlock() error
  • func (s *Ksql) Version() (version int, dirty bool, err error)
• type MigrationResult
• type MigrationRow

Variables

var CreateMigrationStreamSQL = `` /* 201-byte string literal not displayed */

var CreateMigrationTableSQL = `` /* 195-byte string literal not displayed */

var LatestSchemaMigrationSql = `SELECT * FROM migrations WHERE rowtime = %v LIMIT 1;`

var LatestSchemaRowTimeSQL = `SELECT * FROM schema_migrations WHERE type = 'schema' LIMIT 1;`

Types

type Config

type Config struct{}

type Ksql

type Ksql struct {
	Url               string
	HttpUrl           string
	Instance          interface{}
	CurrentVersion    int
	MigrationSequence []string
	LastRunMigration  []byte // todo: make []string
	IsDirty           bool
	FirstRun          bool
	Client            *http.Client

	Config *Config
}

func (*Ksql) Close

func (s *Ksql) Close() error

func (*Ksql) Drop

func (s *Ksql) Drop() error

func (*Ksql) Lock

func (s *Ksql) Lock() error

func (*Ksql) Open

func (s *Ksql) Open(url string) (database.Driver, error)

func (*Ksql) Run

func (s *Ksql) Run(migration io.Reader) error

func (*Ksql) SetVersion

func (s *Ksql) SetVersion(version int, dirty bool) error

Adds a new record with the current migration version and it's dirty state

func (*Ksql) Unlock

func (s *Ksql) Unlock() error

func (*Ksql) Version

func (s *Ksql) Version() (version int, dirty bool, err error)

Retrieves the current version of the KSQL migration state

type MigrationResult

type MigrationResult struct {
	Row MigrationRow
}

type MigrationRow

type MigrationRow struct {
	Columns []interface{}
}