cassandra

Documentation

Index

• Constants
• Variables
• func NewSession(p CassandraProperties) *gocql.Session
• func Use()
• type CassandraProperties
  • func BindCassandraProperties(ctx *bootstrap.ApplicationContext) CassandraProperties
  • func NewCassandraProperties() *CassandraProperties
  • func (p CassandraProperties) Hosts() []string

Constants

const (
	CassandraPropertiesPrefix = "data.cassandra"
)

Variables

var Module = &bootstrap.Module{
	Name:       "cassandra",
	Precedence: bootstrap.DatabasePrecedence,
	Options: []fx.Option{
		fx.Provide(BindCassandraProperties, NewSession),
	},
}

Functions

func NewSession

func NewSession(p CassandraProperties) *gocql.Session

func Use

func Use()

Types

type CassandraProperties

type CassandraProperties struct {
	ContactPoints string         `json:"contact-points"` // comma separated
	Port          int            `json:"port"`
	KeySpaceName  string         `json:"keyspace-name"`
	Username      string         `json:"username"`
	Password      string         `json:"password"`
	Timeout       utils.Duration `json:"timeout"`
	Consistency   string         `json:"consistency"`
}

func BindCassandraProperties

func BindCassandraProperties(ctx *bootstrap.ApplicationContext) CassandraProperties

func NewCassandraProperties

func NewCassandraProperties() *CassandraProperties

func (CassandraProperties) Hosts

func (p CassandraProperties) Hosts() []string