flod.pipeline

Pipeline composition.

This module contains functions and types that are mainly used by pipe implementors to append stages to pipelines and instantiate pipelines.

Members

Enums

DriveMode
enum DriveMode

Determines which driver drives the entire pipeline in pipelines with multiple drivers.

Functions

filterImpl
ulong filterImpl(ulong a)
Undocumented in source. Be warned that the author may not have intended to support it.
filterMark
uint filterMark(string f)
Undocumented in source. Be warned that the author may not have intended to support it.
genChain
string genChain(DriveMode mode, string filterList)
Undocumented in source. Be warned that the author may not have intended to support it.
genStage
string genStage(string filter, string suf)
Undocumented in source. Be warned that the author may not have intended to support it.
methodAttributesFromString
MethodAttribute[][] methodAttributesFromString(string str)
Undocumented in source. Be warned that the author may not have intended to support it.
pipe
auto pipe(Args args)
Undocumented in source. Be warned that the author may not have intended to support it.
pipe
auto pipe(Args args)

Starts building a pipeline.

testChain
void testChain(R r)
Undocumented in source. Be warned that the author may not have intended to support it.
testChain
void testChain()
Undocumented in source. Be warned that the author may not have intended to support it.
testOptimizeChain
bool testOptimizeChain(string str)
Undocumented in source. Be warned that the author may not have intended to support it.

Mixin templates

FiberSwitch
mixintemplate FiberSwitch()

A mixin template that implements spawn(), stop() and yield() using core.Thread.Fiber.

ImplementTestAllocFilter
mixintemplate ImplementTestAllocFilter()
Undocumented in source.
ImplementTestAllocPeekFilter
mixintemplate ImplementTestAllocPeekFilter()
Undocumented in source.
ImplementTestAllocPullFilter
mixintemplate ImplementTestAllocPullFilter()
Undocumented in source.
ImplementTestAllocPushFilter
mixintemplate ImplementTestAllocPushFilter()
Undocumented in source.
ImplementTestAllocSink
mixintemplate ImplementTestAllocSink()
Undocumented in source.
ImplementTestAllocSource
mixintemplate ImplementTestAllocSource()
Undocumented in source.
ImplementTestPeekAllocFilter
mixintemplate ImplementTestPeekAllocFilter()
Undocumented in source.
ImplementTestPeekFilter
mixintemplate ImplementTestPeekFilter()
Undocumented in source.
ImplementTestPeekPullFilter
mixintemplate ImplementTestPeekPullFilter()
Undocumented in source.
ImplementTestPeekPushFilter
mixintemplate ImplementTestPeekPushFilter()
Undocumented in source.
ImplementTestPeekSink
mixintemplate ImplementTestPeekSink()
Undocumented in source.
ImplementTestPeekSource
mixintemplate ImplementTestPeekSource()
Undocumented in source.
ImplementTestPullAllocFilter
mixintemplate ImplementTestPullAllocFilter()
Undocumented in source.
ImplementTestPullFilter
mixintemplate ImplementTestPullFilter()
Undocumented in source.
ImplementTestPullPeekFilter
mixintemplate ImplementTestPullPeekFilter()
Undocumented in source.
ImplementTestPullPushFilter
mixintemplate ImplementTestPullPushFilter()
Undocumented in source.
ImplementTestPullSink
mixintemplate ImplementTestPullSink()
Undocumented in source.
ImplementTestPullSource
mixintemplate ImplementTestPullSource()
Undocumented in source.
ImplementTestPushAllocFilter
mixintemplate ImplementTestPushAllocFilter()
Undocumented in source.
ImplementTestPushFilter
mixintemplate ImplementTestPushFilter()
Undocumented in source.
ImplementTestPushPeekFilter
mixintemplate ImplementTestPushPeekFilter()
Undocumented in source.
ImplementTestPushPullFilter
mixintemplate ImplementTestPushPullFilter()
Undocumented in source.
ImplementTestPushSink
mixintemplate ImplementTestPushSink()
Undocumented in source.
ImplementTestPushSource
mixintemplate ImplementTestPushSource()
Undocumented in source.
TestStage
mixintemplate TestStage(N...)
Undocumented in source.

Structs

Arg
struct Arg(alias T)
Undocumented in source.
Pipeline
struct Pipeline(DriveMode mode, S...)

A pipeline built based on schema S.

Schema
struct Schema(DriveMode mode, S...)

Schema is an expression template that holds the information about the sequence of stages that constitute the pipeline and arguments passed to their constructors when the pipeline is instantiated.

TestAllocSink
struct TestAllocSink(alias Context, A...)
Undocumented in source.
TestAllocSource
struct TestAllocSource(alias Context, A...)
Undocumented in source.
TestPeekSink
struct TestPeekSink(alias Context, A...)
Undocumented in source.
TestPeekSource
struct TestPeekSource(alias Context, A...)
Undocumented in source.
TestPullSink
struct TestPullSink(alias Context, A...)
Undocumented in source.
TestPullSource
struct TestPullSource(alias Context, A...)
Undocumented in source.
TestPushSink
struct TestPushSink(alias Context, A...)
Undocumented in source.
TestPushSource
struct TestPushSource(alias Context, A...)
Undocumented in source.
UniversalTestSink
struct UniversalTestSink(alias Context, A...)
Undocumented in source.
UniversalTestSource
struct UniversalTestSource(alias Context, A...)
Undocumented in source.

Variables

inputArray
ulong[] inputArray;
Undocumented in source.
isSchema
enum bool isSchema(P);

Checks if the type argument is a pipeline schema.

outputArray
ulong[] outputArray;
Undocumented in source.
outputIndex
size_t outputIndex;
Undocumented in source.

Meta

License

BSL-1.0.