oms_di

Documentation

Index

• Variables
• func NewRunRPCServer(runRPCServer *rpc.Server, _ *v1.CartRPC) (*run.Response, error)
• type OMSService
  • func InitializeOMSService() (*OMSService, func(), error)
  • func NewOMSService(log logger.Logger, config2 *config.Config, autoMaxPro2 autoMaxPro.AutoMaxPro, ...) (*OMSService, error)

Variables

var OMSSet = wire.NewSet(di.DefaultSet, rpc.InitServer, v1.New, v1_2.New, NewRunRPCServer, cart.New, order.New, temporal.New, NewOMSService)

OMSService ==========================================================================================================

Functions

func NewRunRPCServer

func NewRunRPCServer(runRPCServer *rpc.Server, _ *v1.CartRPC) (*run.Response, error)

TODO: refactoring. maybe drop this function

Types

type OMSService

type OMSService struct {
	// Common
	Log        logger.Logger
	Config     *config.Config
	AutoMaxPro autoMaxPro.AutoMaxPro

	// Observability
	Tracer        trace.TracerProvider
	Monitoring    *monitoring.Monitoring
	PprofEndpoint profiling.PprofEndpoint
	// contains filtered or unexported fields
}

func InitializeOMSService

func InitializeOMSService() (*OMSService, func(), error)

func NewOMSService

func NewOMSService(

	log logger.Logger, config2 *config.Config, autoMaxPro2 autoMaxPro.AutoMaxPro, monitoring2 *monitoring.Monitoring,
	tracer trace.TracerProvider,
	pprofHTTP profiling.PprofEndpoint,

	authPermission *authzed.Client, run2 *run.Response,
	cartRPCServer *v1.CartRPC,
	orderRPCServer *v1_2.OrderRPC,

	temporalClient client.Client,
) (*OMSService, error)