bizangela

package
v0.2.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 10, 2024 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func NewAppInfoCache added in v0.2.3 

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

func NewFeedItemPostprocessTopic added in v0.2.10 

func NewFeedItemPostprocessTopic(
	a *AngelaBase,
	notify *libmq.Topic[modelangela.NotifyRouter],
	systemNotify *libmq.Topic[modelnetzach.SystemNotify],
) *libmq.Topic[modelangela.FeedItemPostprocess]

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 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,
	parse *libmq.Topic[modelangela.FeedItemPostprocess],
	systemNotify *libmq.Topic[modelnetzach.SystemNotify],
) *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],
	itemPostprocess *libmq.Topic[modelangela.FeedItemPostprocess],
	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
	CheckNewFeedItems(context.Context, []*modelfeed.Item, model.InternalID) ([]string, error)
	UpsertFeedItems(context.Context, []*modelfeed.Item, model.InternalID) error
	UpdateFeedPullStatus(context.Context, *modelyesod.FeedConfig) error
	GetFeedItem(context.Context, model.InternalID) (*modelfeed.Item, error)
	GetFeedActions(context.Context, model.InternalID) ([]*modelyesod.FeedActionSet, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.