cassandra

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

type DBConfig struct {
	DbAddresses         []string `envconfig:"DB_ADDRESSES" required:"true"`
	DbAdminUsername     string   `envconfig:"DB_ADMIN_USERNAME" required:"true"`
	DbServiceUsername   string   `envconfig:"DB_SERVICE_USERNAME" required:"true"`
	DbName              string   `envconfig:"CASSANDRA_DB_NAME" required:"true"`
	DbReplicationFactor string   `envconfig:"DB_REPLICATION_FACTOR" required:"true"`
	DbAdminPassword     string   `envconfig:"DB_ADMIN_PASSWD" required:"true"`
	DbServicePassword   string   `envconfig:"DB_SERVICE_PASSWD" required:"true"`
}

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

type Store interface {
	Connect(dbAddrs []string, dbAdminUsername string, dbAdminPassword string) (err error)
	Close()
	CreateDbUser(serviceUsername string, servicePassword string) (err error)
	GrantPermission(serviceUsername string, dbName string) (err error)
	CreateDb(dbName string, replicationFactor string) (err error)
	CreateLockSchemaDb(replicationFactor string) (err error)
}