db

package

v1.2.0 Latest Latest Go to latest Published: Nov 23, 2025 License: MIT Imports: 9 Imported by: 0

Details

Package db contains helper functions for working with Cassandra

View Source

const CreateKeyspaceCheckAttempts int = 24

View Source

const CreateKeyspaceCheckIntervalSeconds int = 5

View Source

const CreateTableCheckAttempts int = 24

View Source

const CreateTableCheckIntervalSeconds int = 5

View Source

const DeleteKeyspaceCheckAttempts int = 24

View Source

const DeleteKeyspaceCheckIntervalSeconds int = 5

View Source

const ErrorPrefixDb string = "dberror:"

This section is empty.

func IsDbConnError(err error) bool

func VerifyAmazonKeyspacesTablesReady(cqlSession *gocql.Session, keyspace string, tableNames []string) error

func VerifyKeyspaceDeleted(cqlSession *gocql.Session, keyspace string) error

func WrapDbErrorWithQuery(msg string, query string, dbErr error) error

type CassandraEngineType int

const (
	CassandraEngineNone CassandraEngineType = iota
	CassandraEngineCassandra
	CassandraEngineAmazonKeyspaces
)

func NewSession(envConfig *env.EnvConfig, keyspace string, createKeyspace CreateKeyspaceEnumType) (*gocql.Session, CassandraEngineType, error)

type CreateKeyspaceEnumType int

const CreateKeyspaceOnConnect CreateKeyspaceEnumType = 1

const DoNotCreateKeyspaceOnConnect CreateKeyspaceEnumType = 0