facade

Documentation

Index

• type Message
• type NotificationFacade
  • func NewNotificationFacade(repository *notifications.NotificationRepository, log *zap.Logger) *NotificationFacade
  • func (f *NotificationFacade) Publish(ctx context.Context, flow string, message Message, userId string)

Types

type Message

type Message struct {
	Topic     string
	Header    string
	Body      string
	Params    map[string]string
	Meta      []string
	Timestamp int64
}

type NotificationFacade

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

func NewNotificationFacade

func NewNotificationFacade(repository *notifications.NotificationRepository, log *zap.Logger) *NotificationFacade

func (*NotificationFacade) Publish

func (f *NotificationFacade) Publish(ctx context.Context, flow string, message Message, userId string)