events

Documentation

Overview

Package events provides the event consumer for the journal service. This package is responsible for consuming events from the event store and processing them.

Index

• Variables
• func Handle(service journal.Service) handleFunc
• func Start(ctx context.Context, consumer string, sub events.Subscriber, ...) error

Variables

var ErrMissingOccurredAt = errors.New("missing occurred_at")

Functions

func Handle

func Handle(service journal.Service) handleFunc

func Start

func Start(ctx context.Context, consumer string, sub events.Subscriber, service journal.Service) error

Start method starts consuming messages received from Event store.