Index

_

__call__() (reip.Block method) __init__() (reip.Block method) (reip.Graph method) (reip.Task method) __or__() (reip.Block method)

__repr__() (reip.Block method) (reip.Graph method) (reip.Task method) __ror__() (reip.Block method) __weakref__ (reip.Block attribute)

A

append() (reip.util.statistics.OnlineStats method) Array (class in reip.blocks.dummy)

as_list() (in module reip.util.misc) AsDict (class in reip.blocks.misc)

B

b_() (in module reip.util.text) BaseStore (class in reip.stores.base) BaseStore.Customer (class in reip.stores.base) Block (class in reip)

block_stack() (in module reip.util.debug) block_text() (in module reip.util.text) blue() (in module reip.util.text) bold() (in module reip.util.text)

C

check_block() (in module reip.util.debug) close() (reip.Graph method) (reip.Task method) cmd (reip.util.shell.ShellResult attribute) comment() (in module reip.util.text)

Constant (class in reip.blocks.misc) Created (class in reip.blocks.os_watch) cursor (reip.stores.base.BaseStore.Customer property) (reip.stores.customer.Customer property) Customer (class in reip.stores.customer) (reip.stores.queue_store.QueueStore attribute)

D

Debug (class in reip.blocks.misc) decorator() (in module reip.util.misc) decrypt() (reip.blocks.encrypt.TwoStageDecrypt method)

Deleted (class in reip.blocks.os_watch) DiskMonitor (class in reip.blocks.diskmonitor) done (reip.Graph property) (reip.Task property)

E

empty() (reip.interface.Source method) (reip.stores.queue_store.QueueCustomer method) ensure_dir() (in module reip.util.misc)

err (reip.util.shell.ShellResult attribute) error (reip.Graph property) (reip.Task property) extend() (reip.util.statistics.OnlineStats method)

F

FastRebuffer (class in reip.blocks.buffer) filter() (reip.util.logging.InjectData method) (reip.util.logging.MaxLevel method) finish() (reip.Block method) (reip.blocks.buffer.GatedRebuffer method) (reip.blocks.dummy.Array method) (reip.blocks.misc.Gather method) (reip.blocks.misc.Lambda method) (reip.blocks.os_watch.Watch method) (reip.blocks.shell.ShellProcess method) (reip.blocks.video.core.Video method) (reip.blocks.video.core.VideoWriter method)

fname() (in module reip.util.misc) full() (reip.interface.Sink method) (reip.stores.producer.Producer method) fw_() (in module reip.util.text)

G

GatedRebuffer (class in reip.blocks.buffer) Gather (class in reip.blocks.misc) gen_source() (reip.stores.producer.Producer method) get() (reip.interface.Source method) get_nowait() (reip.interface.Source method)

get_serializer() (in module reip.stores.queue) git() (in module reip.util.shell) Glob (class in reip.blocks.misc) Graph (class in reip) green() (in module reip.util.text)

I

Increment (class in reip.blocks.misc) indent() (in module reip.util.text) init() (reip.Block method) (reip.blocks.buffer.FastRebuffer method) (reip.blocks.buffer.GatedRebuffer method) (reip.blocks.buffer.Rebuffer method) (reip.blocks.dummy.Array method) (reip.blocks.dummy.TimeBomb method) (reip.blocks.misc.Gather method) (reip.blocks.misc.Glob method) (reip.blocks.misc.Interval method) (reip.blocks.misc.Lambda method) (reip.blocks.misc.Results method) (reip.blocks.os_watch.Watch method) (reip.blocks.shell.ShellProcess method) (reip.blocks.video.core.Video method) (reip.blocks.video.core.VideoWriter method) (reip.blocks.video.effects.OpticalFlow method)

InjectData (class in reip.util.logging) Interleave (class in reip.blocks.misc) Interval (class in reip.blocks.misc) Iterator (class in reip.blocks.misc)

J

join() (reip.Graph method) (reip.interface.Sink method) (reip.stores.producer.Producer method) (reip.Task method)

L

l_() (in module reip.util.text) Lambda (class in reip.blocks.misc)

last() (reip.interface.Source method) loop() (in module reip.util.iters)

M

MaxLevel (class in reip.util.logging) Meta (class in reip.blocks.misc) Modified (class in reip.blocks.os_watch) module reip reip.blocks.archive reip.blocks.buffer reip.blocks.diskmonitor reip.blocks.dummy reip.blocks.encrypt reip.blocks.misc reip.blocks.os_watch reip.blocks.shell reip.blocks.video.core reip.blocks.video.effects reip.interface reip.stores.base reip.stores.customer reip.stores.plasma reip.stores.pointers reip.stores.producer reip.stores.queue reip.stores.queue_store reip.stores.store reip.util.debug reip.util.func reip.util.iters reip.util.logging reip.util.misc reip.util.shell reip.util.statistics reip.util.stopwatch reip.util.text

Moved (class in reip.blocks.os_watch) multicontext() (in module reip.util.misc)

N

next() (reip.stores.base.BaseStore.Customer method) (reip.stores.customer.Customer method) (reip.stores.queue_store.QueueCustomer method)

npgenarray() (in module reip.util.iters)

O

OnlineStats (class in reip.util.statistics) Op (class in reip.blocks.dummy)

OpticalFlow (class in reip.blocks.video.effects) out (reip.util.shell.ShellResult attribute) output_stream() (reip.Block method)

P

pause() (reip.Graph method) (reip.Task method) peakiter() (in module reip.util.iters) PlasmaStore (class in reip.stores.plasma) print_stack() (in module reip.util.debug) process() (reip.Block method) (reip.blocks.archive.Tar method) (reip.blocks.buffer.FastRebuffer method) (reip.blocks.buffer.GatedRebuffer method) (reip.blocks.buffer.Rebuffer method) (reip.blocks.diskmonitor.DiskMonitor method) (reip.blocks.dummy.Array method) (reip.blocks.dummy.Op method) (reip.blocks.dummy.TextFile method) (reip.blocks.dummy.TimeBomb method) (reip.blocks.encrypt.TwoStageDecrypt method) (reip.blocks.encrypt.TwoStageEncrypt method) (reip.blocks.misc.AsDict method) (reip.blocks.misc.Constant method) (reip.blocks.misc.Debug method) (reip.blocks.misc.Gather method) (reip.blocks.misc.Glob method) (reip.blocks.misc.Interleave method) (reip.blocks.misc.Interval method) (reip.blocks.misc.Iterator method) (reip.blocks.misc.Lambda method) (reip.blocks.misc.Meta method) (reip.blocks.misc.Results method) (reip.blocks.misc.Separate method) (reip.blocks.misc.Time method) (reip.blocks.os_watch.Watch method) (reip.blocks.shell.Shell method) (reip.blocks.video.core.Video method) (reip.blocks.video.core.VideoWriter method) (reip.blocks.video.effects.OpticalFlow method)

Producer (class in reip.stores.producer) put() (reip.interface.Sink method) put_nowait() (reip.interface.Sink method)

Q

QueueCustomer (class in reip.stores.queue_store)

QueueStore (class in reip.stores.queue_store)

R

raise_exception() (reip.Graph method) rc (reip.util.shell.ShellResult attribute) ready (reip.Graph property) (reip.Task property) Rebuffer (class in reip.blocks.buffer) red() (in module reip.util.text) reip module reip.blocks.archive module reip.blocks.buffer module reip.blocks.diskmonitor module reip.blocks.dummy module reip.blocks.encrypt module reip.blocks.misc module reip.blocks.os_watch module reip.blocks.shell module reip.blocks.video.core module reip.blocks.video.effects module reip.interface module reip.stores.base module reip.stores.customer module reip.stores.plasma module reip.stores.pointers module

reip.stores.producer module reip.stores.queue module reip.stores.queue_store module reip.stores.store module reip.util.debug module reip.util.func module reip.util.iters module reip.util.logging module reip.util.misc module reip.util.shell module reip.util.statistics module reip.util.stopwatch module reip.util.text module resize_list() (in module reip.util.misc) Results (class in reip.blocks.misc) resume() (reip.Graph method) (reip.Task method) retry() (in module reip.util.func) run() (in module reip.util.shell) (reip.Graph method) run_scope() (reip.Graph method) running (reip.Graph property) (reip.Task property)

S

Separate (class in reip.blocks.misc) Shell (class in reip.blocks.shell) ShellArg (class in reip.util.shell) ShellProcess (class in reip.blocks.shell) ShellResult (class in reip.util.shell) shmatch() (in module reip.util.shell) short_stack() (in module reip.util.debug) Sink (class in reip.interface) SomeArray (in module reip.blocks.dummy) SomeTransform (in module reip.blocks.dummy) Source (class in reip.interface) space2tab() (in module reip.util.text) spawn() (reip.Block method) (reip.Graph method) (reip.interface.Sink method) (reip.stores.producer.Producer method) (reip.Task method)

squeeze() (in module reip.util.misc) status() (reip.Block method) std (reip.util.statistics.OnlineStats property) Stopwatch (class in reip.util.stopwatch) Store (class in reip.stores.store) store (reip.stores.base.BaseStore.Customer property) (reip.stores.customer.Customer property) striplines() (in module reip.util.text) StrRep (class in reip.util.logging) sum (reip.util.statistics.OnlineStats property)

T

tab2space() (in module reip.util.text) tabindent() (in module reip.util.text) Tar (class in reip.blocks.archive) TarGz (class in reip.blocks.archive) Task (class in reip) tbl() (in module reip.util.text) temporal_coverage() (in module reip.blocks.buffer) terminate() (reip.Graph method) (reip.Task method) terminated (reip.Graph property) (reip.Task property)

TextFile (class in reip.blocks.dummy) throttle() (in module reip.util.func) throttled() (in module reip.util.iters) Time (class in reip.blocks.misc) TimeBomb (class in reip.blocks.dummy) timed() (in module reip.util.iters) to() (reip.Block method) trim_indent() (in module reip.util.text) TwoStageDecrypt (class in reip.blocks.encrypt) TwoStageEncrypt (class in reip.blocks.encrypt)

U

underline() (in module reip.util.text)

V

var (reip.util.statistics.OnlineStats property)

Video (class in reip.blocks.video.core) VideoWriter (class in reip.blocks.video.core)

W

wait() (reip.interface.Sink method) (reip.interface.Source method)

wait_until_ready() (reip.Block method) Watch (class in reip.blocks.os_watch) write() (in module reip.util.misc)

Y

yellow() (in module reip.util.text)