Documentation ¶
Index ¶
- Constants
- Variables
- func FetchData(sheetId string) []models.ScriptElem
- func GenerateResultSheet()
- func GetComputeSheetId() string
- func GetFloat(value interface{}) (float64, error)
- func GetNumComputeSheet() int
- func GetResultSheet() string
- func GetResultsSheet() string
- func GetWorkerSheet() string
- func Init()
- func ProcessScriptInfo(script ScriptInfo) models.ScriptData
- func Push2DArray(array Matrix, sheetId string, sheetName string)
- func PushCommand(symbol string, sheetId string)
- func ReadComputeData()
- func ReadData(sheetId string, majorDimension string) *sheets.ValueRange
- func ThrottleApiRequest(counterName string) bool
- func UpdateCountHist(counthist CountHist, counterName string)
- func WriteComputeData(readRange string, values [][]interface{})
- func WriteData(sheetId string, readRange string, values [][]interface{})
- func WriteResultData(readRange string, values [][]interface{})
- type CountHist
- type Matrix
- type ScriptInfo
Constants ¶
View Source
const ( COMPUTESHEET = "1jI2T8FO5Kt7AkUvE6cS3I6Fm8bt2BeuPbXf8UXVBdEk" RESULTSHEET = "1h7aG-c_nFF3qCr4wXVkhzU0HOmofSY_Bq0wtpOxyhyM" WORKERSHEET = "1l0KW9vebKjydaZTI9T04jnCq-bePJ4MaDslgVkelbmg" RESULTSSHEET = "1kf_2FEF39tgJ3zjMDS5Sgf_vUfJDDQr6f-WlKYvxAAM" NUMCOMPUTESHEETS = 50 )
View Source
const ( DIMENSION_COLUMNS = "COLUMNS" DIMENSION_ROWS = "ROWS" )
Variables ¶
View Source
var DbStream = func(done <-chan interface{}, dbStream <-chan models.StatResult) <-chan float64 { doneStream := make(chan float64) go func() { defer close(doneStream) for result := range dbStream { select { case <-done: return case doneStream <- db.WriteResultsInfo(result): } } }() return doneStream }
View Source
var GetData = func(done <-chan interface{}, scriptStream <-chan ScriptInfo) <-chan models.ScriptData { getDataStream := make(chan models.ScriptData) go func() { defer close(getDataStream) for i := range scriptStream { select { case <-done: return case getDataStream <- ProcessScriptInfo(i): } } }() return getDataStream }
View Source
var MaxThrottle = 55
View Source
var ProcDataStream = func(done <-chan interface{}, dataStream <-chan models.ScriptData) <-chan models.StatResult { scoreStream := make(chan models.StatResult) go func() { defer close(scoreStream) for i := range dataStream { select { case <-done: return default: ai.ProcDataStream(i, scoreStream) } } log.Printf("Exiting go Func") }() return scoreStream }
View Source
var ReadApiCounter = map[string]CountHist{"ReadData": CountHist{/* contains filtered or unexported fields */}, "WriteData": CountHist{/* contains filtered or unexported fields */}}
View Source
var ResultStatStream = func(done <-chan interface{}, resultStream <-chan models.StatResult) <-chan float64 { doneStream := make(chan float64) go func() { defer close(doneStream) for result := range resultStream { select { case <-done: return case doneStream <- results.ProcResultsInfo(result): } } }() return doneStream }
View Source
var ScriptGenerator = func(done <-chan interface{}, allNseScripts []ScriptInfo) <-chan ScriptInfo { scriptStream := make(chan ScriptInfo) go func() { defer close(scriptStream) for _, script := range allNseScripts { select { case <-done: log.Printf("Received Done") return case scriptStream <- script: fmt.Printf("Processing %s\n", script) } } log.Printf("Exiting AllNSE Scripts %d", len(allNseScripts)) }() return scriptStream }
Functions ¶
func FetchData ¶
func FetchData(sheetId string) []models.ScriptElem
func GenerateResultSheet ¶
func GenerateResultSheet()
func GetComputeSheetId ¶
func GetComputeSheetId() string
func GetNumComputeSheet ¶
func GetNumComputeSheet() int
func GetResultSheet ¶
func GetResultSheet() string
func GetResultsSheet ¶
func GetResultsSheet() string
func GetWorkerSheet ¶
func GetWorkerSheet() string
func ProcessScriptInfo ¶
func ProcessScriptInfo(script ScriptInfo) models.ScriptData
func Push2DArray ¶
func PushCommand ¶
func ReadComputeData ¶
func ReadComputeData()
func ThrottleApiRequest ¶
func UpdateCountHist ¶
func WriteComputeData ¶
func WriteComputeData(readRange string, values [][]interface{})
func WriteResultData ¶
func WriteResultData(readRange string, values [][]interface{})
Types ¶
type ScriptInfo ¶
func GetAllNseScripts ¶
func GetAllNseScripts() []ScriptInfo
Click to show internal directories.
Click to hide internal directories.