api

Documentation

Index

• func DropKeyspace(logger *l.Logger, cqlSession *gocql.Session, keyspace string) error
• func GetBatchHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16, ...) ([]*wfmodel.BatchHistory, error)
• func GetNodeHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16) ([]*wfmodel.NodeHistory, error)
• func GetRunHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string) ([]*wfmodel.RunHistory, error)
• func GetTablesCql(script *sc.ScriptDef, keyspace string, runId int16, startNodeNames []string) string
• func RunNode(envConfig *env.EnvConfig, logger *l.Logger, nodeName string, runId int16, ...) (int16, error)
• func StartRun(envConfig *env.EnvConfig, logger *l.Logger, amqpChannel *amqp.Channel, ...) (int16, error)
• func StopRun(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, ...) error

Functions

func DropKeyspace

func DropKeyspace(logger *l.Logger, cqlSession *gocql.Session, keyspace string) error

func GetBatchHistory

func GetBatchHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16, scriptNodes []string) ([]*wfmodel.BatchHistory, error)

func GetNodeHistory

func GetNodeHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16) ([]*wfmodel.NodeHistory, error)

func GetRunHistory

func GetRunHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string) ([]*wfmodel.RunHistory, error)

func GetTablesCql

func GetTablesCql(script *sc.ScriptDef, keyspace string, runId int16, startNodeNames []string) string

func RunNode

func RunNode(envConfig *env.EnvConfig, logger *l.Logger, nodeName string, runId int16, scriptFilePath string, paramsFilePath string, cqlSession *gocql.Session, keyspace string) (int16, error)

func StartRun

func StartRun(envConfig *env.EnvConfig, logger *l.Logger, amqpChannel *amqp.Channel, scriptFilePath string, paramsFilePath string, cqlSession *gocql.Session, keyspace string, startNodes []string) (int16, error)

func StopRun

func StopRun(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, comment string) error