Documentation ¶
Index ¶
- Variables
- func MustRun()
- func Register(name string, opts ...option)
- func Run() error
- func WithInputBinding(factory func() bindings.InputBinding) option
- func WithOutputBinding(factory func() bindings.OutputBinding) option
- func WithPubSub(factory func() pubsub.PubSub) option
- func WithStateStore(factory func() state.Store) option
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoComponentsRegistered = errors.New("none components was registered")
ErrNoComponentsRegistered is returned when none components was registered.
View Source
var (
ErrNoneComponentsFound = errors.New("at least one component service should be defined")
)
Functions ¶
func Register ¶
func Register(name string, opts ...option)
Register a component with the given name.
func WithInputBinding ¶
func WithInputBinding(factory func() bindings.InputBinding) option
WithInputBinding adds inputbinding factory for the component.
func WithOutputBinding ¶
func WithOutputBinding(factory func() bindings.OutputBinding) option
WithOutputBinding adds outputbinding factory for the component.
func WithPubSub ¶
func WithPubSub(factory func() pubsub.PubSub) option
WithPubSub adds pubsub factory for the component.
func WithStateStore ¶
func WithStateStore(factory func() state.Store) option
WithStateStore adds statestore factory for the component.
Types ¶
This section is empty.
Directories ¶
Path | Synopsis |
---|---|
bindings
|
|
examples
|
|
bindings.kafka
Module
|
|
memory
Module
|
|
pubsub.kafka
Module
|
|
pubsub.memory
Module
|
|
pubsub.redis
Module
|
|
redis
Module
|
|
state.memory
Module
|
|
state.redis
Module
|
|
pubsub
|
|
state
|
|
Click to show internal directories.
Click to hide internal directories.