cassandra

package

v0.0.0-...-7e296ea Latest Latest Go to latest Published: Jul 10, 2019 License: MIT Imports: 5 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/wbgalvao/tracking_server

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ClearDataset(session *gocql.Session, table string) error
func CreateEventTable(session *gocql.Session, keyspace, table string) error
func CreateSession(config gocql.ClusterConfig) (*gocql.Session, error)
func DropTable(session *gocql.Session, table string) error
func InsertEvent(session *gocql.Session, table string, event model.Event) error
type Cluster
- func (c Cluster) Create() gocql.ClusterConfig

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrInvalidEvent is returned by InsertEvent when there is an attempt to
	// insert an invalid model.Tracker into the database.
	ErrInvalidEvent = errors.New("cassandra: cannot insert invalid event into the database")
)

Functions ¶

func ClearDataset ¶

func ClearDataset(session *gocql.Session, table string) error

ClearDataset will truncate a given table, removing all items presented in it.

func CreateEventTable ¶

func CreateEventTable(session *gocql.Session, keyspace, table string) error

CreateTable creates a table in the Cassandra cluster which the given session created a connection with.

func CreateSession ¶

func CreateSession(config gocql.ClusterConfig) (*gocql.Session, error)

CreateSession wraps the gocql.NewSession function. It returns a *gocql.Session, which can be used to run queries in an existing Cassandra cluster.

func DropTable ¶

func DropTable(session *gocql.Session, table string) error

DropTable will execute a DROP cql expression in a given table.

func InsertEvent ¶

func InsertEvent(session *gocql.Session, table string, event model.Event) error

InsertEvent uses a given session to insert the data presented in a given event tracker into an also given table. If the event is not valid, returns an ErrInvalidEvent error.

Types ¶

type Cluster ¶

type Cluster struct {
	Hosts           string
	Keyspace        string
	ProtocolVersion int
	Timeout         int
}

Cluster defines the basic configurations for creation and management of Apache Cassandra databases clusters.

Hosts defines the addresses of Cassandra's cluster nodes
Keyspace defines the cluster keyspace (name, identification, alias...)
ProtocolVersion defines the version of Cassandra communication protocol

func (Cluster) Create ¶

func (c Cluster) Create() gocql.ClusterConfig

CreateCluster wraps the gocql.NewCluster function. It returns a *gocql.ClusterConfig which can be used to create sessions to connect to existing Cassandra clusters.

Source Files ¶

View all Source files

cassandra.go

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