bizangela

Documentation

Index

• Variables
• func NewAppInfoCache(g bizgebura.GeburaRepo, store libcache.Store) *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo]
• func NewFeedToNotifyFlowCache(n biznetzach.NetzachRepo, store libcache.Store) *libcache.Map[model.InternalID, modelangela.FeedToNotifyFlowValue]
• func NewNotifyFlowCache(n biznetzach.NetzachRepo, store libcache.Store) *libcache.Map[model.InternalID, modelnetzach.NotifyFlow]
• func NewNotifyPushTopic(a *AngelaBase, ...) *libmq.Topic[modelangela.NotifyPush]
• func NewNotifyRouterTopic(a *AngelaBase, ...) *libmq.Topic[modelangela.NotifyRouter]
• func NewNotifyTargetCache(n biznetzach.NetzachRepo, store libcache.Store) *libcache.Map[model.InternalID, modelnetzach.NotifyTarget]
• func NewParseFeedItemDigestTopic(a *AngelaBase) *libmq.Topic[modelangela.ParseFeedItemDigest]
• func NewPullAccountAppInfoRelationTopic(a *AngelaBase, sa *libmq.Topic[modelangela.PullAppInfo]) *libmq.Topic[modelangela.PullAccountAppInfoRelation]
• func NewPullAccountTopic(a *AngelaBase, sr *libmq.Topic[modelangela.PullAccountAppInfoRelation]) *libmq.Topic[modeltiphereth.PullAccountInfo]
• func NewPullAppInfoTopic(a *AngelaBase, ...) *libmq.Topic[modelangela.PullAppInfo]
• func NewPullFeedTopic(a *AngelaBase, notify *libmq.Topic[modelangela.NotifyRouter], ...) *libmq.Topic[modelyesod.PullFeed]
• func NewUpdateAppInfoIndexTopic(a *AngelaBase) *libmq.Topic[modelangela.UpdateAppInfoIndex]
• type Angela
  • func NewAngela(mq *libmq.MQ, pullAccountInfo *libmq.Topic[modeltiphereth.PullAccountInfo], ...) (*Angela, error)
• type AngelaBase
  • func NewAngelaBase(repo AngelaRepo, supv *supervisor.Supervisor, g bizgebura.GeburaRepo, ...) (*AngelaBase, error)
• type AngelaRepo

Variables

var ProviderSet = wire.NewSet(
	NewAngela,
	NewAngelaBase,
	NewPullAccountTopic,
	NewPullAccountAppInfoRelationTopic,
	NewPullAppInfoTopic,
	NewAppInfoCache,
	NewPullFeedTopic,
	NewNotifyRouterTopic,
	NewNotifyPushTopic,
	NewFeedToNotifyFlowCache,
	NewNotifyFlowCache,
	NewNotifyTargetCache,
	NewParseFeedItemDigestTopic,
	NewUpdateAppInfoIndexTopic,
)

Functions

func NewAppInfoCache

func NewAppInfoCache(
	g bizgebura.GeburaRepo,
	store libcache.Store,
) *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo]

func NewFeedToNotifyFlowCache

func NewFeedToNotifyFlowCache(
	n biznetzach.NetzachRepo,
	store libcache.Store,
) *libcache.Map[model.InternalID, modelangela.FeedToNotifyFlowValue]

NewFeedToNotifyFlowCache Cache-Aside Pattern.

func NewNotifyFlowCache

func NewNotifyFlowCache(
	n biznetzach.NetzachRepo,
	store libcache.Store,
) *libcache.Map[model.InternalID, modelnetzach.NotifyFlow]

NewNotifyFlowCache Cache-Aside Pattern.

func NewNotifyPushTopic

func NewNotifyPushTopic(
	a *AngelaBase,
	targetMap *libcache.Map[model.InternalID, modelnetzach.NotifyTarget],
) *libmq.Topic[modelangela.NotifyPush]

func NewNotifyRouterTopic

