scylla

Documentation

Index

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

Types

type Scylla

type Scylla struct {
	Client        *gocql.Session
	Hosts         []string
	User          string
	Password      string
	Consistency   string
	LocalDC       *string
	Keyspace      string
	RetrieveField *string
	RetrieveQuery *schema.SqlQuery
	ClearQuery    *schema.SqlQuery
	FailQuery     *schema.SqlQuery
	// contains filtered or unexported fields
}

func (*Scylla) Cleanup

func (d *Scylla) Cleanup() error

func (*Scylla) ClearWork

func (d *Scylla) ClearWork() error

func (*Scylla) GetWork

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

func (*Scylla) HandleFailure

func (d *Scylla) HandleFailure() error

func (*Scylla) Init

func (d *Scylla) Init() error

func (*Scylla) LoadEnv

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

func (*Scylla) LoadFlags

func (d *Scylla) LoadFlags() error