queries

Documentation

Index

• func NewQuerySnapshot(table string, projection []string, isNull []string, isNotNull []string, ...) libqpu.ASTQuery
• func NewQuerySnapshotAndSubscribe(table string, projection []string, isNull []string, isNotNull []string, ...) libqpu.ASTQuery
• func NewQuerySubscribe(table string, projection []string, isNull []string, isNotNull []string, ...) libqpu.ASTQuery
• func QueryType(query libqpu.ASTQuery) (bool, bool)
• func SatisfiesPredicate(logOp libqpu.LogOperation, query libqpu.ASTQuery) (bool, error)

Functions

func NewQuerySnapshot

func NewQuerySnapshot(table string, projection []string, isNull []string, isNotNull []string, limit int64, snapshotPredicate *qpu.SnapshotTimePredicate) libqpu.ASTQuery

NewQuerySnapshot ...

func NewQuerySnapshotAndSubscribe

func NewQuerySnapshotAndSubscribe(table string, projection []string, isNull []string, isNotNull []string, attrPredicates []*qpu.AttributePredicate, snapshotPredicate *qpu.SnapshotTimePredicate) libqpu.ASTQuery

NewQuerySnapshotAndSubscribe ...

func NewQuerySubscribe

func NewQuerySubscribe(table string, projection []string, isNull []string, isNotNull []string, snapshotPredicate *qpu.SnapshotTimePredicate) libqpu.ASTQuery

NewQuerySubscribe ...

func QueryType

func QueryType(query libqpu.ASTQuery) (bool, bool)

QueryType ...

func SatisfiesPredicate

func SatisfiesPredicate(logOp libqpu.LogOperation, query libqpu.ASTQuery) (bool, error)

SatisfiesPredicate ...