scyllarepo

Documentation

Index

• type DB
  • func New(scylladbConfig scylladb.Config) (*DB, error)
  • func (d *DB) GetConn() scylladb.SessionxInterface
  • func (d *DB) GetStatement(state Statement) (gocqlx.Queryx, error)
  • func (d *DB) RegisterStatement(states ...Statement)
  • func (d *DB) RegisterStatements(states map[string]Statement)
• type Statement

Types

type DB

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

func New

func New(scylladbConfig scylladb.Config) (*DB, error)

func (*DB) GetConn

func (d *DB) GetConn() scylladb.SessionxInterface

func (*DB) GetStatement

func (d *DB) GetStatement(state Statement) (gocqlx.Queryx, error)

func (*DB) RegisterStatement

func (d *DB) RegisterStatement(states ...Statement)

func (*DB) RegisterStatements

func (d *DB) RegisterStatements(states map[string]Statement)

type Statement

type Statement struct {
	Query  string
	Values []string
}