gocassa

Documentation

Index

• Constants
• func HealthCheck(keyspace gocassa.KeySpace, cfs ...string) healthcheck.Checker
• func KeySpace() gocassa.KeySpace
• func KeySpaceWithName(ks string) gocassa.KeySpace
• func MaxConnHealthCheck(maxconns int) healthcheck.Checker
• type ConnectorFunc

Constants

const (
	HealthCheckId  = "com.hailocab.service.cassandra-gocassa"
	MaxConnCheckId = "com.hailocab.service.cassandra-gocassa.maxconns"
)

Functions

func HealthCheck

func HealthCheck(keyspace gocassa.KeySpace, cfs ...string) healthcheck.Checker

HealthCheck verifies we can connect to the supplied C* keyspace, and verifies the passed column families exist

func KeySpace

func KeySpace() gocassa.KeySpace

Returns a configured keyspace for this service. The name is composed from the service name, but this is not relevant to the caller. If the name of the keyspace is important, use KeySpaceWithName.

func KeySpaceWithName

func KeySpaceWithName(ks string) gocassa.KeySpace

Do not use this unless you have already existing data in an already existing keyspace.

func MaxConnHealthCheck

func MaxConnHealthCheck(maxconns int) healthcheck.Checker

MaxConnHealthCheck asserts that the total number of established connections to all C* nodes falls below a given max threshold.

Types

type ConnectorFunc

type ConnectorFunc func(ks string) gocassa.Connection

var (
	DefaultConnector ConnectorFunc = gocqlConnector
	Connector        ConnectorFunc = DefaultConnector // Connector is the active ConnectorFunc

)