MCPcopy Create free account

hub / github.com/delta/dalal-street-server / functions

Functions739 in github.com/delta/dalal-street-server

↓ 1 callersFunctionmortgageStocksAction
mortgageStocksAction returns total transaction amount while mortgaging
models/MortgageDetail.go:44
↓ 1 callersFunctionnewAskItem
(value *models.Ask, price uint64, quantity uint64)
matchingengine/pqueue.go:84
↓ 1 callersFunctionnewBidItem
(value *models.Bid, price uint64, quantity uint64)
matchingengine/pqueue.go:76
↓ 1 callersFunctionnewGameStateStream
newGameStateStream creates a new GameStateStream
datastreams/GameStateStream.go:27
↓ 1 callersFunctionnewMarketDepthStream
newMarketDepthStream returns a new MarketDepthStream instance for a given stockId
datastreams/MarketDepth.go:64
↓ 1 callersFunctionnewMarketEventsStream
newMarketEventsStream creates a new MarketEventsStream
datastreams/MarketEvents.go:25
↓ 1 callersFunctionnewMyOrdersStream
newMyOrdersStream creates a new MyOrdersStream
datastreams/MyOrders.go:24
↓ 1 callersFunctionnewNotificationsStream
newNotificationsStream creates a new NotificationStream
datastreams/Notifications.go:27
↓ 1 callersFunctionnewStockExchangeStream
newStockExchangeStream creates a new StockExchangeStream
datastreams/StockExchange.go:32
↓ 1 callersFunctionnewStockHistoryStream
newStockHistoryStream returns a new instance of StockHistoryStream
datastreams/StockHistory.go:25
↓ 1 callersFunctionnewStockPricesStream
newStockPricesStream creates a new StockPricesStream
datastreams/StockPrices.go:31
↓ 1 callersFunctionnewTransactionsStream
newTransactionsStream creates a new TransactionsStream
datastreams/Transactions.go:25
↓ 1 callersFunctionpad
(payload *bytes.Buffer, maxPadLen int)
models/PushNotification.go:350
↓ 1 callersFunctionrecorderHigherIntervalOHLCs
retrieves relevant older number of records from the DB and then writes the required (5/10/30/60) intervals to the db
models/StockHistory.go:216
↓ 1 callersFunctionretrieveStocksAction
retrieveStocksAction returns total transaction amount and stock quantity which could be retrieved
models/MortgageDetail.go:87
↓ 1 callersMethodrun
run runs the marketDepthStream by updating the listeners ever 2 seconds
datastreams/MarketDepth.go:84
↓ 1 callersFunctionsaveAskCancelOrderTransaction
saveAskCancelOrderTransaction creates a CancelOrderTransaction for Ask orders and pushses to stream
models/User.go:1308
↓ 1 callersFunctionsaveNewUserState
saveNewUserState saves new user state i.e users who registers when dailyChallenge is open
models/DailyChallenge.go:741
↓ 1 callersFunctionsaveTransSum
Helper for the deadlock test written below. If you want to test any table OTHER than TransactionSummary, all you need to do is update this helper func
models/User_test.go:901
↓ 1 callersFunctionsaveUsersState
saveUsersState saves registered users cash,stockworth,Networth,specificstock quantity based on challenge type invoked inside OpenDailyChallenge
models/DailyChallenge.go:458
↓ 1 callersFunctionsendPushNotification
(message []byte, s *UserSubscription, options *options)
models/PushNotification.go:182
↓ 1 callersMethodsink
(k int)
matchingengine/pqueue.go:372
↓ 1 callersMethodsink
(k int)
matchingengine/pqueue.go:388
↓ 1 callersFunctionstartStockHistoryRecorder
(interval time.Duration)
models/StockHistory.go:304
↓ 1 callersFunctionstopStockHistoryRecorder
()
models/StockHistory.go:83
↓ 1 callersMethodswim
(k int)
matchingengine/pqueue.go:357
↓ 1 callersMethodswim
(k int)
matchingengine/pqueue.go:364
↓ 1 callersFunctionupdateUserState
updateUsersState updates userState when dailyChallenges Closes similiar to saveUsersState,invoked inside CloseDailyChallenge
models/DailyChallenge.go:284
↓ 1 callersMethodwaitForOrder
* * Method to wait for an incoming order on the channels */
matchingengine/OrderBook.go:611
↓ 1 callersFunctionwriteUserDetailsToLog
(ctx context.Context)
grpcapi/actionservice/AuthActionService.go:19
FunctionAbsInt64
(n int64)
utils/utils.go:73
MethodAddAskOrder
AddAskOrder adds an ask order to the relevant order book
matchingengine/MatchingEngine.go:72
MethodAddAskOrder
AddAskOrder mocks base method
mocks/mock_OrderBook.go:67
MethodAddAskOrder
AddAskOrder indicates an expected call of AddAskOrder
mocks/mock_OrderBook.go:72
MethodAddAskOrder
AddAskOrder mocks base method
mocks/mock_MatchingEngine.go:37
MethodAddAskOrder
AddAskOrder indicates an expected call of AddAskOrder
mocks/mock_MatchingEngine.go:42
MethodAddBidOrder
AddBidOrder adds a bid order to the relevant order book
matchingengine/MatchingEngine.go:77
MethodAddBidOrder
AddBidOrder mocks base method
mocks/mock_OrderBook.go:77
MethodAddBidOrder
AddBidOrder indicates an expected call of AddBidOrder
mocks/mock_OrderBook.go:82
MethodAddBidOrder
AddBidOrder mocks base method
mocks/mock_MatchingEngine.go:47
MethodAddBidOrder
AddBidOrder indicates an expected call of AddBidOrder
mocks/mock_MatchingEngine.go:52
FunctionAddDailyChallenge
AddDailyChallenge add daily challenge to db, only Admin can invoke this function
models/DailyChallenge.go:133
MethodAddDailyChallenge
(ctx context.Context, req *actions_pb.AddDailyChallengeRequest)
grpcapi/actionservice/AdminActionService.go:632
FunctionAddExtraCredit
AddExtraCredit Adds extra credit for the users
models/ReferralCode.go:107
MethodAddListener
AddListener mocks base method
mocks/mock_MarketDepth.go:36
MethodAddListener
AddListener indicates an expected call of AddListener
mocks/mock_MarketDepth.go:41
MethodAddListener
AddListener adds a listener to marketDepthStream
datastreams/MarketDepth.go:148
MethodAddListener
AddListener adds a listener to the StockHistory stream
datastreams/StockHistory.go:38
MethodAddListener
AddListener adds a listener to the MyOrders stream
datastreams/MarketEvents.go:50
MethodAddListener
AddListener adds a listener for a given user and connection
datastreams/GameStateStream.go:57
MethodAddListener
AddListener adds a listener for a given user and connection
datastreams/Notifications.go:57
MethodAddListener
AddListener adds a listener to the StockExchangeStream
datastreams/StockExchange.go:96
MethodAddListener
AddListener adds a listener to a group in a stream. Creates group if required
datastreams/MulticastStream.go:44
MethodAddListener
AddListener adds a listener to the StockPricesStream
datastreams/StockPrices.go:94
MethodAddListener
AddListener adds a listener to the Transactions stream
datastreams/Transactions.go:51
MethodAddListener
(sessionId string, lis *listener)
datastreams/BroadcastStream.go:13
MethodAddListener
AddListener adds a listener to a stream
datastreams/BroadcastStream.go:44
MethodAddListener
AddListener adds a listener to the MyOrders stream
datastreams/MyOrders.go:47
MethodAddMarketEvent
(ctx context.Context, req *actions_pb.AddMarketEventRequest)
grpcapi/actionservice/AdminActionService.go:271
MethodAddOrder
AddOrder mocks base method
mocks/mock_MarketDepth.go:56
MethodAddOrder
AddOrder indicates an expected call of AddOrder
mocks/mock_MarketDepth.go:61
MethodAddOrder
AddOrder adds an order to a marketdepth stream
datastreams/MarketDepth.go:202
MethodAddPhone
(ctx context.Context, req *actions_pb.AddPhoneRequest)
grpcapi/actionservice/AuthActionService.go:233
MethodAddStocksToExchange
(ctx context.Context, req *actions_pb.AddStocksToExchangeRequest)
grpcapi/actionservice/AdminActionService.go:188
FunctionAddToGeneralLog
AddToGeneralLog adds entries to the GeneralLogs table
models/GeneralLog.go:9
MethodAddTrade
AddTrade mocks base method
mocks/mock_MarketDepth.go:66
MethodAddTrade
AddTrade indicates an expected call of AddTrade
mocks/mock_MarketDepth.go:71
MethodAddTrade
AddTrade adds a trade to the marketdepthstream
datastreams/MarketDepth.go:236
MethodAddUserSubscription
(ctx context.Context, req *actions_pb.AddUserSubscriptionRequest)
grpcapi/actionservice/UserActionService.go:481
FunctionAdminLog
(username, msg string)
models/Admin.go:25
FunctionAssertEqual
(t *testing.T, o1, o2 interface{})
utils/test/testutils.go:11
MethodBlockUser
(ctx context.Context, req *actions_pb.BlockUserRequest)
grpcapi/actionservice/AdminActionService.go:533
MethodBroadcastUpdate
BroadcastUpdate broadcasts a given update to all listeners in the stream
datastreams/BroadcastStream.go:72
MethodBroadcastUpdateToGroup
BroadcastUpdateToGroup broadcasts a given update to all listeners in the stream belonging to the given group
datastreams/MulticastStream.go:100
MethodCancelAskOrder
CancelAskOrder removes an Ask Order from the OrderBook NOTE: 1. It *ONLY* removes it from the depth, and not from the queue Removal from queue will
matchingengine/OrderBook.go:188
MethodCancelAskOrder
CancelAskOrder removes the ask order from the orderbook.
matchingengine/MatchingEngine.go:82
MethodCancelAskOrder
CancelAskOrder mocks base method
mocks/mock_OrderBook.go:87
MethodCancelAskOrder
CancelAskOrder indicates an expected call of CancelAskOrder
mocks/mock_OrderBook.go:92
MethodCancelAskOrder
CancelAskOrder mocks base method
mocks/mock_MatchingEngine.go:57
MethodCancelAskOrder
CancelAskOrder indicates an expected call of CancelAskOrder
mocks/mock_MatchingEngine.go:62
MethodCancelBidOrder
CancelBidOrder removes an Bid Order from the OrderBook NOTE: 1. It *ONLY* removes it from the depth, and not from the queue Removal from queue will
matchingengine/OrderBook.go:205
MethodCancelBidOrder
CancelBidOrder removes the bid order from the orderbook.
matchingengine/MatchingEngine.go:87
MethodCancelBidOrder
CancelBidOrder mocks base method
mocks/mock_OrderBook.go:97
MethodCancelBidOrder
CancelBidOrder indicates an expected call of CancelBidOrder
mocks/mock_OrderBook.go:102
MethodCancelBidOrder
CancelBidOrder mocks base method
mocks/mock_MatchingEngine.go:67
MethodCancelBidOrder
CancelBidOrder indicates an expected call of CancelBidOrder
mocks/mock_MatchingEngine.go:72
MethodCancelIpoBid
(ctx context.Context, req *actions_pb.CancelIpoBidRequest)
grpcapi/actionservice/OrderActionService.go:202
MethodCancelOrder
(ctx context.Context, req *actions_pb.CancelOrderRequest)
grpcapi/actionservice/OrderActionService.go:12
MethodChangePassword
(ctx context.Context, req *actions_pb.ChangePasswordRequest)
grpcapi/actionservice/UserActionService.go:269
MethodClose
Marks an ask as closed and removes it from asksMap
models/Ask.go:214
FunctionCloseDailyChallenge
CloseDailyChallenge closes dailychallenge and updates UserState
models/DailyChallenge.go:240
MethodCloseDailyChallenge
(ctx context.Context, req *actions_pb.CloseDailyChallengeRequest)
grpcapi/actionservice/AdminActionService.go:712
MethodCloseIpoBidding
(ctx context.Context, req *actions_pb.CloseIpoBiddingRequest)
grpcapi/actionservice/AdminActionService.go:917
FunctionCloseMarket
(updatePreviousDayClose bool)
models/MarketClose.go:42
MethodCloseMarket
(ctx context.Context, req *actions_pb.CloseMarketRequest)
grpcapi/actionservice/AdminActionService.go:52
MethodCloseOrder
CloseOrder mocks base method
mocks/mock_MarketDepth.go:76
MethodCloseOrder
CloseOrder indicates an expected call of CloseOrder
mocks/mock_MarketDepth.go:81
MethodCloseOrder
CloseOrder will close an order from the order book. It should be called every time an order closes either due to cancellation or due to fulfillment
datastreams/MarketDepth.go:264
MethodCreateBot
(ctx context.Context, req *actions_pb.CreateBotRequest)
grpcapi/actionservice/BotsActionService.go:12
MethodDelete
(str string)
session/fakeSession.go:52
← previousnext →301–400 of 739, ranked by callers