eventhandler

Documentation

Index

• Constants
• func Close(_ context.Context) error
• func HandleEvents(eventHandler EventHandler) func(ctx context.Context) error
• func Init(cfg *config.Config) func(context.Context) error
• func ProcudeConfimation(ctx context.Context, stock domain.Stock) error
• type EventHandler

Constants

const (
	OrderStream   = `orders_stream`
	ConfirmStream = `confirmation_stream`
	StockGroup    = `stock_group`
)

Functions

func Close

func Close(_ context.Context) error

func HandleEvents

func HandleEvents(eventHandler EventHandler) func(ctx context.Context) error

func Init

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

func ProcudeConfimation

func ProcudeConfimation(ctx context.Context, stock domain.Stock) error

Types

type EventHandler

type EventHandler func(domain.Event) (domain.Stock, error)