bizangela

Documentation

Index

• Variables
• 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 NewPullAccountTopic(a *AngelaBase, sr *libmq.Topic[modelangela.PullSteamAccountAppRelation]) *libmq.Topic[modeltiphereth.PullAccountInfo]
• func NewPullFeedTopic(a *AngelaBase, notify *libmq.Topic[modelangela.NotifyRouter], ...) *libmq.Topic[modelyesod.PullFeed]
• func NewPullSteamAccountAppRelationTopic(a *AngelaBase, sa *libmq.Topic[modelangela.PullSteamApp]) *libmq.Topic[modelangela.PullSteamAccountAppRelation]
• func NewPullSteamAppTopic(a *AngelaBase, updateAppIndex *libmq.Topic[modelangela.UpdateAppIndex]) *libmq.Topic[modelangela.PullSteamApp]
• func NewUpdateAppIndexTopic(a *AngelaBase) *libmq.Topic[modelangela.UpdateAppIndex]
• type Angela
  • func NewAngela(mq *libmq.MQ, pullAccount *libmq.Topic[modeltiphereth.PullAccountInfo], ...) (*Angela, error)
• type AngelaBase
  • func NewAngelaBase(repo AngelaRepo, g bizgebura.GeburaRepo, ...) (*AngelaBase, error)
• type AngelaRepo

Variables

var ProviderSet = wire.NewSet(
	NewAngela,
	NewAngelaBase,
	NewPullAccountTopic,
	NewPullSteamAccountAppRelationTopic,
	NewPullSteamAppTopic,
	NewPullFeedTopic,
	NewNotifyRouterTopic,
	NewNotifyPushTopic,
	NewFeedToNotifyFlowCache,
	NewNotifyFlowCache,
	NewNotifyTargetCache,
	NewParseFeedItemDigestTopic,
	NewUpdateAppIndexTopic,
)

Functions

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 NewPullAccountTopic

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

func NewPullFeedTopic

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

func NewPullSteamAccountAppRelationTopic

func NewPullSteamAccountAppRelationTopic(
	a *AngelaBase,
	sa *libmq.Topic[modelangela.PullSteamApp],
) *libmq.Topic[modelangela.PullSteamAccountAppRelation]

func NewPullSteamAppTopic

func NewPullSteamAppTopic(
	a *AngelaBase,
	updateAppIndex *libmq.Topic[modelangela.UpdateAppIndex],
) *libmq.Topic[modelangela.PullSteamApp]

func NewUpdateAppIndexTopic

func NewUpdateAppIndexTopic(
	a *AngelaBase,
) *libmq.Topic[modelangela.UpdateAppIndex]

Types

type Angela

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

func NewAngela

func NewAngela(
	mq *libmq.MQ,
	pullAccount *libmq.Topic[modeltiphereth.PullAccountInfo],
	pullSteamAccountAppRelation *libmq.Topic[modelangela.PullSteamAccountAppRelation],
	pullSteamApp *libmq.Topic[modelangela.PullSteamApp],
	pullFeed *libmq.Topic[modelyesod.PullFeed],
	notifyRouter *libmq.Topic[modelangela.NotifyRouter],
	notifyPush *libmq.Topic[modelangela.NotifyPush],
	parseFeedItem *libmq.Topic[modelangela.ParseFeedItemDigest],
	updateAppIndex *libmq.Topic[modelangela.UpdateAppIndex],
) (*Angela, error)

type AngelaBase

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

func NewAngelaBase

func NewAngelaBase(
	repo AngelaRepo,
	g bizgebura.GeburaRepo,
	mClient mapper.LibrarianMapperServiceClient,
	pClient porter.LibrarianPorterServiceClient,
	sClient *client.Searcher,
) (*AngelaBase, error)

type AngelaRepo

type AngelaRepo interface {
	UpdateAccount(context.Context, modeltiphereth.Account) error
	UpdateApp(context.Context, *modelgebura.App, *modelgebura.App) error
	UpsertApps(context.Context, []*modelgebura.App) error
	AccountPurchaseApps(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
}