notification

Documentation

Index

• type ConsumerModule
  • func NewConsumerModule(config *config.Config, logger *logger.Logger) *ConsumerModule
• type NotificationService
• type ServerModule
  • func NewServerModule(config *config.Config, logger *logger.Logger) (*ServerModule, error)

Types

type ConsumerModule

type ConsumerModule struct {
	NotificationConsumer *kafkaPKG.Consumer
}

ConsumerModule

func NewConsumerModule

func NewConsumerModule(config *config.Config, logger *logger.Logger) *ConsumerModule

type NotificationService

type NotificationService interface {
	Start()
	Stop()
}

NotificationService provides methods for starting and stopping a notification service.

type ServerModule

type ServerModule struct {
	NotificationService NotificationService
}

ServerModule provides access to the functionality of notification server module.

func NewServerModule

func NewServerModule(config *config.Config, logger *logger.Logger) (*ServerModule, error)

NewServerModule is a construction function for ServerModule.