biznetzach

Documentation

Index

• type Netzach
  • func NewNetzach(repo NetzachRepo, supv *supervisor.Supervisor, sClient *client.Searcher, ...) *Netzach
  • 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) UpdateNotifyFlow(ctx context.Context, flow *modelnetzach.NotifyFlow) *errors.Error
  • func (n *Netzach) UpdateNotifyTarget(ctx context.Context, target *modelnetzach.NotifyTarget) *errors.Error
• type NetzachRepo

Types

type Netzach

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

func NewNetzach

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

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,
	destinations []string,
	statuses []modelnetzach.NotifyTargetStatus,
) ([]*modelnetzach.NotifyTarget, 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,
		[]string, []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)
}