Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
rethinkdb-lite
master
Top Level Namespace
Array
Duktape
Context
Float64
Hash
Int32
Int64
Object
PerSecondMetric
ReQL
AbstractValue
Type
AddTerm
AndTerm
AppendTerm
AprilTerm
ArgsTerm
ArrayStream
AscTerm
AugustTerm
AvgTerm
BetweenDeprecatedTerm
BetweenTerm
BinaryTerm
BitAndTerm
BitNotTerm
BitOrTerm
BitSalTerm
BitSarTerm
BitXorTerm
BracketTerm
BranchTerm
CeilTerm
ChangeAtTerm
ChangesTerm
CircleTerm
ClientError
CoerceToTerm
CompileError
ConcatMapStream
ConcatMapTerm
ConfigTerm
ContainsTerm
CountTerm
DateTerm
Datum
DatumTerm
DayOfWeekTerm
DayOfYearTerm
DayTerm
Db
DbCreateTerm
DbDropTerm
DbListTerm
DbTerm
DecemberTerm
DefaultTerm
DeleteAtTerm
DeleteTerm
DescTerm
DifferenceTerm
DistanceTerm
DistinctTerm
DivTerm
DoTerm
DowncaseTerm
DriverCompileError
Durability
DuringTerm
EpochTimeTerm
EqJoinTerm
EqTerm
ErrorTerm
Evaluator
FebruaryTerm
FieldFunc
FillTerm
FilterStream
FilterTerm
FloorTerm
FoldTerm
ForEachTerm
FridayTerm
Func
FuncTerm
GeojsonTerm
GetAllStream
InternalData
GetAllTerm
GeTerm
GetFieldTerm
GetIntersectingTerm
GetNearestTerm
GetTerm
GetWriteHookTerm
GrantTerm
GroupStream
InternalData
GroupTerm
GroupTransformer
GtTerm
HasFieldsTerm
HoursTerm
HttpTerm
ImplicitVarTerm
IncludesTerm
IndexCreateTerm
IndexDropTerm
IndexListTerm
IndexRenameTerm
IndexStatusTerm
IndexWaitTerm
InfiniteRange
InfiniteStream
InfoTerm
InnerJoinTerm
InsertAtTerm
InsertTerm
InternalError
IntersectsTerm
InTimezoneTerm
IsEmptyTerm
Iso8601Term
JanuaryTerm
Job
JobManager
JsFunc
JsonTerm
JsTerm
JulyTerm
JuneTerm
KeysTerm
LeTerm
LimitStream
LimitTerm
LineTerm
LiteralTerm
LtTerm
MakeArrayTerm
MakeObjTerm
MapStream
MapTerm
MarchTerm
MatchTerm
MaxTerm
Maxval
MaxvalTerm
MayTerm
MergeTerm
MinTerm
MinutesTerm
Minval
MinvalTerm
ModTerm
MondayTerm
MonthTerm
MulTerm
NeTerm
NonExistenceError
NotTerm
NovemberTerm
NowTerm
NthTerm
ObjectSelection
ObjectTerm
OctoberTerm
OffsetsOfTerm
OpFailedError
OpIndeterminateError
OrderByTerm
OrTerm
OuterJoinTerm
PermissionError
PluckTerm
PointTerm
PolygonSubTerm
PolygonTerm
PrependTerm
QueryJob
ResultStream
QueryLogicError
RandomTerm
Range
RangeTerm
RebalanceTerm
ReconfigureTerm
ReduceTerm
ReplaceTerm
ReqlFunc
ResourceLimitError
RoundTerm
Row
RowReference
RowValue
RuntimeError
SampleTerm
SaturdayTerm
SecondsTerm
SeptemberTerm
SetDifferenceTerm
SetInsertTerm
SetIntersectionTerm
SetUnionTerm
SetWriteHookTerm
SimplifyVariablesTransformer
SkipStream
SkipTerm
SliceTerm
SpliceAtTerm
SplitTerm
StatusTerm
Stream
SubTerm
SumTerm
SundayTerm
SyncTerm
Table
InternalData
TableCreateTerm
TableDropTerm
TableListTerm
TableScanJob
FinishedScan
TableTerm
TableWriter
Term
Type
TermType
ThursdayTerm
TimeOfDayTerm
TimeTerm
TimezoneTerm
ToEpochTimeTerm
ToGeojsonTerm
ToIso8601Term
ToJsonStringTerm
Transformer
TransformerWithVisitor
TuesdayTerm
TypeOfTerm
UngroupTerm
UnionTerm
UpcaseTerm
UpdateTerm
UserError
UuidTerm
ValuesTerm
VarTerm
WaitTerm
WednesdayTerm
WithFieldsTerm
WithoutTerm
Worker
YearTerm
ZipTerm
RethinkDB
Connection
Cursor
Datum
DSL
R
Type
Radd
Rand
Rappend
Rapril
Rargs
Rasc
Raugust
Ravg
Rbetween
Rbetween_deprecated
Rbinary
Rbit_and
Rbit_not
Rbit_or
Rbit_sal
Rbit_sar
Rbit_xor
Rbracket
Rbranch
Rceil
Rchange_at
Rchanges
Rcircle
Rcoerce_to
Rconcat_map
Rconfig
Rcontains
Rcount
Rdate
Rdatum
Rday
Rday_of_week
Rday_of_year
Rdb
Rdb_create
Rdb_drop
Rdb_list
Rdecember
Rdefault
Rdelete
Rdelete_at
Rdesc
Rdifference
Rdistance
Rdistinct
Rdiv
Rdo
Rdowncase
Rduring
Repoch_time
Req
Req_join
Rerror
RExpr
Rfebruary
Rfill
Rfilter
Rfloor
Rfold
Rfor_each
Rfriday
Rfunc
Rge
Rgeojson
Rget
Rget_all
Rget_field
Rget_intersecting
Rget_nearest
Rget_write_hook
Rgrant
Rgroup
Rgt
Rhas_fields
Rhours
Rhttp
Rimplicit_var
Rin_timezone
Rincludes
Rindex_create
Rindex_drop
Rindex_list
Rindex_rename
Rindex_status
Rindex_wait
Rinfo
Rinner_join
Rinsert
Rinsert_at
Rintersects
Ris_empty
Riso8601
Rjanuary
Rjs
Rjson
Rjuly
Rjune
Rkeys
Rle
Rlimit
Rline
Rliteral
Rlt
Rmake_array
Rmake_obj
Rmap
Rmarch
Rmatch
Rmax
Rmaxval
Rmay
Rmerge
Rmin
Rminutes
Rminval
Rmod
Rmonday
Rmonth
Rmul
Rne
Rnot
Rnovember
Rnow
Rnth
Robject
Roctober
Roffsets_of
Ror
Rorder_by
Router_join
Rpluck
Rpoint
Rpolygon
Rpolygon_sub
Rprepend
Rrandom
Rrange
Rrebalance
Rreconfigure
Rreduce
Rreplace
Rround
Rsample
Rsaturday
Rseconds
Rseptember
Rset_difference
Rset_insert
Rset_intersection
Rset_union
Rset_write_hook
Rskip
Rslice
Rsplice_at
Rsplit
Rstatus
Rsub
Rsum
Rsunday
Rsync
Rtable
Rtable_create
Rtable_drop
Rtable_list
Rthursday
Rtime
Rtime_of_day
Rtimezone
Rto_epoch_time
Rto_geojson
Rto_iso8601
Rto_json_string
Rtuesday
Rtype_of
Rungroup
Runion
Rupcase
Rupdate
Ruuid
Rvalues
Rvar
Rwait
Rwednesday
Rwith_fields
Rwithout
Ryear
Rzip
LocalConnection
Cursor
RemoteConnection
Cursor
ErrorType
Query
QueryType
Response
ResponseType
RunOpts
Server
Client
DriverServer
WebUiServer
Storage
AbstractTable
KeyValueStore
DatabaseInfo
IndexBuilder
IndexInfo
SystemInfo
TableInfo
WriteBatch
Manager
Database
Index
Table
PhysicalTable
VirtualCurrentIssuesTable
VirtualDbConfigTable
VirtualJobsTable
VirtualServerConfigTable
VirtualServerStatusTable
VirtualStatsTable
VirtualTable
VirtualTableConfigTable
VirtualTableStatusTable
String
WaitGroup
Generated using Crystal 1.10.1
2024-01-09 19:06:52 UTC
class
ReQL::
Worker
ReQL::Worker
Reference
Object
Defined in:
reql/worker.cr
Constant Summary
CHANNEL_SIZE
=
10
*
WORKER_COUNT
WORKER_COUNT
=
128
Constructors
.new
Instance Method Summary
#close
#delete
(wait_group, table_writer, table, key)
#insert
(wait_group, table_writer, table, row)
Instance methods inherited from class
Object
!=(other : RethinkDB::DSL::R)
!=
,
%(other : RethinkDB::DSL::R)
%
,
&(other : RethinkDB::DSL::R)
&
,
*(other : RethinkDB::DSL::R)
*
,
+(other : RethinkDB::DSL::R)
+
,
-(other : RethinkDB::DSL::R)
-
,
/(other : RethinkDB::DSL::R)
/
,
<(other : RethinkDB::DSL::R)
<
,
<=(other : RethinkDB::DSL::R)
<=
,
==(other : RethinkDB::DSL::R)
==
,
>(other : RethinkDB::DSL::R)
>
,
>=(other : RethinkDB::DSL::R)
>=
,
|(other : RethinkDB::DSL::R)
|
Constructor Detail
def self.
new
#
[
View source
]
Instance Method Detail
def
close
#
[
View source
]
def
delete
(wait_group, table_writer, table, key)
#
[
View source
]
def
insert
(wait_group, table_writer, table, row)
#
[
View source
]