biznetzach

Documentation

Index

• Variables
• func NewSystemNotificationTopic(repo NetzachRepo, searcher *client.Searcher) *libmq.Topic[modelnetzach.SystemNotify]
• type Netzach
  • func NewNetzach(repo NetzachRepo, supv *supervisor.Supervisor, sClient *client.Searcher, ...) (*Netzach, error)
  • func (n *Netzach) CreateNotifyFlow(ctx context.Context, flow *modelnetzach.NotifyFlow) (model.InternalID, *errors.Error)
  • func (n *Netzach) CreateNotifyTarget(ctx context.Context, target *modelnetzach.NotifyTarget) (model.InternalID, *errors.Error)
  • func (n *Netzach) ListNotifyFlows(ctx context.Context, paging model.Paging, ids []model.InternalID) ([]*modelnetzach.NotifyFlow, int64, *errors.Error)
  • func (n *Netzach) ListNotifyTargets(ctx context.Context, paging model.Paging, ids []model.InternalID, ...) ([]*modelnetzach.NotifyTarget, int64, *errors.Error)
  • func (n *Netzach) ListSystemNotifications(ctx context.Context, paging model.Paging, ...) ([]*modelnetzach.SystemNotification, int64, *errors.Error)
  • func (n *Netzach) UpdateNotifyFlow(ctx context.Context, flow *modelnetzach.NotifyFlow) *errors.Error
  • func (n *Netzach) UpdateNotifyTarget(ctx context.Context, target *modelnetzach.NotifyTarget) *errors.Error
• type NetzachRepo

Variables

var ProviderSet = wire.NewSet(
	NewNetzach,
	NewSystemNotificationTopic,
)

Functions

func NewSystemNotificationTopic

func NewSystemNotificationTopic(
	repo NetzachRepo,
	searcher *client.Searcher,
) *libmq.Topic[modelnetzach.SystemNotify]

Types

type Netzach

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

func NewNetzach

func NewNetzach(
	repo NetzachRepo,
	supv *supervisor.Supervisor,
	sClient *client.Searcher,
	mq *libmq.MQ,
	notifySourceCache *libcache.Map[model.InternalID, modelangela.FeedToNotifyFlowValue],
	notifyFlowCache *libcache.Map[model.InternalID, modelnetzach.NotifyFlow],
	notifyTargetCache *libcache.Map[model.InternalID, modelnetzach.NotifyTarget],
	systemNotification *libmq.Topic[modelnetzach.SystemNotify],
) (*Netzach, error)

func (*Netzach) CreateNotifyFlow

func (n *Netzach) CreateNotifyFlow(ctx context.Context, flow *modelnetzach.NotifyFlow) (
	model.InternalID, *errors.Error)

func (*Netzach) CreateNotifyTarget

func (n *Netzach) CreateNotifyTarget(ctx context.Context, target *modelnetzach.NotifyTarget) (
	model.InternalID, *errors.Error)

func (*Netzach) ListNotifyFlows

func (n *Netzach) ListNotifyFlows(
	ctx context.Context,
	paging model.Paging,
	ids []model.InternalID,
) ([]*modelnetzach.NotifyFlow, int64, *errors.Error)

func (*Netzach) ListNotifyTargets

func (n *Netzach) ListNotifyTargets(
	ctx context.Context,
	paging model.Paging,
	ids []model.InternalID,
	statuses []modelnetzach.NotifyTargetStatus,
) ([]*modelnetzach.NotifyTarget, int64, *errors.Error)

func (*Netzach) ListSystemNotifications

func (n *Netzach) ListSystemNotifications(
	ctx context.Context,
	paging model.Paging,
	types []modelnetzach.SystemNotificationType,
	levels []modelnetzach.SystemNotificationLevel,
	statuses []modelnetzach.SystemNotificationStatus,
) ([]*modelnetzach.SystemNotification, int64, *errors.Error)

func (*Netzach) UpdateNotifyFlow

func (n *Netzach) UpdateNotifyFlow(ctx context.Context, flow *modelnetzach.NotifyFlow) *errors.Error

func (*Netzach) UpdateNotifyTarget

func (n *Netzach) UpdateNotifyTarget(ctx context.Context, target *modelnetzach.NotifyTarget) *errors.Error

type NetzachRepo

type NetzachRepo interface {
	CreateNotifyTarget(context.Context, model.InternalID, *modelnetzach.NotifyTarget) error
	UpdateNotifyTarget(context.Context, model.InternalID, *modelnetzach.NotifyTarget) error
	ListNotifyTargets(context.Context, model.Paging, model.InternalID, []model.InternalID,
		[]modelnetzach.NotifyTargetStatus) (
		[]*modelnetzach.NotifyTarget, int64, error)
	GetNotifyTarget(context.Context, model.InternalID) (*modelnetzach.NotifyTarget, error)
	CreateNotifyFlow(context.Context, model.InternalID, *modelnetzach.NotifyFlow) error
	UpdateNotifyFlow(context.Context, model.InternalID, *modelnetzach.NotifyFlow) error
	ListNotifyFlows(context.Context, model.Paging, model.InternalID, []model.InternalID) (
		[]*modelnetzach.NotifyFlow, int64, error)
	GetNotifyFlow(context.Context, model.InternalID) (*modelnetzach.NotifyFlow, error)
	GetNotifyFlowIDsWithFeed(context.Context, model.InternalID) ([]model.InternalID, error)

	UpsertSystemNotification(context.Context, model.InternalID, *modelnetzach.SystemNotification) error
	ListSystemNotifications(context.Context, model.Paging, *model.InternalID, []modelnetzach.SystemNotificationType,
		[]modelnetzach.SystemNotificationLevel, []modelnetzach.SystemNotificationStatus) (
		[]*modelnetzach.SystemNotification, int64, error)
}