service

Documentation

Index

• Variables
• type MessengerService
  • func NewMessengerService(uc *biz.MessengerUsecase, p kafka.MessagesProducer) *MessengerService
  • func (s *MessengerService) Send(ctx context.Context, in *v1.SendRequest) (*v1.NewMessage, error)
  • func (s *MessengerService) Subscribe(req *v1.SubscribeRequest, conn v1.Messenger_SubscribeServer) error

Variables

var ProviderSet = wire.NewSet(NewMessengerService)

ProviderSet is service providers.

Types

type MessengerService

type MessengerService struct {
	v1.UnimplementedMessengerServer
	// contains filtered or unexported fields
}

MessengerService is a messenger service.

func NewMessengerService

func NewMessengerService(uc *biz.MessengerUsecase, p kafka.MessagesProducer) *MessengerService

NewMessengerService new a messenger service.

func (*MessengerService) Send

func (s *MessengerService) Send(ctx context.Context, in *v1.SendRequest) (*v1.NewMessage, error)

Send implements messenger.Send.

func (*MessengerService) Subscribe

func (s *MessengerService) Subscribe(req *v1.SubscribeRequest, conn v1.Messenger_SubscribeServer) error

Subscribe implements messenger.Subscribe.