Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewMessengerService)
ProviderSet is service providers.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.