Documentation ¶
Index ¶
- Variables
- func InitLinkMQ(ctx2 context.Context, log logger.Logger, mq v1_4.MQ, service *link.Service) (*api_mq.Event, error)
- func NewCQSLinkStore(ctx2 context.Context, logger2 logger.Logger, db2 *db.Store, ...) (*cqs.Store, error)
- func NewLinkApplication(logger2 logger.Logger, mq v1_4.MQ, metadataService v1_5.MetadataServiceClient, ...) (*link.Service, error)
- func NewLinkCQRSApplication(logger2 logger.Logger, cqsStore *cqs.Store, queryStore *query.Store) (*link_cqrs.Service, error)
- func NewLinkCQRSRPCServer(runRPCServer *rpc.RPCServer, application *link_cqrs.Service, log logger.Logger) (*v1_2.Link, error)
- func NewLinkRPCClient(runRPCClient *grpc.ClientConn) (v1.LinkServiceClient, error)
- func NewLinkRPCServer(runRPCServer *rpc.RPCServer, application *link.Service, log logger.Logger) (*v1.Link, error)
- func NewLinkStore(ctx2 context.Context, logger2 logger.Logger, db2 *db.Store, ...) (*crud.Store, error)
- func NewMetadataRPCClient(runRPCClient *grpc.ClientConn) (v1_5.MetadataServiceClient, error)
- func NewQueryLinkStore(ctx2 context.Context, logger2 logger.Logger, db2 *db.Store, ...) (*query.Store, error)
- func NewRunRPCServer(runRPCServer *rpc.RPCServer, cqrsLinkRPC *v1_2.Link, linkRPC *v1.Link) (*run.Response, error)
- func NewSitemapApplication(logger2 logger.Logger, mq v1_4.MQ) (*sitemap.Service, error)
- func NewSitemapRPCServer(runRPCServer *rpc.RPCServer, application *sitemap.Service, log logger.Logger) (*v1_3.Sitemap, error)
- type LinkService
Constants ¶
This section is empty.
Variables ¶
View Source
var LinkSet = wire.NewSet(di.DefaultSet, mq_di.New, rpc.InitServer, rpc.InitClient, store.New, InitLinkMQ, NewLinkRPCServer, NewLinkCQRSRPCServer, NewSitemapRPCServer, NewRunRPCServer, NewLinkRPCClient, NewMetadataRPCClient, NewLinkApplication, NewLinkCQRSApplication, NewSitemapApplication, NewLinkStore, NewCQSLinkStore, NewQueryLinkStore, NewLinkService, )
LinkService =========================================================================================================
Functions ¶
func InitLinkMQ ¶
func NewCQSLinkStore ¶
func NewLinkApplication ¶
func NewLinkCQRSApplication ¶
func NewLinkCQRSRPCServer ¶
func NewLinkRPCClient ¶
func NewLinkRPCClient(runRPCClient *grpc.ClientConn) (v1.LinkServiceClient, error)
func NewLinkRPCServer ¶
func NewLinkStore ¶
func NewMetadataRPCClient ¶
func NewMetadataRPCClient(runRPCClient *grpc.ClientConn) (v1_5.MetadataServiceClient, error)
func NewQueryLinkStore ¶
func NewRunRPCServer ¶
func NewSitemapApplication ¶
Types ¶
type LinkService ¶
func InitializeLinkService ¶
func InitializeLinkService() (*LinkService, func(), error)
func NewLinkService ¶
func NewLinkService( log logger.Logger, linkService *link.Service, linkCQRSService *link_cqrs.Service, sitemapService *sitemap.Service, linkMQ *api_mq.Event, run2 *run.Response, linkRPCServer *v1.Link, linkCQRSRPCServer *v1_2.Link, sitemapRPCServer *v1_3.Sitemap, linkStore *crud.Store, cqsStore *cqs.Store, queryStore *query.Store, ) (*LinkService, error)
Click to show internal directories.
Click to hide internal directories.