cassandra

package

v0.14.0 Latest Latest Go to latest Published: Jan 29, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/absmach/magistrala

Links

Open Source Insights

Documentation ¶

Overview ¶

Package cassandra contains the domain concept definitions needed to support Magistrala Cassandra database functionality.

It provides the abstraction of the Cassandra database service, which is used to configure, setup and connect to the Cassandra database.

Index ¶

func Connect(cfg Config) (*gocql.Session, error)
func InitDB(cs *gocql.Session, query string) error
func Setup(envPrefix string) (*gocql.Session, error)
func SetupDB(envPrefix, initQuery string) (*gocql.Session, error)
type Config

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Connect ¶

func Connect(cfg Config) (*gocql.Session, error)

Connect establishes connection to the Cassandra cluster.

func InitDB ¶

func InitDB(cs *gocql.Session, query string) error

func Setup ¶

func Setup(envPrefix string) (*gocql.Session, error)

Setup load configuration from environment and creates new cassandra connection.

func SetupDB ¶

func SetupDB(envPrefix, initQuery string) (*gocql.Session, error)

SetupDB load configuration from environment, creates new cassandra connection and executes the initial query in database.

Types ¶

type Config ¶

type Config struct {
	Hosts    []string `env:"CLUSTER"     envDefault:"127.0.0.1" envSeparator:","`
	Keyspace string   `env:"KEYSPACE"    envDefault:"magistrala"`
	User     string   `env:"USER"        envDefault:""`
	Pass     string   `env:"PASS"        envDefault:""`
	Port     int      `env:"PORT"        envDefault:"9042"`
}

Config contains Cassandra DB specific parameters.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL