event

func Dataflow ¶

func Dataflow(ctx context.Context) error

func ErrorHandler ¶

func ErrorHandler(ctx context.Context, err error) bool

ErrorHandler ...

func EventLogger ¶

func EventLogger(m event.EventWithContexter) (event.KeyValueWithContexter, error)

func GetFanoutEventLogger ¶

func GetFanoutEventLogger(
	ctx context.Context,
	fn func(event.EventWithContexter) ([]event.KeyValueWithContexter, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- event.EventWithContexter,
	<-chan event.KeyValueWithContexter,
)

GetFanoutEventLogger returns new input(chan<- EventEventWithContexter)/output(<-chan EventKeyValueWithContexter) channels that embedded the given 'func(EventEventWithContexter) EventKeyValueWithContexter'.

func GetFanoutSaver ¶

func GetFanoutSaver(
	ctx context.Context,
	fn func(event.KeyValueWithContexter) ([]context.Context, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- event.KeyValueWithContexter,
	<-chan context.Context,
)

GetFanoutSaver returns new input(chan<- EventKeyValueWithContexter)/output(<-chan ContextContext) channels that embedded the given 'func(EventKeyValueWithContexter) ContextContext'.

func GetFanoutStart ¶

func GetFanoutStart(
	ctx context.Context,
	fn func(context.Context) ([]event.EventWithContexter, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- context.Context,
	<-chan event.EventWithContexter,
)

GetFanoutStart returns new input(chan<- ContextContext)/output(<-chan EventEventWithContexter) channels that embedded the given 'func(ContextContext) EventEventWithContexter'.

func GetPipeEventLogger ¶

func GetPipeEventLogger(
	ctx context.Context,
	fn func(event.EventWithContexter) (event.KeyValueWithContexter, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- event.EventWithContexter,
	<-chan event.KeyValueWithContexter,
)

GetPipeEventLogger returns new input(chan<- EventEventWithContexter)/output(<-chan EventKeyValueWithContexter) channels that embedded the given 'func(EventEventWithContexter) EventKeyValueWithContexter'.

func GetPipeSaver ¶

func GetPipeSaver(
	ctx context.Context,
	fn func(event.KeyValueWithContexter) (context.Context, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- event.KeyValueWithContexter,
	<-chan context.Context,
)

GetPipeSaver returns new input(chan<- EventKeyValueWithContexter)/output(<-chan ContextContext) channels that embedded the given 'func(EventKeyValueWithContexter) ContextContext'.

func GetPipeStart ¶

func GetPipeStart(
	ctx context.Context,
	fn func(context.Context) (event.EventWithContexter, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- context.Context,
	<-chan event.EventWithContexter,
)

GetPipeStart returns new input(chan<- ContextContext)/output(<-chan EventEventWithContexter) channels that embedded the given 'func(ContextContext) EventEventWithContexter'.

func Start ¶

func Start(ctx context.Context) (event.EventWithContexter, error)