Documentation
¶
Index ¶
Constants ¶
View Source
const (
// SourceType defines the "source" type from qlbridge datasource
SourceType = "lytics"
)
Variables ¶
View Source
var (
// DefaultLimit is default limit page size.
DefaultLimit = 1000
)
Functions ¶
This section is empty.
Types ¶
type Generator ¶
type Generator struct {
// contains filtered or unexported fields
}
Generator Generate Lytics api requests from Sql Statements - convert sql WHERE into SegmentQL api statements - fetch entities from entity scan api
func NewGenerator ¶
NewGenerator create a new generator to generate lytics query from request.
func (*Generator) WalkExecSource ¶
WalkExecSource allow this to do its own Exec planning.
type ResultReader ¶
type ResultReader struct { *exec.TaskBase Docs []u.JsonHelper Vals [][]driver.Value Total int Aggs u.JsonHelper ScrollId string Req *Generator // contains filtered or unexported fields }
ResultReader, adapts the lytics http json response
func NewResultReader ¶
func NewResultReader(req *Generator) *ResultReader
NewResultReader create a new lytics reader that will handle translation of lytics rest api content into dataux/qlbridge types.
func (*ResultReader) Close ¶
func (m *ResultReader) Close() error
func (*ResultReader) Run ¶
func (m *ResultReader) Run() error
Run() Fetch api response, page through result continuing to send messages.
type ResultReaderNext ¶
type ResultReaderNext struct {
*ResultReader
}
ResultReaderNext is wrapper, allowing us to implement sql/driver Next() interface which is different than qlbridge/datasource Next()
Click to show internal directories.
Click to hide internal directories.