func NewNotifyRouterTopic(
	a *AngelaBase,
	flowMap *libcache.Map[model.InternalID, modelnetzach.NotifyFlow],
	feedToFlowMap *libcache.Map[model.InternalID, modelangela.FeedToNotifyFlowValue],
	push *libmq.Topic[modelangela.NotifyPush],
) *libmq.Topic[modelangela.NotifyRouter]

func NewNotifyTargetCache

func NewNotifyTargetCache(
	n biznetzach.NetzachRepo,
	store libcache.Store,
) *libcache.Map[model.InternalID, modelnetzach.NotifyTarget]

NewNotifyTargetCache Cache-Aside Pattern.

func NewParseFeedItemDigestTopic

func NewParseFeedItemDigestTopic(
	a *AngelaBase,
) *libmq.Topic[modelangela.ParseFeedItemDigest]

func NewPullAccountAppInfoRelationTopic

func NewPullAccountAppInfoRelationTopic(
	a *AngelaBase,
	sa *libmq.Topic[modelangela.PullAppInfo],
) *libmq.Topic[modelangela.PullAccountAppInfoRelation]

func NewPullAccountTopic

func NewPullAccountTopic(
	a *AngelaBase,
	sr *libmq.Topic[modelangela.PullAccountAppInfoRelation],
) *libmq.Topic[modeltiphereth.PullAccountInfo]

func NewPullAppInfoTopic

func NewPullAppInfoTopic(
	a *AngelaBase,
	infoCache *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo],
	updateAppInfoIndex *libmq.Topic[modelangela.UpdateAppInfoIndex],
) *libmq.Topic[modelangela.PullAppInfo]

func NewPullFeedTopic

func NewPullFeedTopic(
	a *AngelaBase,
	notify *libmq.Topic[modelangela.NotifyRouter],
	parse *libmq.Topic[modelangela.ParseFeedItemDigest],
) *libmq.Topic[modelyesod.PullFeed]

func NewUpdateAppInfoIndexTopic

func NewUpdateAppInfoIndexTopic(
	a *AngelaBase,
) *libmq.Topic[modelangela.UpdateAppInfoIndex]

Types

type Angela

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

func NewAngela

func NewAngela(
	mq *libmq.MQ,
	pullAccountInfo *libmq.Topic[modeltiphereth.PullAccountInfo],
	pullAccountAppInfoRelation *libmq.Topic[modelangela.PullAccountAppInfoRelation],
	pullAppInfo *libmq.Topic[modelangela.PullAppInfo],
	pullFeed *libmq.Topic[modelyesod.PullFeed],
	notifyRouter *libmq.Topic[modelangela.NotifyRouter],
	notifyPush *libmq.Topic[modelangela.NotifyPush],
	parseFeedItem *libmq.Topic[modelangela.ParseFeedItemDigest],
	updateAppIndex *libmq.Topic[modelangela.UpdateAppInfoIndex],
) (*Angela, error)

type AngelaBase

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

func NewAngelaBase

func NewAngelaBase(
	repo AngelaRepo,
	supv *supervisor.Supervisor,
	g bizgebura.GeburaRepo,

	pClient porter.LibrarianPorterServiceClient,
	sClient *client.Searcher,
) (*AngelaBase, error)

type AngelaRepo

type AngelaRepo interface {
	UpdateAccount(context.Context, modeltiphereth.Account) error
	UpsertAppInfo(context.Context, *modelgebura.AppInfo, *modelgebura.AppInfo) error
	UpsertAppInfos(context.Context, []*modelgebura.AppInfo) error
	AccountPurchaseAppInfos(context.Context, model.InternalID, []model.InternalID) error
	UpsertFeed(context.Context, *modelfeed.Feed) error
	UpsertFeedItems(context.Context, []*modelfeed.Item, model.InternalID) ([]string, error)
	GetFeedItem(context.Context, model.InternalID) (*modelfeed.Item, error)
	UpdateFeedItemDigest(context.Context, *modelfeed.Item) error
}