Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet( NewNotifyService, )
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type NotifyService ¶
type NotifyService struct {
// contains filtered or unexported fields
}
func NewNotifyService ¶
func NewNotifyService(dc *conf.DatabaseServerConfig, lc *conf.LogConfig) *NotifyService
type UserNotifyConsumer ¶
type UserNotifyConsumer struct {
// contains filtered or unexported fields
}
func NewUserNotifyConsumer ¶
func NewUserNotifyConsumer(userClient user.UserClient) *UserNotifyConsumer
func (*UserNotifyConsumer) Cleanup ¶
func (s *UserNotifyConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*UserNotifyConsumer) ConsumeClaim ¶
func (s *UserNotifyConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*UserNotifyConsumer) Setup ¶
func (s *UserNotifyConsumer) Setup(sarama.ConsumerGroupSession) error
Source Files
Click to show internal directories.
Click to hide internal directories.