This provides a custom gocql.HostDialer
that can be used to allow gocql to connect to DataStax Astra. The goal is to
provide native support for gocql on Astra.
This library relies on the following features of gocql:
- The ability to customize connection features via the HostDialer interface
- Querying system.peers if system.peers_v2 should be used but isn't available
You must use a version of gocql which supports both of these features. Both features have been merged into master as of version 1.2.1 so any release >= 1.2.1 should work.
- Need to verify that topology/status events correctly update the driver when using Astra.
- This seems to work correctly and was tested by removing Astra coordinators
- There is a bit of weirdness around contact points. I'm just using a place holder
"0.0.0.0"
(some valid IP address) then theHostDialer
provides a host ID from the metadata service when the host ID in theHostInfo
is empty.
Using an Astra bundle:
cluster, err := gocqlastra.NewClusterFromBundle("/path/to/your/bundle.zip",
"<username>", "<password>", 10 * time.Second)
if err != nil {
panic("unable to load the bundle")
}
session, err := gocql.NewSession(*cluster)
// ...
Using an Astra token:
cluster, err = gocqlastra.NewClusterFromURL(gocqlastra.AstraAPIURL,
"<astra-database-id>", "<astra-token>", 10 * time.Second)
if err != nil {
panic("unable to load the bundle")
}
session, err := gocql.NewSession(*cluster)
// ...
Also, look at the example for more information.
cd example
go build
# Using a bundle
./example --astra-bundle /path/to/bundle.zip --username <username> --password <password>
# Using a token
./example --astra-token <astra-token> --astra-database-id <astra-database-id> \
[--astra-api-url <astra-api-url>]