gocassa

package

v0.0.0-...-cbea63e Latest Latest Go to latest Published: Dec 4, 2021 License: Apache-2.0 Imports: 22 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/hailo-platform/h2o

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

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

)

Source Files ¶

View all Source files

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