Documentation ¶
Index ¶
- Variables
- func MarshalOptions(opts interface{}) map[string]interface{}
- func WithBlocking(blocking bool) options.Option
- func WithBufferSize(size int) options.Option
- func WithClose(close bool) options.Option
- func WithEOSExit(exit bool) options.Option
- func WithEnable(b bool) options.Option
- func WithIgnoreErrors(ignore bool) options.Option
- func WithMapping(opt map[string]interface{}) options.Option
- func WithName(name string) options.Option
- type Builder
- type Options
- type Plugin
- type Registry
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Global = New() ErrExists = errors.New("already exists") ErrNotFound = errors.New("not found") ErrCorruptedRegistry = errors.New("registry seems to be corrupted") )
View Source
var ErrNOP = errors.New("No op")
Functions ¶
func MarshalOptions ¶
func MarshalOptions(opts interface{}) map[string]interface{}
func WithBlocking ¶
/ Sets whether output should be blocking. / Non blocking will skip data.
func WithEOSExit ¶
/ Stop the step if End Of Stream is detected
func WithMapping ¶
/ Update Options struct with values inside the map. / Usecase: write/read options to JSON.
Types ¶
type Options ¶
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func (*Registry) Unregister ¶
Click to show internal directories.
Click to hide internal directories.