cassandra

Documentation

Index

• Constants
• func WithConsistency(consistency gocql.Consistency) func(*gocql.ClusterConfig)
• func WithKeySpace(ks string) func(*gocql.ClusterConfig)
• type Client
  • func New(host string, port int, opts ...func(*gocql.ClusterConfig)) (*Client, error)
  • func (c Client) Close()
  • func (c Client) InsertEvent(ctx context.Context, query string, args ...interface{}) error

Constants

const (
	InsertFunnelChange = `
		INSERT INTO users_per_stage_by_date(
			app,
			date,
			stage,
			user
		) values(?,?,?,?)
	`
	UpsertAvgTimeStage = `
		UPDATE avg_time_per_stage 
			SET elapsed = elapsed + ?, hit = hit+1
		WHERE app = ? and stage = ?
	`
	UpsertPageHit = `` /* 141-byte string literal not displayed */

	UpsertInterestingBtn = `` /* 252-byte string literal not displayed */

	InsertSession = `
		INSERT INTO session(
			app,
			date,
			user,
			start,
			duration,
			referrer
		) values(?,?,?,?,?,?)
	`

	InsertBatchStart = `` /* 262-byte string literal not displayed */

)

Functions

func WithConsistency

func WithConsistency(consistency gocql.Consistency) func(*gocql.ClusterConfig)

func WithKeySpace

func WithKeySpace(ks string) func(*gocql.ClusterConfig)

Types

type Client

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

func New

func New(host string, port int, opts ...func(*gocql.ClusterConfig)) (*Client, error)

func (Client) Close

func (c Client) Close()

func (Client) InsertEvent

func (c Client) InsertEvent(ctx context.Context, query string, args ...interface{}) error