queue

Documentation

Index

• type ConsumerService
  • func (s *ConsumerService) CreateFeed(ctx context.Context, post *model.Post) error
  • func (s *ConsumerService) DeletePostFromFeed(ctx context.Context, post *model.Post) error
  • func (s *ConsumerService) Run() error
  • func (s *ConsumerService) UpdatePostInFeed(ctx context.Context, previousPost, post *model.Post) error
• type NotificationService
  • func (s *NotificationService) PublishNotification(post *model.Post, routingKey string) error
• type ProducerService
  • func (s *ProducerService) CreateFeed(post *model.Post) error
  • func (s *ProducerService) DeleteFromFeed(post *model.Post) error

Types

type ConsumerService

type ConsumerService struct {
	Consumer            rabbit.Consumer
	Logger              *zap.Logger
	FriendService       friend.Service
	CacheService        cache.Service
	NotificationService *NotificationService
}

func (*ConsumerService) CreateFeed

func (s *ConsumerService) CreateFeed(ctx context.Context, post *model.Post) error

func (*ConsumerService) DeletePostFromFeed

func (s *ConsumerService) DeletePostFromFeed(ctx context.Context, post *model.Post) error

func (*ConsumerService) Run

func (s *ConsumerService) Run() error

func (*ConsumerService) UpdatePostInFeed

func (s *ConsumerService) UpdatePostInFeed(ctx context.Context, previousPost, post *model.Post) error

type NotificationService

type NotificationService struct {
	Producer rabbit.Publisher
	Logger   *zap.Logger
}

func (*NotificationService) PublishNotification

func (s *NotificationService) PublishNotification(post *model.Post, routingKey string) error

type ProducerService

type ProducerService struct {
	Producer   rabbit.Publisher
	Logger     *zap.Logger
	RoutingKey string
}

func (*ProducerService) CreateFeed

func (s *ProducerService) CreateFeed(post *model.Post) error

func (*ProducerService) DeleteFromFeed

func (s *ProducerService) DeleteFromFeed(post *model.Post) error