core

package

Go to main page

Versions in this module

v0

v0.7.0

Jul 21, 2017

v0.6.1

Jan 5, 2017

Changes in this version

type ContextFlags

+ DestinationlessTupleLog AtomicFlag

v0.5.2

Sep 15, 2016

v0.5.0

Jul 7, 2016

Changes in this version

+ const MaxCapacity

type BoxInputConfig

+ func (c *BoxInputConfig) Validate() error

type SinkInputConfig

+ func (c *SinkInputConfig) Validate() error

v0.4.1

Mar 11, 2016

Changes in this version

+ var ErrSourceRewound = errors.New("the source has been rewound")

+ var ErrSourceStopped = errors.New("the source has been stopped")

+ func FatalError(err error) error

+ func IsFatalError(err error) bool

+ func IsNotExist(err error) bool

+ func IsTemporaryError(err error) bool

+ func NewTemporaryID() int64

+ func NotExistError(err error) error

+ func TemporaryError(err error) error

+ func ValidateSymbol(name string) error

+ type AtomicFlag int32

+ func (a *AtomicFlag) Enabled() bool

+ func (a *AtomicFlag) Set(b bool)

+ type Box interface

+ Process func(ctx *Context, t *Tuple, w Writer) error

+ func BoxFunc(b func(ctx *Context, t *Tuple, w Writer) error) Box

+ type BoxConfig struct

+ Meta interface{}

+ RemoveOnStop bool

+ type BoxInputConfig struct

+ Capacity int

+ DropMode QueueDropMode

+ InputName string

+ type BoxNode interface

+ Box func() Box

+ EnableGracefulStop func()

+ Input func(refname string, config *BoxInputConfig) error

+ StopOnDisconnect func(dir ConnDir)

+ type ConnDir int

+ const Inbound

+ const Outbound

+ type Context struct

+ Flags ContextFlags

+ SharedStates SharedStateRegistry

+ func NewContext(config *ContextConfig) *Context

+ func (c *Context) ErrLog(err error) *logrus.Entry

+ func (c *Context) Log() *logrus.Entry

+ type ContextConfig struct

+ Flags ContextFlags

+ Logger *logrus.Logger

+ type ContextFlags struct

+ DroppedTupleLog AtomicFlag

+ DroppedTupleSummarization AtomicFlag

+ TupleTrace AtomicFlag

+ type EventType int

+ const ETInput

+ const ETOther

+ const ETOutput

+ func (t EventType) String() string

+ type LoadableSharedState interface

+ Load func(ctx *Context, r io.Reader, params data.Map) error

+ type NamedInputBox interface

+ InputNames func() []string

+ type Node interface

+ Meta func() interface{}

+ Name func() string

+ RemoveOnStop func()

+ State func() TopologyStateHolder

+ Status func() data.Map

+ Stop func() error

+ Type func() NodeType

+ type NodeType int

+ const NTBox

+ const NTSink

+ const NTSource

+ func (t NodeType) String() string

+ type QueueDropMode int

+ const DropLatest

+ const DropNone

+ const DropOldest

+ type Resumable interface

+ Pause func(ctx *Context) error

+ Resume func(ctx *Context) error

+ type RewindableSource interface

+ Rewind func(ctx *Context) error

+ func NewRewindableSource(s Source) RewindableSource

+ type SavableSharedState interface

+ Save func(ctx *Context, w io.Writer, params data.Map) error

+ type SharedState interface

+ Terminate func(ctx *Context) error

+ type SharedStateRegistry interface

+ Add func(name, typeName string, s SharedState) error

+ Get func(name string) (SharedState, error)

+ List func() (map[string]SharedState, error)

+ Remove func(name string) (SharedState, error)

+ Replace func(name, typeName string, s SharedState) (SharedState, error)

+ Type func(name string) (string, error)

+ func NewDefaultSharedStateRegistry(ctx *Context) SharedStateRegistry

+ type Sink interface

+ func NewSharedStateSink(ctx *Context, name string) (Sink, error)

+ type SinkConfig struct

+ Meta interface{}

+ RemoveOnStop bool

+ type SinkInputConfig struct

+ Capacity int

+ DropMode QueueDropMode

+ type SinkNode interface

+ EnableGracefulStop func()

+ Input func(refname string, config *SinkInputConfig) error

+ Sink func() Sink

+ StopOnDisconnect func()

+ type Source interface

+ GenerateStream func(ctx *Context, w Writer) error

+ Stop func(ctx *Context) error

+ func ImplementSourceStop(s Source) Source

+ func NewDroppedTupleCollectorSource() Source

+ type SourceConfig struct

+ Meta interface{}

+ PausedOnStartup bool

+ RemoveOnStop bool

+ type SourceNode interface

+ Pause func() error

+ Resume func() error

+ Rewind func() error

+ Source func() Source

+ StopOnDisconnect func()

+ type StatefulBox interface

+ Init func(ctx *Context) error

+ Terminate func(ctx *Context) error

+ type Statuser interface

+ Status func() data.Map

+ type Topology interface

+ AddBox func(name string, b Box, config *BoxConfig) (BoxNode, error)

+ AddSink func(name string, s Sink, config *SinkConfig) (SinkNode, error)

+ AddSource func(name string, s Source, config *SourceConfig) (SourceNode, error)

+ Box func(name string) (BoxNode, error)

+ Boxes func() map[string]BoxNode

+ Context func() *Context

+ Name func() string

+ Node func(name string) (Node, error)

+ Nodes func() map[string]Node

+ Remove func(name string) error

+ Sink func(name string) (SinkNode, error)

+ Sinks func() map[string]SinkNode

+ Source func(name string) (SourceNode, error)

+ Sources func() map[string]SourceNode

+ State func() TopologyStateHolder

+ Stop func() error

+ func NewDefaultTopology(ctx *Context, name string) (Topology, error)

+ type TopologyState int

+ const TSInitialized

+ const TSPaused

+ const TSRunning

+ const TSStarting

+ const TSStopped

+ const TSStopping

+ func (s TopologyState) String() string

+ type TopologyStateHolder interface

+ Get func() TopologyState

+ Wait func(s TopologyState) TopologyState

+ type TraceEvent struct

+ Msg string

+ Timestamp time.Time

+ Type EventType

+ type Tuple struct

+ BatchID int64

+ Data data.Map

+ Flags TupleFlags

+ InputName string

+ ProcTimestamp time.Time

+ Timestamp time.Time

+ Trace []TraceEvent

+ func NewTuple(d data.Map) *Tuple

+ func (t *Tuple) AddEvent(ev TraceEvent)

+ func (t *Tuple) Copy() *Tuple

+ func (t *Tuple) ShallowCopy() *Tuple

+ type TupleFlags uint32

+ const TFDropped

+ const TFShared

+ const TFSharedData

+ func (f *TupleFlags) Clear(v TupleFlags)

+ func (f *TupleFlags) IsSet(v TupleFlags) bool

+ func (f *TupleFlags) Set(v TupleFlags)

+ type Updater interface

+ Update func(ctx *Context, params data.Map) error

+ type WriteCloser interface

+ Close func(ctx *Context) error

+ type Writer interface

+ Write func(ctx *Context, t *Tuple) error

+ func WriterFunc(f func(ctx *Context, t *Tuple) error) Writer

v0.3.1

Oct 30, 2015

v0.3.0

Sep 4, 2015

v0.1.0

Aug 3, 2015

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL