eventhandler

Documentation

Index

• Constants
• func Close(_ context.Context) error
• func HandleEvents(handler EventHandler) func(context.Context) error
• func Init(cfg *config.Config) func(context.Context) error
• func Produce(ctx context.Context, event schema.OrderEvent) error
• type EventHandler

Constants

const (
	OrderStream   = `orders_stream`
	ConfirmStream = `confirmation_stream`
	OrderGroup    = `orders_group`
)

Functions

func Close

func Close(_ context.Context) error

func HandleEvents

func HandleEvents(handler EventHandler) func(context.Context) error

func Init

func Init(cfg *config.Config) func(context.Context) error

func Produce

func Produce(ctx context.Context, event schema.OrderEvent) error

Types

type EventHandler

type EventHandler func(context.Context, uuid.UUID, domain.Event) (domain.Order, error)