MCPcopy Create free account

hub / github.com/codealong-dev/ride-sharing / functions

Functions317 in github.com/codealong-dev/ride-sharing

↓ 20 callersFunctionGetString
(key, fallback string)
shared/env/env.go:11
↓ 17 callersMethodString
()
shared/proto/trip/trip.pb.go:491
↓ 15 callersFunctioncn
(...inputs: ClassValue[])
web/src/lib/utils.ts:4
↓ 10 callersMethodClose
()
services/api-gateway/grpc_clients/trip_client.go:41
↓ 10 callersFunctionfile_trip_proto_rawDescGZIP
()
shared/proto/trip/trip.pb.go:686
↓ 9 callersMethodPublishMessage
(ctx context.Context, routingKey string, message contracts.AmqpMessage)
shared/messaging/rabbitmq.go:123
↓ 8 callersMethoddeclareAndBindQueue
(queueName string, messageTypes []string, exchange string)
shared/messaging/rabbitmq.go:281
↓ 7 callersMethodStart
()
shared/messaging/queue_consumer.go:24
↓ 6 callersMethodClose
()
shared/messaging/rabbitmq.go:314
↓ 5 callersMethodGet
(key string)
shared/tracing/rabbitmq.go:19
↓ 5 callersMethodSet
(key string, value string)
shared/tracing/rabbitmq.go:28
↓ 5 callersFunctionWrapHandlerFunc
(handler http.HandlerFunc, operation string)
shared/tracing/http.go:9
↓ 4 callersMethodConsumeMessages
(queueName string, handler MessageHandler)
shared/messaging/rabbitmq.go:53
↓ 4 callersMethodGetTripByID
(ctx context.Context, id string)
services/trip-service/internal/domain/trip.go:52
↓ 4 callersFunctionInitTracer
(cfg Config)
shared/tracing/tracing.go:22
↓ 4 callersFunctionNewRabbitMQ
(uri string)
shared/messaging/rabbitmq.go:25
↓ 4 callersMethodRegisterDriver
(ctx context.Context, in *RegisterDriverRequest, opts ...grpc.CallOption)
shared/proto/driver/driver_grpc.pb.go:30
↓ 4 callersMethodUnregisterDriver
(ctx context.Context, in *RegisterDriverRequest, opts ...grpc.CallOption)
shared/proto/driver/driver_grpc.pb.go:31
↓ 4 callersFunctionfile_driver_proto_rawDescGZIP
()
shared/proto/driver/driver.pb.go:294
↓ 3 callersMethodCreateTrip
(ctx context.Context, fare *RideFareModel)
services/trip-service/internal/domain/trip.go:42
↓ 3 callersMethodGetDriverID
()
shared/proto/driver/driver.pb.go:62
↓ 3 callersMethodListen
()
services/trip-service/internal/infrastructure/events/driver_consumer.go:28
↓ 3 callersMethodPreviewTrip
(ctx context.Context, in *PreviewTripRequest, opts ...grpc.CallOption)
shared/proto/trip/trip_grpc.pb.go:30
↓ 3 callersMethodToProto
()
services/trip-service/internal/domain/trip.go:22
↓ 3 callersMethodUpdateTrip
(ctx context.Context, tripID string, status string, driver *pbd.Driver)
services/trip-service/internal/domain/trip.go:53
↓ 2 callersMethodAdd
(id string, conn *websocket.Conn)
shared/messaging/connection_manager.go:51
↓ 2 callersMethodCreatePaymentSession
(ctx context.Context, tripID, userID, driverID string, amount int64, currency string)
services/payment-service/internal/domain/domain.go:10
↓ 2 callersMethodCreateTrip
(ctx context.Context, in *CreateTripRequest, opts ...grpc.CallOption)
shared/proto/trip/trip_grpc.pb.go:31
↓ 2 callersFunctionDialOptionsWithTracing
()
shared/tracing/grpc.go:16
↓ 2 callersMethodGetRoute
(ctx context.Context, pickup, destination *types.Coordinate, useOsrmApi bool)
services/trip-service/internal/domain/trip.go:43
↓ 2 callersMethodGetUserID
()
shared/proto/trip/trip.pb.go:542
↓ 2 callersMethodListen
()
services/payment-service/internal/events/trip_consumer.go:27
↓ 2 callersFunctionNewMongoDefaultConfig
NewMongoConfig creates a new MongoDB configuration from environment variables
shared/db/mongodb.go:27
↓ 2 callersFunctionNewQueueConsumer
(rb *RabbitMQ, connMgr *ConnectionManager, queueName string)
shared/messaging/queue_consumer.go:16
↓ 2 callersFunctionNewTripServiceClient
()
services/api-gateway/grpc_clients/trip_client.go:17
↓ 2 callersMethodRemove
(id string)
shared/messaging/connection_manager.go:62
↓ 2 callersMethodSendMessage
(id string, message contracts.WSMessage)
shared/messaging/connection_manager.go:78
↓ 2 callersMethodUpgrade
(w http.ResponseWriter, r *http.Request)
shared/messaging/connection_manager.go:43
↓ 2 callersFunctionWithTracingInterceptors
()
shared/tracing/grpc.go:10
↓ 2 callersFunctionconvertMetersToKilometers
(meters: number)
web/src/utils/math.ts:6
↓ 2 callersFunctionconvertSecondsToMinutes
(seconds: number)
web/src/utils/math.ts:2
↓ 2 callersFunctionenableCORS
(handler http.HandlerFunc)
services/api-gateway/middleware.go:5
↓ 2 callersFunctionhandleClick
(userType: "driver" | "rider")
web/src/app/page.tsx:39
↓ 2 callersFunctionisValidTripEvent
(event: string)
web/src/contracts.ts:103
↓ 2 callersFunctionisValidWsMessage
(message: ServerWsMessage)
web/src/contracts.ts:107
↓ 2 callersFunctionresetTripStatus
()
web/src/hooks/useRiderStreamConnection.ts:78
↓ 2 callersFunctionsendMessage
(message: ClientWsMessage)
web/src/hooks/useDriverStreamConnection.ts:91
↓ 2 callersFunctionwriteJSON
(w http.ResponseWriter, status int, data any)
services/api-gateway/json.go:8
↓ 1 callersFunctionDefaultConfig
DefaultConfig returns a Config with sensible default values
shared/retry/retry.go:20
↓ 1 callersMethodEstimatePackagesPriceWithRoute
(route *tripTypes.OsrmApiResponse)
services/trip-service/internal/domain/trip.go:44
↓ 1 callersMethodFindAvailableDrivers
(packageType string)
services/driver-service/service.go:29
↓ 1 callersFunctionGenerateRandomPlate
()
services/driver-service/utils.go:49
↓ 1 callersMethodGenerateTripFares
( ctx context.Context, fares []*RideFareModel, userID string, Route *tripTypes.OsrmApiResponse, )
services/trip-service/internal/domain/trip.go:45
↓ 1 callersMethodGetAndValidateFare
(ctx context.Context, fareID, userID string)
services/trip-service/internal/domain/trip.go:51
↓ 1 callersFunctionGetDatabase
GetDatabase returns a database instance
shared/db/mongodb.go:60
↓ 1 callersMethodGetEndLocation
()
shared/proto/trip/trip.pb.go:77
↓ 1 callersMethodGetPackageSlug
()
shared/proto/trip/trip.pb.go:354
↓ 1 callersFunctionGetRandomAvatar
GetRandomAvatar returns a random avatar URL from the randomuser.me API
shared/util/util.go:6
↓ 1 callersMethodGetRideFareByID
(ctx context.Context, id string)
services/trip-service/internal/domain/trip.go:36
↓ 1 callersMethodGetRideFareID
()
shared/proto/trip/trip.pb.go:406
↓ 1 callersMethodGetStartLocation
()
shared/proto/trip/trip.pb.go:70
↓ 1 callersFunctionGetTracer
(name string)
shared/tracing/tracing.go:43
↓ 1 callersMethodListen
()
services/driver-service/trip_consumer.go:26
↓ 1 callersFunctionNewConnectionManager
Note that on multiple instances of the API gateway, the connection manager needs to store the connections on a separate shared storage.
shared/messaging/connection_manager.go:37
↓ 1 callersFunctionNewDriverConsumer
(rabbitmq *messaging.RabbitMQ, service domain.TripService)
services/trip-service/internal/infrastructure/events/driver_consumer.go:21
↓ 1 callersFunctionNewDriverServiceClient
()
services/api-gateway/grpc_clients/driver_client.go:17
↓ 1 callersFunctionNewGrpcHandler
(s *grpc.Server, service *Service)
services/driver-service/gprc_handler.go:18
↓ 1 callersFunctionNewMongoClient
NewMongoClient creates a new MongoDB client
shared/db/mongodb.go:35
↓ 1 callersFunctionNewMongoRepository
(db *mongo.Database)
services/trip-service/internal/infrastructure/repository/mongodb.go:20
↓ 1 callersFunctionNewPaymentConsumer
(rabbitmq *messaging.RabbitMQ, service domain.TripService)
services/trip-service/internal/infrastructure/events/payment_consumer.go:20
↓ 1 callersFunctionNewPaymentService
NewPaymentService creates a new instance of the payment service
services/payment-service/internal/service/service.go:19
↓ 1 callersFunctionNewService
(repo domain.TripRepository)
services/trip-service/internal/service/service.go:24
↓ 1 callersFunctionNewService
()
services/driver-service/service.go:23
↓ 1 callersFunctionNewStripeClient
(config *types.PaymentConfig)
services/payment-service/internal/infrastructure/stripe/stripe.go:17
↓ 1 callersFunctionNewTripConsumer
(rabbitmq *messaging.RabbitMQ, service domain.Service)
services/payment-service/internal/events/trip_consumer.go:20
↓ 1 callersFunctionNewTripConsumer
(rabbitmq *messaging.RabbitMQ, service *Service)
services/driver-service/trip_consumer.go:19
↓ 1 callersFunctionNewTripEventPublisher
(rabbitmq *messaging.RabbitMQ)
services/trip-service/internal/infrastructure/events/trip_publisher.go:15
↓ 1 callersMethodPublishTripCreated
(ctx context.Context, trip *domain.TripModel)
services/trip-service/internal/infrastructure/events/trip_publisher.go:21
↓ 1 callersMethodSaveRideFare
(ctx context.Context, f *RideFareModel)
services/trip-service/internal/domain/trip.go:35
↓ 1 callersMethodToProto
()
services/trip-service/internal/domain/ride_fare.go:18
↓ 1 callersFunctionToRideFaresProto
(fares []*RideFareModel)
services/trip-service/internal/domain/ride_fare.go:27
↓ 1 callersFunctionTracedConsumer
TracedConsumer wraps the RabbitMQ message handler with tracing
shared/tracing/rabbitmq.go:77
↓ 1 callersFunctionTracedPublisher
TracedPublisher wraps the RabbitMQ publish function with tracing
shared/tracing/rabbitmq.go:41
↓ 1 callersFunctionWithBackoff
WithBackoff executes the given operation with exponential backoff retry logic
shared/retry/retry.go:29
↓ 1 callersFunctiondecodeGeoHash
(geohash: string)
web/src/utils/geohash.ts:3
↓ 1 callersFunctionestimateFareRoute
(f *domain.RideFareModel, route *tripTypes.OsrmApiResponse)
services/trip-service/internal/service/service.go:155
↓ 1 callersFunctionfile_driver_proto_init
()
shared/proto/driver/driver.pb.go:323
↓ 1 callersFunctionfile_trip_proto_init
()
shared/proto/trip/trip.pb.go:729
↓ 1 callersFunctiongetBaseFares
()
services/trip-service/internal/service/service.go:172
↓ 1 callersFunctiongetGeohashBounds
(geohash: string)
web/src/utils/geohash.ts:12
↓ 1 callersFunctionhandleDriversWebSocket
(w http.ResponseWriter, r *http.Request, rb *messaging.RabbitMQ)
services/api-gateway/ws.go:62
↓ 1 callersMethodhandleFindAndNotifyDrivers
(ctx context.Context, payload messaging.TripEventData)
services/driver-service/trip_consumer.go:53
↓ 1 callersFunctionhandleRidersWebSocket
(w http.ResponseWriter, r *http.Request, rb *messaging.RabbitMQ)
services/api-gateway/ws.go:17
↓ 1 callersFunctionhandleStripeWebhook
(w http.ResponseWriter, r *http.Request, rb *messaging.RabbitMQ)
services/api-gateway/http.go:96
↓ 1 callersMethodhandleTripAccepted
(ctx context.Context, tripID string, driver *pbd.Driver)
services/trip-service/internal/infrastructure/events/driver_consumer.go:92
↓ 1 callersMethodhandleTripAccepted
(ctx context.Context, payload messaging.PaymentTripResponseData)
services/payment-service/internal/events/trip_consumer.go:53
↓ 1 callersMethodhandleTripDeclined
(ctx context.Context, tripID, riderID string)
services/trip-service/internal/infrastructure/events/driver_consumer.go:63
↓ 1 callersFunctionnewClientHandler
()
shared/tracing/grpc.go:22
↓ 1 callersFunctionnewExporter
(endpoint string)
shared/tracing/tracing.go:47
↓ 1 callersFunctionnewPropagator
()
shared/tracing/tracing.go:51
next →1–100 of 317, ranked by callers