listener

Documentation

Index

• func NewCommentListener(optionService service.OptionService, postService service.PostService, ...)
• func NewLogEventListener(db *gorm.DB, bus event.Bus)
• func NewPostUpdateListener(bus event.Bus, categoryService service.CategoryService, ...)
• func NewStartListener(db *gorm.DB, optionService service.OptionService, bus event.Bus)
• func NewTemplateConfigListener(bus event.Bus, template *template.Template, themeService service.ThemeService, ...)
• type CommentListener
  • func (c *CommentListener) HandleCommentNew(ctx context.Context, ce event.Event) error
  • func (c *CommentListener) HandleCommentReply(ctx context.Context, ce event.Event) error
• type LogEventListener
  • func (l *LogEventListener) HandleEvent(ctx context.Context, logEvent event.Event) error
• type PostUpdateListener
  • func (p *PostUpdateListener) HandlePostUpdateEvent(ctx context.Context, postUpdateEvent event.Event) error
• type StartListener
  • func (s *StartListener) HandleEvent(ctx context.Context, startEvent event.Event) error
• type TemplateConfigListener
  • func (t *TemplateConfigListener) HandleOptionUpdateEvent(ctx context.Context, optionUpdateEvent event.Event) error
  • func (t *TemplateConfigListener) HandleStartEvent(ctx context.Context, startEvent event.Event) error
  • func (t *TemplateConfigListener) HandleThemeFileUpdateEvent(ctx context.Context, themeFileUpdateEvent event.Event) error
  • func (t *TemplateConfigListener) HandleThemeUpdateEvent(ctx context.Context, themeUpdateEvent event.Event) error
  • func (t *TemplateConfigListener) HandleUserUpdateEvent(ctx context.Context, userUpdateEvent event.Event) error

Functions

func NewCommentListener

func NewCommentListener(
	optionService service.OptionService,
	postService service.PostService,
	journalService service.JournalService,
	sheetService service.SheetService,
	bus event.Bus,
	postAssembler assembler.PostAssembler,
	themeService service.ThemeService,
	emailService service.EmailService,
	userService service.UserService,
	template *template.Template,
	baseCommentService service.BaseCommentService,
)

func NewLogEventListener

func NewLogEventListener(db *gorm.DB, bus event.Bus)

func NewPostUpdateListener

func NewPostUpdateListener(bus event.Bus,
	categoryService service.CategoryService,
	postCategoryService service.PostCategoryService,
	postService service.PostService,
)

func NewStartListener

func NewStartListener(db *gorm.DB, optionService service.OptionService, bus event.Bus)

func NewTemplateConfigListener

func NewTemplateConfigListener(bus event.Bus,
	template *template.Template,
	themeService service.ThemeService,
	optionService service.ClientOptionService,
	logger *zap.Logger,
	userService service.UserService,
	config *config.Config, server *handler.Server,
)

Types

type CommentListener

type CommentListener struct {
	OptionService      service.OptionService
	PostService        service.PostService
	PostAssembler      assembler.PostAssembler
	JournalService     service.JournalService
	SheetService       service.SheetService
	ThemeService       service.ThemeService
	EmailService       service.EmailService
	UserService        service.UserService
	BaseCommentService service.BaseCommentService
	Template           *template.Template
}

func (*CommentListener) HandleCommentNew

func (c *CommentListener) HandleCommentNew(ctx context.Context, ce event.Event) error

func (*CommentListener) HandleCommentReply

func (c *CommentListener) HandleCommentReply(ctx context.Context, ce event.Event) error

type LogEventListener

type LogEventListener struct {
	// contains filtered or unexported fields
}

func (*LogEventListener) HandleEvent

func (l *LogEventListener) HandleEvent(ctx context.Context, logEvent event.Event) error

type PostUpdateListener

type PostUpdateListener struct {
	CategoryService     service.CategoryService
	PostCategoryService service.PostCategoryService
	PostService         service.PostService
}

func (*PostUpdateListener) HandlePostUpdateEvent

func (p *PostUpdateListener) HandlePostUpdateEvent(ctx context.Context, postUpdateEvent event.Event) error

type StartListener

type StartListener struct {
	// contains filtered or unexported fields
}

func (*StartListener) HandleEvent

func (s *StartListener) HandleEvent(ctx context.Context, startEvent event.Event) error

type TemplateConfigListener

type TemplateConfigListener struct {
	Template      *template.Template
	ThemeService  service.ThemeService
	OptionService service.ClientOptionService
	UserService   service.UserService
	Logger        *zap.Logger
	Config        *config.Config
	Router        *gin.Engine
}

func (*TemplateConfigListener) HandleOptionUpdateEvent

func (t *TemplateConfigListener) HandleOptionUpdateEvent(ctx context.Context, optionUpdateEvent event.Event) error

func (*TemplateConfigListener) HandleStartEvent

func (t *TemplateConfigListener) HandleStartEvent(ctx context.Context, startEvent event.Event) error

func (*TemplateConfigListener) HandleThemeFileUpdateEvent

func (t *TemplateConfigListener) HandleThemeFileUpdateEvent(ctx context.Context, themeFileUpdateEvent event.Event) error

func (*TemplateConfigListener) HandleThemeUpdateEvent

func (t *TemplateConfigListener) HandleThemeUpdateEvent(ctx context.Context, themeUpdateEvent event.Event) error

func (*TemplateConfigListener) HandleUserUpdateEvent

func (t *TemplateConfigListener) HandleUserUpdateEvent(ctx context.Context, userUpdateEvent event.Event) error