excel

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
  • func GetAllNseScripts() []ScriptInfo

Constants

const (
	COMPUTESHEET     = "1jI2T8FO5Kt7AkUvE6cS3I6Fm8bt2BeuPbXf8UXVBdEk"
	RESULTSHEET      = "1h7aG-c_nFF3qCr4wXVkhzU0HOmofSY_Bq0wtpOxyhyM"
	WORKERSHEET      = "1l0KW9vebKjydaZTI9T04jnCq-bePJ4MaDslgVkelbmg"
	RESULTSSHEET     = "1kf_2FEF39tgJ3zjMDS5Sgf_vUfJDDQr6f-WlKYvxAAM"
	NUMCOMPUTESHEETS = 50
)

const (
	DIMENSION_COLUMNS = "COLUMNS"
	DIMENSION_ROWS    = "ROWS"
)

Variables

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

}

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
}

var MaxThrottle = 55

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
}

var ReadApiCounter = map[string]CountHist{"ReadData": CountHist{/* contains filtered or unexported fields */},
	"WriteData": CountHist{/* contains filtered or unexported fields */}}

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
}

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 GetFloat

func GetFloat(value interface{}) (float64, error)

func GetNumComputeSheet

func GetNumComputeSheet() int

func GetResultSheet

func GetResultSheet() string

func GetResultsSheet

func GetResultsSheet() string

func GetWorkerSheet

func GetWorkerSheet() string

func Init

func Init()

func ProcessScriptInfo

func ProcessScriptInfo(script ScriptInfo) models.ScriptData

func Push2DArray

func Push2DArray(array Matrix, sheetId string, sheetName string)

func PushCommand

func PushCommand(symbol string, sheetId string)

func ReadComputeData

func ReadComputeData()

func ReadData

func ReadData(sheetId string, majorDimension string) *sheets.ValueRange

func ThrottleApiRequest

func ThrottleApiRequest(counterName string) bool

func UpdateCountHist

func UpdateCountHist(counthist CountHist, counterName string)

func WriteComputeData

func WriteComputeData(readRange string, values [][]interface{})

func WriteData

func WriteData(sheetId string, readRange string, values [][]interface{})

func WriteResultData

func WriteResultData(readRange string, values [][]interface{})

Types

type CountHist

type CountHist struct {
	// contains filtered or unexported fields
}

type Matrix

type Matrix [][]interface{}

type ScriptInfo

type ScriptInfo struct {
	Symbol  string
	Company string
	Market  int64
}

func GetAllNseScripts

func GetAllNseScripts() []ScriptInfo