bizangela

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2023 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func NewFeedToNotifyFlowMap added in v0.1.0

NewFeedToNotifyFlowMap Cache-Aside Pattern.

func NewNotifyFlowCache added in v0.1.0

NewNotifyFlowCache Cache-Aside Pattern.

func NewNotifyPushTopic added in v0.1.0

func NewNotifyTargetCache added in v0.1.0

NewNotifyTargetCache Cache-Aside Pattern.

func NewPullFeedTopic added in v0.0.5

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

func NewPullSteamAppTopic

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

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],
) (*Angela, error)

type AngelaBase

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL