Documentation ¶
Index ¶
- Variables
- type NotifyConsumer
- 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)
- func (ns *NotifyService) NotifyTestEmail(ctx context.Context, req *notify.NotifyTestEmailReq) (*notify.Empty, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet( NewNotifyService, )
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type NotifyConsumer ¶ added in v0.3.2
type NotifyConsumer struct {
// contains filtered or unexported fields
}
func NewNotifyConsumer ¶ added in v0.3.2
func NewNotifyConsumer(s *NotifyService) *NotifyConsumer
func (*NotifyConsumer) Cleanup ¶ added in v0.3.2
func (s *NotifyConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*NotifyConsumer) ConsumeClaim ¶ added in v0.3.2
func (s *NotifyConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*NotifyConsumer) Setup ¶ added in v0.3.2
func (s *NotifyConsumer) Setup(sarama.ConsumerGroupSession) error
type NotifyService ¶
type NotifyService struct { notify.UnimplementedNotifyServer // contains filtered or unexported fields }
func NewNotifyService ¶
func NewNotifyService(dc *conf.NotifyConfig, k *conf.KafkaConfig, reg registry.Registrar) *NotifyService
func (*NotifyService) NotifyDeviceOffline ¶ added in v0.3.2
func (s *NotifyService) NotifyDeviceOffline(ctx context.Context, req *notify.NotifyDeviceOfflineReq) (*notify.Empty, error)
func (*NotifyService) NotifyDeviceOnline ¶ added in v0.3.2
func (s *NotifyService) NotifyDeviceOnline(ctx context.Context, req *notify.NotifyDeviceOnlineReq) (*notify.Empty, error)
func (*NotifyService) NotifyTestEmail ¶ added in v0.4.0
func (ns *NotifyService) NotifyTestEmail(ctx context.Context, req *notify.NotifyTestEmailReq) (*notify.Empty, error)
Click to show internal directories.
Click to hide internal directories.