cassandra

package

v1.0.0 Latest Latest Go to latest Published: Nov 24, 2023 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	ClusterHosts []string
	// Keyspace to be used when doing I/O to cassandra.
	Keyspace string
}

type Connection struct {
	Session *gocql.Session
	Config
}

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

GetConnection will create(& return) a new Connection to Cassandra if there is not one yet, otherwise, will just return existing singleton connection.

type TransactionSession struct {
	TransactionID *btree.UUID
	Started       *bool
}

func (trans *TransactionSession) Begin() error

func (trans *TransactionSession) CommitPhase1() error

CommitPhase1 commits all changes to each Btree modified during transaction.

func (trans *TransactionSession) CommitPhase2() error

CommitPhase2 finalize commits of each Btree modified during transaction.

func (trans *TransactionSession) Rollback() error

Rollback undoes any changes done to each Btree modified during transaction.

Path	Synopsis
btree