Help us shape the future of Go! Take the 2026 Go Developer Survey

config

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Feb 24, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Authenticator added in v0.6.0

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

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

type BasicAuthenticator added in v0.6.0

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"`
	LocalDC              string        `yaml:"local_dc"`
	ConnectionsPerHost   int           `validate:"min=1" yaml:"connections_per_host"`
	Timeout              time.Duration `validate:"min=500"`
	ConnectTimeout       time.Duration `yaml:"connect_timeout"`
	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"`
	DisableCompression   bool          `yaml:"disable-compression"`
	Port                 int           `yaml:"port"`
	Authenticator        Authenticator `yaml:"authenticator"`
	DisableAutoDiscovery bool          `yaml:"disable_auto_discovery"`
	EnableDependenciesV2 bool          `yaml:"enable_dependencies_v2"`
	TLS                  tlscfg.Options
}

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 added in v0.6.0

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

SessionBuilder creates new cassandra.Session

Jump to

Keyboard shortcuts

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