bizangela

Documentation

Index

• Variables
• func NewPullAccountTopic(a *AngelaBase, sr *libmq.TopicImpl[PullSteamAccountAppRelation]) *libmq.TopicImpl[biztiphereth.PullAccountInfo]
• func NewPullFeedTopic(a *AngelaBase) *libmq.TopicImpl[bizyesod.PullFeed]
• func NewPullSteamAccountAppRelationTopic(a *AngelaBase, sa *libmq.TopicImpl[PullSteamApp]) *libmq.TopicImpl[PullSteamAccountAppRelation]
• func NewPullSteamAppTopic(a *AngelaBase) *libmq.TopicImpl[PullSteamApp]
• type Angela
  • func NewAngela(mq *libmq.MQ, pullAccount *libmq.TopicImpl[biztiphereth.PullAccountInfo], ...) (*Angela, error)
• type AngelaBase
  • func NewAngelaBase(t biztiphereth.TipherethRepo, g bizgebura.GeburaRepo, y bizyesod.YesodRepo, ...) (*AngelaBase, error)
• type PullSteamAccountAppRelation
• type PullSteamApp

Variables

var ProviderSet = wire.NewSet(
	NewAngela,
	NewAngelaBase,
	NewPullAccountTopic,
	NewPullSteamAccountAppRelationTopic,
	NewPullSteamAppTopic,
	NewPullFeedTopic,
)

Functions

func NewPullAccountTopic

func NewPullAccountTopic(
	a *AngelaBase,
	sr *libmq.TopicImpl[PullSteamAccountAppRelation],
) *libmq.TopicImpl[biztiphereth.PullAccountInfo]

func NewPullFeedTopic

func NewPullFeedTopic(
	a *AngelaBase,
) *libmq.TopicImpl[bizyesod.PullFeed]

func NewPullSteamAccountAppRelationTopic

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

func NewPullSteamAppTopic

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

Types

type Angela

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

func NewAngela

func NewAngela(
	mq *libmq.MQ,
	pullAccount *libmq.TopicImpl[biztiphereth.PullAccountInfo],
	pullSteamAccountAppRelation *libmq.TopicImpl[PullSteamAccountAppRelation],
	pullSteamApp *libmq.TopicImpl[PullSteamApp],
	pullFeed *libmq.TopicImpl[bizyesod.PullFeed],
) (*Angela, error)

type AngelaBase

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

func NewAngelaBase

func NewAngelaBase(
	t biztiphereth.TipherethRepo,
	g bizgebura.GeburaRepo,
	y bizyesod.YesodRepo,
	mClient mapper.LibrarianMapperServiceClient,
	pClient porter.LibrarianPorterServiceClient,
	sClient searcher.LibrarianSearcherServiceClient,
) (*AngelaBase, error)

type PullSteamAccountAppRelation

type PullSteamAccountAppRelation struct {
	InternalID int64
	SteamID    string
}

type PullSteamApp

type PullSteamApp struct {
	InternalID int64
	AppID      string
}