Documentation
¶
Index ¶
- func Aggregate(data []mongo.DASRecord, agg, key string) mongo.DASRecord
- func Bytes(pid string) int
- func CheckData(pid string) bool
- func CheckDataReadiness(pid string) bool
- func Count(pid string) int
- func FormRESTUrl(dasquery dasql.DASQuery, dasmap mongo.DASRecord) string
- func FormUrlCall(dasquery dasql.DASQuery, dasmap mongo.DASRecord) string
- func GetData(dasquery dasql.DASQuery, coll string, idx, limit int) (string, []mongo.DASRecord)
- func GetTimestamp(pid string) int64
- func PostProcessing(dasquery dasql.DASQuery, data []mongo.DASRecord) []mongo.DASRecord
- func Process(dasquery dasql.DASQuery, dmaps dasmaps.DASMaps)
- func ProcessLogic(dasquery dasql.DASQuery, maps []mongo.DASRecord, selectedServices []string) ([]string, []string, map[string]string, []mongo.DASRecord)
- func ProcessingQueries() []string
- func RemoveExpired(pid string)
- func TimeStamp(dasquery dasql.DASQuery) int64
- type DASRecord
- type DASRecords
- type Record
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckDataReadiness ¶
CheckDataReadiness checks if data exists in DAS cache for given query/pid we look-up DAS record (record=0) with status ok (merging step is done)
func FormRESTUrl ¶
FormRESTUrl forms appropriate URL from given dasquery and dasmap, the final URL contains all parameters
func FormUrlCall ¶
FormUrlCall forms appropriate URL from given dasquery and dasmap, the final URL contains all parameters
func GetTimestamp ¶
GetTimestamp gets initial timestamp of DAS query request
func PostProcessing ¶
helper function to perform post-processing of DAS data, e.g. when we call site query we need to distinguish the case when to show original site
func ProcessLogic ¶
func ProcessLogic(dasquery dasql.DASQuery, maps []mongo.DASRecord, selectedServices []string) ([]string, []string, map[string]string, []mongo.DASRecord)
ProcessLogic represents common logic for Process API shared both in das2go and dasgoclient codebase. It figures out which services pkeys, urls and localApis to use for given dasquery, das maps and selected Services The selectedServices is only used in dasgoclient to speed up the process.
func ProcessingQueries ¶
func ProcessingQueries() []string
ProcessingQueries returns list of DAS queries which are currently processing by the server
Source Files