events

Documentation

Index

• Variables
• type App
  • func New(ctx context.Context, cfg *configs.Configs) (*App, error)
  • func NewMinimum(ctx context.Context, cfg *configs.Configs) (*App, error)
  • func (app *App) Start() error
  • func (app *App) Stop() error

Variables

var (
	ErrNoApp      = errors.New("events: app was not constructed")
	ErrQueueEmpty = errors.New("events: queue name of subscriber could not be empty")
)

Types

type App

type App struct {
	Logger  *zap.SugaredLogger
	Configs *configs.Configs

	Datastore datastore.Database
	MsgBus    msgbus.MsgBus
	Metrics   xmetrics.Metrics
}

func New

func New(ctx context.Context, cfg *configs.Configs) (*App, error)

func NewMinimum

func NewMinimum(ctx context.Context, cfg *configs.Configs) (*App, error)

func (*App) Start

func (app *App) Start() error

func (*App) Stop

func (app *App) Stop() error