Documentation ¶
Index ¶
- func CreatedDatabase(log logging.Logger) (err error)
- type CassandraAdmin
- func (c *CassandraAdmin) Close()
- func (c *CassandraAdmin) CreateDb(dbName string, replicationFactor string) (err error)
- func (c *CassandraAdmin) CreateDbUser(serviceUsername string, servicePassword string) (err error)
- func (c *CassandraAdmin) CreateLockSchemaDb(replicationFactor string) (err error)
- func (c *CassandraAdmin) GrantPermission(serviceUsername string, dbName string) (err error)
- func (c *CassandraAdmin) Session() *gocql.Session
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreatedDatabase ¶
Types ¶
type CassandraAdmin ¶
type CassandraAdmin struct {
// contains filtered or unexported fields
}
func NewCassandraAdmin ¶
func (*CassandraAdmin) Close ¶
func (c *CassandraAdmin) Close()
func (*CassandraAdmin) CreateDb ¶
func (c *CassandraAdmin) CreateDb(dbName string, replicationFactor string) (err error)
func (*CassandraAdmin) CreateDbUser ¶
func (c *CassandraAdmin) CreateDbUser(serviceUsername string, servicePassword string) (err error)
func (*CassandraAdmin) CreateLockSchemaDb ¶
func (c *CassandraAdmin) CreateLockSchemaDb(replicationFactor string) (err error)
func (*CassandraAdmin) GrantPermission ¶
func (c *CassandraAdmin) GrantPermission(serviceUsername string, dbName string) (err error)
func (*CassandraAdmin) Session ¶
func (c *CassandraAdmin) Session() *gocql.Session
type Config ¶
type Config struct { DBAddresses []string `envconfig:"DB_ADDRESSES" required:"true"` DBAdminCredIdentifier string `envconfig:"DB_ADMIN_CRED_IDENTIFIER" default:"cassandra-admin"` DBReplicationFactor string `envconfig:"DB_REPLICATION_FACTOR" required:"true" default:"1"` EntityName string `envconfig:"DB_ENTITY_NAME" required:"true"` DBName string `envconfig:"DB_NAME" required:"true"` DBServiceUsername string `envconfig:"DB_SERVICE_USERNAME" required:"true"` }
Click to show internal directories.
Click to hide internal directories.