Documentation ¶
Index ¶
- Variables
- func InitLinkMQ(ctx2 context.Context, log logger.Logger, mq2 mq.MQ, service *link.UC) (*api_mq.Event, error)
- func NewCQSLinkStore(ctx2 context.Context, log logger.Logger, db2 db.DB, cache3 *cache2.Cache) (*cqs.Store, error)
- func NewLinkApplication(log logger.Logger, mq2 mq.MQ, store2 crud.Repository, ...) (*link.UC, error)
- func NewLinkCQRSApplication(log logger.Logger, cqsStore *cqs.Store, queryStore *query.Store) (*link_cqrs.Service, error)
- func NewLinkCQRSRPCServer(runRPCServer *rpc.Server, application *link_cqrs.Service, log logger.Logger) (*v1_2.LinkRPC, error)
- func NewLinkRPCClient(runRPCClient *grpc.ClientConn) (v1.LinkServiceClient, error)
- func NewLinkRPCServer(runRPCServer *rpc.Server, application *link.UC, log logger.Logger) (*v1.LinkRPC, error)
- func NewLinkStore(ctx2 context.Context, log logger.Logger, db2 db.DB, cache3 *cache2.Cache) (crud.Repository, error)
- func NewQueryLinkStore(ctx2 context.Context, log logger.Logger, db2 db.DB, cache3 *cache2.Cache) (*query.Store, error)
- func NewRunRPCServer(runRPCServer *rpc.Server, _ *v1_2.LinkRPC, _ *v1.LinkRPC) (*run.Response, error)
- func NewSitemapApplication(log logger.Logger, dataBus mq.MQ) (*sitemap.Service, error)
- func NewSitemapRPCServer(runRPCServer *rpc.Server, 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, NewLinkApplication, NewLinkCQRSApplication, NewSitemapApplication, NewLinkStore, NewCQSLinkStore, NewQueryLinkStore, NewLinkService, )
LinkService =========================================================================================================
Functions ¶
func InitLinkMQ ¶
func NewCQSLinkStore ¶
func NewLinkApplication ¶
func NewLinkApplication(log logger.Logger, mq2 mq.MQ, store2 crud.Repository, authPermission *authzed.Client) (*link.UC, error)
func NewLinkApplication(log logger.Logger, mq mq.MQ, metadataService metadata_rpc.MetadataServiceClient, store crud.Repository, authPermission *authzed.Client) (*link.UC, error) {
func NewLinkCQRSApplication ¶
func NewLinkCQRSRPCServer ¶
func NewLinkRPCClient ¶
func NewLinkRPCClient(runRPCClient *grpc.ClientConn) (v1.LinkServiceClient, error)
func NewLinkRPCServer ¶
func NewLinkStore ¶
func NewQueryLinkStore ¶
func NewRunRPCServer ¶
func NewRunRPCServer(runRPCServer *rpc.Server, _ *v1_2.LinkRPC, _ *v1.LinkRPC) (*run.Response, error)
TODO: refactoring. maybe drop this function
func NewSitemapApplication ¶
Types ¶
type LinkService ¶
type LinkService struct { // Common Log logger.Logger Config *config.Config // Observability Tracer trace.TracerProvider Monitoring *monitoring.Monitoring PprofEndpoint profiling.PprofEndpoint AutoMaxPro autoMaxPro.AutoMaxPro // contains filtered or unexported fields }
func InitializeLinkService ¶
func InitializeLinkService() (*LinkService, func(), error)
func NewLinkService ¶
func NewLinkService( log logger.Logger, config2 *config.Config, monitoring2 *monitoring.Monitoring, tracer trace.TracerProvider, pprofHTTP profiling.PprofEndpoint, autoMaxProcsOption autoMaxPro.AutoMaxPro, authPermission *authzed.Client, linkService *link.UC, linkCQRSService *link_cqrs.Service, sitemapService *sitemap.Service, linkMQ *api_mq.Event, run2 *run.Response, linkRPCServer *v1.LinkRPC, linkCQRSRPCServer *v1_2.LinkRPC, sitemapRPCServer *v1_3.Sitemap, linkStore crud.Repository, cqsStore *cqs.Store, queryStore *query.Store, ) (*LinkService, error)
Click to show internal directories.
Click to hide internal directories.