api

Documentation

Index

• Constants
• func DropKeyspace(logger *l.Logger, cqlSession *gocql.Session, keyspace string) error
• func GetBatchHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16, ...) ([]*wfmodel.BatchHistoryEvent, error)
• func GetNodeHistoryForRun(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16) ([]*wfmodel.NodeHistoryEvent, error)
• func GetRunHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string) ([]*wfmodel.RunHistoryEvent, error)
• func GetRunNodeBatchHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, ...) ([]*wfmodel.BatchHistoryEvent, error)
• func GetRunProperties(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16) ([]*wfmodel.RunProperties, error)
• func GetRunsNodeHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16) ([]*wfmodel.NodeHistoryEvent, error)
• func GetTablesCql(script *sc.ScriptDef, keyspace string, runId int16, startNodeNames []string) string
• func HarvestRunLifespans(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runIds []int16) (wfmodel.RunLifespanMap, error)
• func IsSystemKeyspaceName(keyspace string) bool
• 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

Constants

const AllowedKeyspaceNameRegex = "[a-zA-Z0-9_]+"

const ProhibitedKeyspaceNameRegex = "^system"

Functions

func DropKeyspace

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

Used by Toolbelt and Webapi

func GetBatchHistory

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

func GetNodeHistoryForRun

func GetNodeHistoryForRun(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16) ([]*wfmodel.NodeHistoryEvent, error)

wfdb wrapper for webapi use

func GetRunHistory

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

func GetRunNodeBatchHistory

func GetRunNodeBatchHistory(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, nodeName string) ([]*wfmodel.BatchHistoryEvent, error)

wfdb wrapper for webapi use

func GetRunProperties

func GetRunProperties(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16) ([]*wfmodel.RunProperties, error)

wfdb wrapper for webapi use

func GetRunsNodeHistory

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

func GetTablesCql

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

A helper used by Toolbelt get_table_cql cmd, no logging needed

func HarvestRunLifespans

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

wfdb wrapper for webapi use

func IsSystemKeyspaceName

func IsSystemKeyspaceName(keyspace string) bool

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, desc string) (int16, error)

func StopRun

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