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
- type AngelaBase
- type AngelaRepo
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet( NewAngela, NewAngelaBase, NewPullAccountTopic, NewPullAccountAppInfoRelationTopic, NewPullAppInfoTopic, NewAppInfoCache, NewPullFeedTopic, NewNotifyRouterTopic, NewNotifyPushTopic, NewFeedToNotifyFlowCache, NewNotifyFlowCache, NewNotifyTargetCache, NewParseFeedItemDigestTopic, NewUpdateAppInfoIndexTopic, )
Functions ¶
func NewAppInfoCache ¶ added in v0.2.3
func NewAppInfoCache( g bizgebura.GeburaRepo, store libcache.Store, ) *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo]
func NewFeedToNotifyFlowCache ¶ added in v0.1.15
func NewFeedToNotifyFlowCache( n biznetzach.NetzachRepo, store libcache.Store, ) *libcache.Map[model.InternalID, modelangela.FeedToNotifyFlowValue]
NewFeedToNotifyFlowCache Cache-Aside Pattern.
func NewNotifyFlowCache ¶ added in v0.1.0
func NewNotifyFlowCache( n biznetzach.NetzachRepo, store libcache.Store, ) *libcache.Map[model.InternalID, modelnetzach.NotifyFlow]
NewNotifyFlowCache Cache-Aside Pattern.
func NewNotifyPushTopic ¶ added in v0.1.0
func NewNotifyPushTopic( a *AngelaBase, targetMap *libcache.Map[model.InternalID, modelnetzach.NotifyTarget], ) *libmq.Topic[modelangela.NotifyPush]
func NewNotifyRouterTopic ¶ added in v0.1.0
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 ¶ added in v0.1.0
func NewNotifyTargetCache( n biznetzach.NetzachRepo, store libcache.Store, ) *libcache.Map[model.InternalID, modelnetzach.NotifyTarget]
NewNotifyTargetCache Cache-Aside Pattern.
func NewParseFeedItemDigestTopic ¶ added in v0.1.5
func NewParseFeedItemDigestTopic( a *AngelaBase, ) *libmq.Topic[modelangela.ParseFeedItemDigest]
func NewPullAccountAppInfoRelationTopic ¶ added in v0.2.3
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 ¶ added in v0.2.3
func NewPullAppInfoTopic( a *AngelaBase, infoCache *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo], updateAppInfoIndex *libmq.Topic[modelangela.UpdateAppInfoIndex], ) *libmq.Topic[modelangela.PullAppInfo]
func NewPullFeedTopic ¶ added in v0.0.5
func NewPullFeedTopic( a *AngelaBase, notify *libmq.Topic[modelangela.NotifyRouter], parse *libmq.Topic[modelangela.ParseFeedItemDigest], ) *libmq.Topic[modelyesod.PullFeed]
func NewUpdateAppInfoIndexTopic ¶ added in v0.2.3
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 ¶ added in v0.1.5
type AngelaRepo interface {
UpsertAccount(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
}
Source Files
Click to show internal directories.
Click to hide internal directories.