Functions — github.com/day0market/geger

hub / github.com/day0market/geger / functions

Functions95 in github.com/day0market/geger

⨍ Functions 95 ◇ Types & classes 53

↓ 10 callersMethodexchange_timestamp

(&self)

src/core/events.rs:41

↓ 9 callersMethodadd_generated_event

(&mut self, event: Event)

src/sim/broker.rs:352

↓ 8 callersMethodnext_public_event_id

(&mut self)

src/sim/broker.rs:148

↓ 8 callersMethodtimestamp

(&self)

src/core/events.rs:29

↓ 5 callersMethodadd_exchange

(&mut self, exchange: Exchange)

src/core/engine.rs:70

↓ 4 callersMethodexchange

(&self)

src/sim/broker.rs:486

↓ 3 callersMethodadd_actor

(&mut self, actor: Arc<Mutex<S>>)

src/core/engine.rs:62

↓ 3 callersMethodadd_message_handler

(&mut self, message_handler: Arc<Mutex<H>>)

src/core/engine.rs:66

↓ 3 callersMethodcancel_order

( &mut self, request: CancelOrderRequest, )

src/core/gateway_router.rs:101

↓ 3 callersMethodexecute_with_sim_environment

( self, md_provider: T, default_latency: Option<Latency>, sim_broker_configs:

src/core/engine.rs:195

↓ 3 callersMethodmd_event_expected_received_ts

(&self, md: &MarketDataEvent)

src/sim/environment.rs:67

↓ 3 callersMethodnext_event

(&mut self)

src/sim/environment.rs:166

↓ 3 callersMethodsend_message_to_handler

(&self, handler: &Arc<Mutex<H>>, message: &M)

src/core/message_bus.rs:82

↓ 3 callersMethodsend_order

( &mut self, request: NewOrderRequest, )

src/core/gateway_router.rs:87

↓ 3 callersMethodstart_threads

( &self, event_provider: T, actions_context: ActionsContext<M, MS>, message_pr

src/core/engine.rs:100

↓ 2 callersMethodcreate_actions_context_with_default_message_provider

( &self, run_messaging: bool, )

src/core/engine.rs:151

↓ 2 callersMethodestimate_market_data_timestamp

(&self, md: &MarketDataEvent)

src/sim/broker.rs:508

↓ 2 callersMethodexchange_requests_receivers

(&self)

src/core/actions_context.rs:32

↓ 2 callersMethodfeed_market_data_event_to_brokers

( &mut self, pending_md_event: MarketDataEvent, )

src/sim/environment.rs:128

↓ 2 callersFunctionget_expected_events_from_fixture

()

tests/sim_environment.rs:48

↓ 2 callersMethodget_generated_events

(&mut self)

src/sim/broker.rs:445

↓ 2 callersMethodget_request_id

(&mut self)

tests/sim_environment.rs:124

↓ 2 callersMethodon_new_timestamp

(&mut self, ts: Timestamp)

src/sim/broker.rs:490

↓ 2 callersMethodprocess_requests_on_new_ts

(&mut self, ts: Timestamp)

src/sim/broker.rs:462

↓ 2 callersMethodreceivers

(&self)

src/core/gateway_router.rs:73

↓ 2 callersMethodsend_message

(&mut self, message: M)

src/core/actions_context.rs:60

↓ 2 callersMethodsymbol

(&self)

src/core/events.rs:65

↓ 1 callersMethodadd_broker

(&mut self, broker: B)

src/sim/environment.rs:54

↓ 1 callersMethodcancel

(&mut self, cancel_ts: u64)

src/sim/broker.rs:65

↓ 1 callersMethodcreation_ts

(&self)

src/core/gateway_router.rs:16

↓ 1 callersMethodexchange

(&self)

src/core/events.rs:53

↓ 1 callersMethodexecute_limit_order

(&mut self, md: &MarketDataEvent, internal_order_id: InternalID)

src/sim/broker.rs:209

↓ 1 callersMethodexecute_requests_after_ts

(&mut self, ts: Timestamp)

src/sim/broker.rs:153

↓ 1 callersMethodget_topic

(&self)

src/core/message_bus.rs:199

↓ 1 callersMethodget_topics

(&self)

src/core/message_bus.rs:224

↓ 1 callersMethodis_event_loop_stopped_message

(&self)

src/core/message_bus.rs:203

↓ 1 callersMethodnext_message

(&mut self)

src/core/message_bus.rs:170

↓ 1 callersMethodon_cancel_order_requests

(&mut self, request: &CancelOrderRequest, ts: Timestamp)

src/sim/broker.rs:359

↓ 1 callersMethodon_event

(&mut self, event: &Event, actions_context: &mut ActionsContext<SimpleMessage, MS>)

examples/strategy.rs:203

↓ 1 callersMethodon_new_market_data

(&mut self, md: &MarketDataEvent)

src/sim/broker.rs:496

↓ 1 callersMethodon_new_message

(&mut self, message: &M, _actions_context: &ActionsContext<M, MS>)

src/core/message_bus.rs:220

↓ 1 callersMethodon_new_order_request

(&mut self, request: &NewOrderRequest, ts: Timestamp)

src/sim/broker.rs:284

↓ 1 callersMethodon_order_accepted

(&mut self, event: &NewOrderAccepted)

tests/sim_environment.rs:119

↓ 1 callersMethodon_quote

( &mut self, event: &Quote, actions_context: &mut ActionsContext<M, MS>, )

tests/sim_environment.rs:148

↓ 1 callersMethodon_quote

( &mut self, quote: &Quote, actions_context: &mut ActionsContext<M, MS>, )

examples/strategy.rs:174

↓ 1 callersMethodon_uds

(&mut self, event: &OrderUpdate)

tests/sim_environment.rs:129

↓ 1 callersMethodread_events_to_buffer

(&mut self)

examples/strategy.rs:103

↓ 1 callersMethodreceiver

(&self)

src/core/message_bus.rs:139

↓ 1 callersMethodrun

(&mut self)

src/core/event_loop.rs:34

↓ 1 callersMethodrun

(&mut self)

src/core/message_bus.rs:93

↓ 1 callersMethodsend_request

( &mut self, request: ExchangeRequest, )

src/core/gateway_router.rs:77

↓ 1 callersMethodset_confirmed_by_exchange

( &mut self, exchange_order_id: String, confirmation_ts: u64, )

src/sim/broker.rs:51

↓ 1 callersMethodset_timestamp

(&mut self, ts: Timestamp)

src/core/market_data.rs:11

↓ 1 callersFunctionsetup_log

( log_level: Option<LevelFilter>, log_file_path: Option<String>, )

src/common/log.rs:10

↓ 1 callersFunctionstart_event_loop

( event_provider: T, actors: Vec<Arc<Mutex<S>>>, actions_context: ActionsContext<M, MS>, )

src/core/event_loop.rs:63

↓ 1 callersFunctionstart_message_bus

( message_provider: T, message_handlers: Vec<Arc<Mutex<H>>>, actions_context: ActionsContext<M, MS

src/core/message_bus.rs:229

↓ 1 callersMethodupdate_orders_on_md

(&mut self, md: &MarketDataEvent)

src/sim/broker.rs:182

↓ 1 callersMethodupdate_pending_md

(&mut self)

src/sim/environment.rs:77

↓ 1 callersMethodwire_latency

(&self)

src/sim/broker.rs:512

Methodcancel_order

(&mut self, request: CancelOrderRequest)

src/core/actions_context.rs:55

Functioncheck_event_sequence_multiple_exchanges_symbols

()

tests/sim_environment.rs:327

Functioncheck_event_sequence_single_exchange_symbol

()

tests/sim_environment.rs:277

Methodexchange

(&self)

src/core/market_data.rs:39

Methodexchange_timestamp

(&self)

src/core/market_data.rs:18

Methodfrom

(md_event: MarketDataEvent)

src/core/events.rs:20

Methodfrom

(err: GatewayRouterError)

src/core/actions_context.rs:19

Methodfrom

(def: QuoteDef)

examples/strategy.rs:44

Methodget_actors

(&self)

src/core/event_loop.rs:58

Methodget_md_events_from_fixture

(fixture_path: &str)

tests/sim_environment.rs:72

Methodget_topics

(&self)

examples/strategy.rs:267

Functionmain

()

examples/strategy.rs:272

Methodnew

(md_provider: T, default_latency: Option<u64>)

src/sim/environment.rs:40

Methodnew

( strict_execution: bool, wire_latency: Option<Latency>, internal_latency: Option<Late

src/sim/broker.rs:91

Methodnew

(exchanges: Vec<Exchange>)

src/core/gateway_router.rs:62

Methodnew

()

src/core/engine.rs:53

Methodnew

( event_provider: T, actors: Vec<Arc<Mutex<S>>>, actions_context: ActionsContext<M, MS

src/core/event_loop.rs:22

Methodnew

(gw_router: GatewayRouter)

src/core/actions_context.rs:75

Methodnew

( message_provider: T, message_handlers: Vec<Arc<Mutex<H>>>, actions_context: ActionsC

src/core/message_bus.rs:47

Methodnew

(fixture_path: &str)

tests/sim_environment.rs:64

Methodnew

(directory: &str)

examples/strategy.rs:79

Methodnew_event_loop_stopped_message

()

src/core/message_bus.rs:207

Methodnew_order_from_exchange_request

(request: &NewOrderRequest, ts: u64)

src/sim/broker.rs:24

Methodnew_with_receiver

(receiver: Receiver<M>)

src/core/message_bus.rs:164

Methodnew_with_sender

(gw_router: GatewayRouter, message_sender: T)

src/core/actions_context.rs:35

Methodnext_event

(&mut self)

tests/sim_environment.rs:84

Methodnext_event

(&mut self)

examples/strategy.rs:131

Methodon_event

(&mut self, event: &Event, actions_context: &mut ActionsContext<M, MS>)

tests/sim_environment.rs:35

Methodon_new_message

( &mut self, message: &SimpleMessage, _actions_context: &ActionsContext<SimpleMessage,

examples/strategy.rs:259

Methodrun_with_event_provider_custom_messaging

( self, event_provider: T, message_sender: MS, message_provider: MP, )

src/core/engine.rs:74

Methodsend_exchange_request

( &mut self, request: ExchangeRequest, )

src/core/actions_context.rs:43

Methodsend_message

(&mut self, message: M)

src/core/message_bus.rs:150

Methodsend_order

(&mut self, request: NewOrderRequest)

src/core/actions_context.rs:50

Methodstart_with_event_provider

( self, event_provider: T, run_messaging: bool, )

src/core/engine.rs:171

Methodsymbol

(&self)

src/core/market_data.rs:46

Methodtimestamp

(&self)

src/core/market_data.rs:28