cassandra

Documentation

Index

• Constants
• func NewCassandra(config Config, metricsIn metric.Measures, lc fx.Lifecycle, logger *zap.Logger) (store.S, error)
• type Client
  • func CreateCassandraClient(config Config, measures metric.Measures) (*Client, error)
  • func (s *Client) Close()
  • func (s *Client) Delete(key model.Key) (store.OwnableItem, error)
  • func (s *Client) Get(key model.Key) (store.OwnableItem, error)
  • func (s *Client) GetAll(bucket string) (map[string]store.OwnableItem, error)
  • func (s *Client) Ping() error
  • func (s *Client) Push(key model.Key, item store.OwnableItem) error
• type Config

Constants

const (
	Yugabyte = "yugabyte"
)

Functions

func NewCassandra

func NewCassandra(config Config, metricsIn metric.Measures, lc fx.Lifecycle, logger *zap.Logger) (store.S, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func CreateCassandraClient

func CreateCassandraClient(config Config, measures metric.Measures) (*Client, error)

func (*Client) Close

func (s *Client) Close()

func (*Client) Delete

func (s *Client) Delete(key model.Key) (store.OwnableItem, error)

nolint:dupl

func (*Client) Get

func (s *Client) Get(key model.Key) (store.OwnableItem, error)

nolint:dupl

func (*Client) GetAll

func (s *Client) GetAll(bucket string) (map[string]store.OwnableItem, error)

func (*Client) Ping

func (s *Client) Ping() error

Ping is for pinging the database to verify that the connection is still good.

func (*Client) Push

func (s *Client) Push(key model.Key, item store.OwnableItem) error

type Config

type Config struct {
	// Hosts to  connect to. Must have at least one
	Hosts []string

	// Database aka Keyspace for cassandra
	Database string

	// OpTimeout
	OpTimeout time.Duration

	// SSLRootCert used for enabling tls to the cluster. SSLKey, and SSLCert must also be set.
	SSLRootCert string
	// SSLKey used for enabling tls to the cluster. SSLRootCert, and SSLCert must also be set.
	SSLKey string
	// SSLCert used for enabling tls to the cluster. SSLRootCert, and SSLRootCert must also be set.
	SSLCert string
	// If you want to verify the hostname and server cert (like a wildcard for cass cluster) then you should turn this on
	// This option is basically the inverse of InSecureSkipVerify
	// See InSecureSkipVerify in http://golang.org/pkg/crypto/tls/ for more info
	EnableHostVerification bool

	// Username to authenticate into the cluster. Password must also be provided.
	Username string
	// Password to authenticate into the cluster. Username must also be provided.
	Password string

	// NumRetries for connecting to the db
	NumRetries int

	// WaitTimeMult the amount of time to wait before retrying to connect to the db
	WaitTimeMult time.Duration

	// MaxConnsPerHost max number of connections per host
	MaxConnsPerHost int
}