core

package

Go to main page

Versions in this module

v0

v0.7.1

Aug 18, 2017

v0.7.0

Jul 21, 2017

v0.6.1

Jan 5, 2017

v0.6.0

Dec 5, 2016

Changes in this version

type ContextFlags

+ DestinationlessTupleLog AtomicFlag

v0.5.2

Sep 15, 2016

v0.5.1

Jul 14, 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.2

May 20, 2016

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

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