cassandra

Documentation

Index

• type Cassandra
  • func (d *Cassandra) Cleanup() error
  • func (d *Cassandra) ClearWork() error
  • func (d *Cassandra) GetWork() (io.Reader, error)
  • func (d *Cassandra) HandleFailure() error
  • func (d *Cassandra) Init() error
  • func (d *Cassandra) LoadEnv(prefix string) error
  • func (d *Cassandra) LoadFlags() error

Types

type Cassandra

type Cassandra struct {
	Client        *gocql.Session
	Hosts         []string
	User          string
	Password      string
	Consistency   string
	Keyspace      string
	QueryKey      *bool
	Key           *string
	RetrieveQuery *schema.SqlQuery
	ClearQuery    *schema.SqlQuery
	FailQuery     *schema.SqlQuery
}

func (*Cassandra) Cleanup

func (d *Cassandra) Cleanup() error

func (*Cassandra) ClearWork

func (d *Cassandra) ClearWork() error

func (*Cassandra) GetWork

func (d *Cassandra) GetWork() (io.Reader, error)

func (*Cassandra) HandleFailure

func (d *Cassandra) HandleFailure() error

func (*Cassandra) Init

func (d *Cassandra) Init() error

func (*Cassandra) LoadEnv

func (d *Cassandra) LoadEnv(prefix string) error

func (*Cassandra) LoadFlags

func (d *Cassandra) LoadFlags() error