Documentation ¶
Index ¶
- Variables
- func InitMetadataMQ(ctx2 context.Context, log logger.Logger, mq v1_2.MQ) (*metadata_mq.Event, error)
- func NewMetaDataApplication(store2 *meta_store.MetaStore) (*metadata.Service, error)
- func NewMetaDataRPCServer(runRPCServer *rpc.RPCServer, application *metadata.Service, log logger.Logger) (*v1.Metadata, error)
- func NewMetaDataStore(ctx2 context.Context, logger2 logger.Logger, db2 *db.Store) (*meta_store.MetaStore, error)
- type MetaDataService
Constants ¶
This section is empty.
Variables ¶
View Source
var MetaDataSet = wire.NewSet(di.DefaultSet, mq_di.New, store.New, rpc.InitServer, InitMetadataMQ, NewMetaDataRPCServer, NewMetaDataApplication, NewMetaDataStore, NewMetaDataService, )
MetaDataService =====================================================================================================
Functions ¶
func InitMetadataMQ ¶
func NewMetaDataApplication ¶
func NewMetaDataApplication(store2 *meta_store.MetaStore) (*metadata.Service, error)
func NewMetaDataRPCServer ¶
Types ¶
type MetaDataService ¶
type MetaDataService struct { // Common Log logger.Logger // contains filtered or unexported fields }
func InitializeMetaDataService ¶
func InitializeMetaDataService() (*MetaDataService, func(), error)
func NewMetaDataService ¶
Click to show internal directories.
Click to hide internal directories.