notify

May 12, 2024

Changes in this version

type NotifyService

+ func (ns *NotifyService) NotifyTestEmail(ctx context.Context, req *notify.NotifyTestEmailReq) (*notify.Empty, error)

Mar 14, 2024

Changes in this version

+ type NotifyConsumer struct

+ func NewNotifyConsumer(s *NotifyService) *NotifyConsumer

+ func (s *NotifyConsumer) Cleanup(sarama.ConsumerGroupSession) error

+ func (s *NotifyConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (s *NotifyConsumer) Setup(sarama.ConsumerGroupSession) error

type NotifyService

+ func (s *NotifyService) NotifyDeviceOffline(ctx context.Context, req *notify.NotifyDeviceOfflineReq) (*notify.Empty, error)

+ func (s *NotifyService) NotifyDeviceOnline(ctx context.Context, req *notify.NotifyDeviceOnlineReq) (*notify.Empty, error)

Mar 8, 2024

Changes in this version

+ var ProviderSet = wire.NewSet(NewNotifyService)

+ type NotifyService struct

+ func NewNotifyService(dc *conf.DatabaseServerConfig, lc *conf.LogConfig) *NotifyService

+ type UserNotifyConsumer struct

+ func NewUserNotifyConsumer(userClient user.UserClient) *UserNotifyConsumer

+ func (s *UserNotifyConsumer) Cleanup(sarama.ConsumerGroupSession) error

+ func (s *UserNotifyConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (s *UserNotifyConsumer) Setup(sarama.ConsumerGroupSession) error