Version: v0.0.0-...-132f1c2 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Oct 8, 2018 License: Apache-2.0 Imports: 6 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


type Authenticator

type Authenticator struct {
	Basic BasicAuthenticator `yaml:"basic"`

Authenticator holds the authentication properties needed to connect to a Cassandra cluster

type BasicAuthenticator

type BasicAuthenticator struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`

BasicAuthenticator holds the username and password for a password authenticator for a Cassandra cluster

type Configuration

type Configuration struct {
	Servers              []string      `validate:"nonzero"`
	Keyspace             string        `validate:"nonzero"`
	ConnectionsPerHost   int           `validate:"min=1" yaml:"connections_per_host"`
	Timeout              time.Duration `validate:"min=500"`
	ReconnectInterval    time.Duration `validate:"min=500" yaml:"reconnect_interval"`
	SocketKeepAlive      time.Duration `validate:"min=0" yaml:"socket_keep_alive"`
	MaxRetryAttempts     int           `validate:"min=0" yaml:"max_retry_attempt"`
	ProtoVersion         int           `yaml:"proto_version"`
	Consistency          string        `yaml:"consistency"`
	Port                 int           `yaml:"port"`
	Authenticator        Authenticator `yaml:"authenticator"`
	DisableAutoDiscovery bool          `yaml:"disable_auto_discovery"`
	TLS                  TLS

Configuration describes the configuration properties needed to connect to a Cassandra cluster

func (*Configuration) ApplyDefaults

func (c *Configuration) ApplyDefaults(source *Configuration)

ApplyDefaults copies settings from source unless its own value is non-zero.

func (*Configuration) NewCluster

func (c *Configuration) NewCluster() *gocql.ClusterConfig

NewCluster creates a new gocql cluster from the configuration

func (*Configuration) NewSession

func (c *Configuration) NewSession() (cassandra.Session, error)

NewSession creates a new Cassandra session

func (*Configuration) String

func (c *Configuration) String() string

type SessionBuilder

type SessionBuilder interface {
	NewSession() (cassandra.Session, error)

SessionBuilder creates new cassandra.Session

type TLS

type TLS struct {
	Enabled                bool
	ServerName             string
	CertPath               string
	KeyPath                string
	CaPath                 string
	EnableHostVerification bool

TLS Config

Source Files

Jump to

Keyboard shortcuts

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