event

Documentation

Index

• func Dataflow(ctx context.Context) error
• func ErrorHandler(ctx context.Context, err error) bool
• func EventLogger(m event.EventWithContexter) (event.KeyValueWithContexter, error)
• func GetFanoutEventLogger(ctx context.Context, ...) (chan<- event.EventWithContexter, <-chan event.KeyValueWithContexter)
• func GetFanoutSaver(ctx context.Context, ...) (chan<- event.KeyValueWithContexter, <-chan context.Context)
• func GetFanoutStart(ctx context.Context, ...) (chan<- context.Context, <-chan event.EventWithContexter)
• func GetPipeEventLogger(ctx context.Context, ...) (chan<- event.EventWithContexter, <-chan event.KeyValueWithContexter)
• func GetPipeSaver(ctx context.Context, ...) (chan<- event.KeyValueWithContexter, <-chan context.Context)
• func GetPipeStart(ctx context.Context, ...) (chan<- context.Context, <-chan event.EventWithContexter)
• func Start(ctx context.Context) (event.EventWithContexter, error)
• type EventLoggerGetContexter
• type Saver
  • func (p *Saver) Save(m event.KeyValueWithContexter) (context.Context, error)
• type SaverGetContexter
• type StartGetContexter

Functions

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)

Types

type EventLoggerGetContexter

type EventLoggerGetContexter interface {
	GetContext() context.Context
}

type Saver

type Saver struct {
	Saver event.Saver
}

func (*Saver) Save

func (p *Saver) Save(m event.KeyValueWithContexter) (context.Context, error)

type SaverGetContexter

type SaverGetContexter interface {
	GetContext() context.Context
}

type StartGetContexter

type StartGetContexter interface {
	GetContext() context.Context
}