Documentation ¶
Index ¶
- func CreateKeyspace(contactPoint string, port int, keyspace string) error
- func TryToConnectWithRetry(contactPoint string, port int, attempts int, timeout time.Duration) error
- type Scylla
- func (s *Scylla) CheckIfTableExits(tableName string) bool
- func (s *Scylla) Close()
- func (s *Scylla) CreateTable(tablename, schema string) error
- func (s *Scylla) CreateTablePath(tableName string, prefix string) string
- func (s *Scylla) Delete(metaTable *table.Table, model interface{}) error
- func (s *Scylla) GetAll(metaTable *table.Table) *gocqlx.Queryx
- func (s *Scylla) GetByKeys(metaTable *table.Table, model interface{}) *gocqlx.Queryx
- func (s *Scylla) Insert(metaTable *table.Table, model interface{}) error
- func (s *Scylla) NewTable(schema table.Metadata) *table.Table
- func (s *Scylla) Update(metaTable *table.Table, model interface{}, columns ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Scylla ¶
func NewScyllaDbWithPool ¶
func (*Scylla) CheckIfTableExits ¶
func (*Scylla) CreateTable ¶
func (*Scylla) CreateTablePath ¶
Click to show internal directories.
Click to hide internal directories.