user

Documentation

Index

• func Start(ctx context.Context, config *Config, client registry.SvcDiscoveryRegistry, ...) error
• func WithUserDB(db controller.UserDatabase) userNotificationSenderOptions
• func WithUserFunc(...) userNotificationSenderOptions
• type Config
• type UserNotificationSender
  • func NewUserNotificationSender(config *Config, msgClient *rpcli.MsgClient, ...) *UserNotificationSender
  • func (u *UserNotificationSender) UserCommandAddNotification(ctx context.Context, tips *sdkws.UserCommandAddTips)
  • func (u *UserNotificationSender) UserCommandDeleteNotification(ctx context.Context, tips *sdkws.UserCommandDeleteTips)
  • func (u *UserNotificationSender) UserCommandUpdateNotification(ctx context.Context, tips *sdkws.UserCommandUpdateTips)
  • func (u *UserNotificationSender) UserStatusChangeNotification(ctx context.Context, tips *sdkws.UserStatusChangeTips)

Functions

func Start

func Start(ctx context.Context, config *Config, client registry.SvcDiscoveryRegistry, server *grpc.Server) error

func WithUserDB

func WithUserDB(db controller.UserDatabase) userNotificationSenderOptions

func WithUserFunc

func WithUserFunc(
	fn func(ctx context.Context, userIDs []string) (users []*relationtb.User, err error),
) userNotificationSenderOptions

Types

type Config

type Config struct {
	RpcConfig          config.User
	RedisConfig        config.Redis
	MongodbConfig      config.Mongo
	KafkaConfig        config.Kafka
	NotificationConfig config.Notification
	Share              config.Share
	WebhooksConfig     config.Webhooks
	LocalCacheConfig   config.LocalCache
	Discovery          config.Discovery
}

type UserNotificationSender

type UserNotificationSender struct {
	*rpcclient.NotificationSender
	// contains filtered or unexported fields
}

func NewUserNotificationSender

func NewUserNotificationSender(config *Config, msgClient *rpcli.MsgClient, opts ...userNotificationSenderOptions) *UserNotificationSender

func (*UserNotificationSender) UserCommandAddNotification

func (u *UserNotificationSender) UserCommandAddNotification(
	ctx context.Context,
	tips *sdkws.UserCommandAddTips,
)

func (*UserNotificationSender) UserCommandDeleteNotification

func (u *UserNotificationSender) UserCommandDeleteNotification(
	ctx context.Context,
	tips *sdkws.UserCommandDeleteTips,
)

func (*UserNotificationSender) UserCommandUpdateNotification

func (u *UserNotificationSender) UserCommandUpdateNotification(
	ctx context.Context,
	tips *sdkws.UserCommandUpdateTips,
)

func (*UserNotificationSender) UserStatusChangeNotification

func (u *UserNotificationSender) UserStatusChangeNotification(
	ctx context.Context,
	tips *sdkws.UserStatusChangeTips,
)