consumer

Documentation

Index

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

Variables

var (
	ErrNotStarted     = errors.New("SERVICES.STORAGE.NOT_STARTED")
	ErrAlreadyStarted = errors.New("SERVICES.STORAGE.ALREAD_STARTED")
)

Functions

func Handler

func Handler(service *storage) streaming.SubHandler

func New

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