database

Documentation

Index

• func InitSchema(session *gocql.Session) error
• type Config
  • func NewConfig() *Config
  • func (c *Config) WithHosts(hosts []string) *Config
  • func (c *Config) WithKeyspace(keyspace string) *Config
• type Connection
  • func NewConnection(config *Config) (*Connection, error)
  • func (c *Connection) Close()
  • func (c *Connection) Session() *gocql.Session

Functions

func InitSchema

func InitSchema(session *gocql.Session) error

Types

type Config

type Config struct {
	Hosts       []string
	Keyspace    string
	Timeout     time.Duration
	Retries     int
	ConnectWait time.Duration
}

func NewConfig

func NewConfig() *Config

func (*Config) WithHosts

func (c *Config) WithHosts(hosts []string) *Config

func (*Config) WithKeyspace

func (c *Config) WithKeyspace(keyspace string) *Config

type Connection

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

func NewConnection

func NewConnection(config *Config) (*Connection, error)

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Session

func (c *Connection) Session() *gocql.Session