db

Documentation

Overview

Package db contains helper functions for working with Cassandra

Index

• Constants
• func IsDbConnError(err error) bool
• func NewSession(envConfig *env.EnvConfig, keyspace string, ...) (*gocql.Session, error)
• func WrapDbErrorWithQuery(msg string, query string, dbErr error) error
• type CreateKeyspaceEnumType

Constants

const ErrorPrefixDb string = "dberror:"

Functions

func IsDbConnError

func IsDbConnError(err error) bool

func NewSession

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

func WrapDbErrorWithQuery

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

Types

type CreateKeyspaceEnumType

type CreateKeyspaceEnumType int

const CreateKeyspaceOnConnect CreateKeyspaceEnumType = 1

const DoNotCreateKeyspaceOnConnect CreateKeyspaceEnumType = 0