Documentation ¶
Index ¶
- Variables
- func Check(err error)
- func ExecuteSubquery(doneDeps chan<- st.Latency, dep string, url []string, cacheable []int8, ...)
- func InitSubSystems(cacheip string)
- func ParseRequest(layers QueryLayerSlice, startTime time.Time)
- func PingTest(cacheip string)
- type BackConn
- type DepQuery
- type Empty
- type FbBackConn
- type JsonRequest
- type MySqlBackConn
- type Query
- type QueryLayer
- type QueryLayerSlice
- type Semaphore
- type SizeGen
- type Subsystem
Constants ¶
This section is empty.
Variables ¶
View Source
var BypassCaches bool
bypass caches
View Source
var DepConfigs []st.DepConfig
global config store
View Source
var Subs map[string]Subsystem
subsystems
Functions ¶
func ExecuteSubquery ¶
func ExecuteSubquery(doneDeps chan<- st.Latency, dep string, url []string, cacheable []int8, startTime time.Time)
execute a subquery and handle cache hits
func ParseRequest ¶
func ParseRequest(layers QueryLayerSlice, startTime time.Time)
parse a request struct and issue requests following dependency graph
Types ¶
type FbBackConn ¶
type FbBackConn struct { Conn chan *rpc.Client Pars st.FbackParameters }
fb-type backend connection
func (FbBackConn) Ping ¶
func (fbcon FbBackConn) Ping() (works bool)
type JsonRequest ¶
type JsonRequest struct { T int64 `json:"t"` D QueryLayerSlice `json:"d"` }
type MySqlBackConn ¶
func (MySqlBackConn) Ping ¶
func (mybc MySqlBackConn) Ping() (works bool)
type QueryLayer ¶
type QueryLayerSlice ¶
type QueryLayerSlice []QueryLayer
type SizeGen ¶
func NewSizeGen ¶
Click to show internal directories.
Click to hide internal directories.