consumer

Documentation

Index

• Variables
• func Handler(service *consumer) streaming.SubHandler
• func New(conf *config.Config, logger logging.Logger, ...) patterns.Runnable

Variables

var (
	ErrNotStarted     = errors.New("ATTEMPT.ENTRYPOINT.CONSUMER.NOT_STARTED")
	ErrAlreadyStarted = errors.New("ATTEMPT.ENTRYPOINT.CONSUMER.ALREAD_STARTED")
)

Functions

func Handler

func Handler(service *consumer) streaming.SubHandler

func New

func New(
	conf *config.Config,
	logger logging.Logger,
	infra *infrastructure.Infrastructure,
	db database.Database,
	ds datastore.Datastore,
	uc usecase.Attempt,
) patterns.Runnable