cassandra

Documentation

Overview

Package cassandra contains Cassandra driver for Gocrud. Testing of this package, works best via linux, unless you have cassandra tools installed on your Mac. To test this cassandra integration, run cassandra on docker $ docker pull poklet/cassandra $ docker run --detach --name cassone poklet/cassandra Now copy the contents of table_cassandra.cql to clipboard. $ docker run -it --rm --net container:cassone poklet/cassandra cqlsh Paste the cql instructions. This would generate the 'instructions' table in a 'crudtest' keyspace.

Cassandra driver can now be imported, and initialized in social.go, or any other client. import _ "github.com/aslanides/gocrud/drivers/cassandra" Initialize in main(): store.Get().Init("cassone", "crudtest", "instructions")

Index

• type Cassandra
  • func (cs *Cassandra) Commit(its []*x.Instruction) error
  • func (cs *Cassandra) GetEntity(subject string) (result []x.Instruction, rerr error)
  • func (cs *Cassandra) Init(args ...string)
  • func (cs *Cassandra) IsNew(subject string) bool
  • func (cs *Cassandra) Iterate(fromId string, num int, ch chan x.Entity) (rnum int, rlast x.Entity, rerr error)
  • func (cs *Cassandra) SetSession(session *gocql.Session)

Types

type Cassandra

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

func (*Cassandra) Commit

func (cs *Cassandra) Commit(its []*x.Instruction) error

func (*Cassandra) GetEntity

func (cs *Cassandra) GetEntity(subject string) (
	result []x.Instruction, rerr error)

func (*Cassandra) Init

func (cs *Cassandra) Init(args ...string)

func (*Cassandra) IsNew

func (cs *Cassandra) IsNew(subject string) bool

func (*Cassandra) Iterate

func (cs *Cassandra) Iterate(fromId string, num int,
	ch chan x.Entity) (rnum int, rlast x.Entity, rerr error)

func (*Cassandra) SetSession

func (cs *Cassandra) SetSession(session *gocql.Session)