notifi

Documentation

Index

• Constants
• func SplitSubject(in string) (events.Subject, events.Topic, []string)
• type INotifi
  • func New(p Params) INotifi
• type Notifi
  • func (n *Notifi) NotifyUser(ctx context.Context, not *notifications.Notification) error
• type Params

Constants

const (
	StreamName = "NOTIFI"

	BaseSubject events.Subject = "notifi"

	// User notifications topic
	UserTopic events.Topic = "user"
	// Job event topic
	JobTopic events.Topic = "job"
	// System event topic
	SystemTopic events.Topic = "sys"
)

Functions

func SplitSubject

func SplitSubject(in string) (events.Subject, events.Topic, []string)

Types

type INotifi

type INotifi interface {
	NotifyUser(ctx context.Context, not *notifications.Notification) error
}

func New

func New(p Params) INotifi

type Notifi

type Notifi struct {
	// contains filtered or unexported fields
}

func (*Notifi) NotifyUser

func (n *Notifi) NotifyUser(ctx context.Context, not *notifications.Notification) error

type Params

type Params struct {
	fx.In

	LC     fx.Lifecycle
	Logger *zap.Logger
	DB     *sql.DB
	JS     *events.JSWrapper
}