cassandra

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 NewMessageRepository(session *gocql.Session) writer.MessageRepository

Functions

func Connect

func Connect(hosts []string, keyspace string) (*gocql.Session, error)

Connect establishes connection to the Cassandra cluster.

func Initialize

func Initialize(session *gocql.Session) error

Initialize creates tables used by the service.

func NewMessageRepository

func NewMessageRepository(session *gocql.Session) writer.MessageRepository

NewMessageRepository instantiates Cassandra message repository.