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
SessionBuilder creates new cassandra.Session
Click to show internal directories.
Click to hide internal directories.