Documentation ¶
Overview ¶
Package cassandra contains Cassandra-specific repository implementations.
Index ¶
- func Connect(hosts []string, keyspace string) (*gocql.Session, error)
- func Initialize(session *gocql.Session) error
- func NewChannelRepository(session *gocql.Session) manager.ChannelRepository
- func NewClientRepository(session *gocql.Session) manager.ClientRepository
- func NewUserRepository(session *gocql.Session) manager.UserRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
Initialize creates tables used by the service.
func NewChannelRepository ¶
func NewChannelRepository(session *gocql.Session) manager.ChannelRepository
NewChannelRepository instantiates Cassandra channel repository.
func NewClientRepository ¶
func NewClientRepository(session *gocql.Session) manager.ClientRepository
NewClientRepository instantiates Cassandra client repository.
func NewUserRepository ¶
func NewUserRepository(session *gocql.Session) manager.UserRepository
NewUserRepository instantiates Cassandra user repository.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.