Functions — github.com/bloomberg/blazingmq

CodeHub MCPcopy Create free account

hub / github.com/bloomberg/blazingmq / functions

Functions9,318 in github.com/bloomberg/blazingmq

⨍ Functions 9,318◇ Types & classes 2,131

↓ 5 callersMethodcloseQueue

Sends an `CloseQueue` event for the specified `uri` and `queuId`, to this testbench's `ClientSession`.

src/groups/mqb/mqba/mqba_clientsession.t.cpp:786

↓ 5 callersMethodclusterNode

src/groups/mqb/mqbnet/mqbnet_dummysession.h:188

↓ 5 callersMethodclusterNode

src/groups/mqb/mqbc/mqbc_clusternodesession.h:444

↓ 5 callersMethodclusterPeer

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9871

↓ 5 callersMethodconfigureQueueSync

src/groups/bmq/bmqa/bmqa_session.cpp:1148

↓ 5 callersMethodconfirmMessage

src/groups/bmq/bmqa/bmqa_session.h:1131

↓ 5 callersMethodconsumptionMonitorPeriodMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10853

↓ 5 callersMethodcontextType

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1831

↓ 5 callersFunctioncurrentTime

Return the current time in UTC

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.cpp:97

↓ 5 callersMethoddeletionRecordFlag

src/groups/mqb/mqbs/mqbs_filestoreprotocol.h:2870

↓ 5 callersMethoddeliverMessage

src/groups/mqb/mqbblp/mqbblp_queuehandle.cpp:794

↓ 5 callersMethoddisable

src/groups/mqb/mqbblp/mqbblp_queueengineutil.h:638

↓ 5 callersMethoddownstreamBroker

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9861

↓ 5 callersMethoddropPendingJobs

src/groups/mwc/mwcex/mwcex_sequentialcontext.cpp:199

↓ 5 callersMethodend

src/groups/mqb/mqbblp/mqbblp_routers.h:320

↓ 5 callersFunctionfanoutConfig

Return a fanout domain.

src/groups/mqb/mqbblp/mqbblp_relayqueueengine.t.cpp:55

↓ 5 callersMethodfindBySubId

src/groups/bmq/bmqp/bmqp_protocolutil.h:1175

↓ 5 callersMethodflushAtShutdown

src/groups/mqb/mqbcfg/mqbcfg_messages.h:13905

↓ 5 callersMethodfragmentBit

src/groups/bmq/bmqp/bmqp_protocol.h:3790

↓ 5 callersMethodgcExpiredMessages

src/groups/mqb/mqbs/mqbs_filestore.cpp:6830

↓ 5 callersMethodgenCount

src/groups/mqb/mqbi/mqbi_dispatcher.h:1406

↓ 5 callersMethodgetOutboundControlMessage

src/groups/bmq/bmqimp/bmqimp_brokersession.t.cpp:2398

↓ 5 callersMethodgetPropertyAsChar

src/groups/bmq/bmqp/bmqp_messageproperties.h:895

↓ 5 callersMethodgetSchemaId

src/groups/bmq/bmqp/bmqp_schemagenerator.cpp:76

↓ 5 callersMethodhasNoHandleStreamConsumers

src/groups/mqb/mqbi/mqbi_queue.h:1080

↓ 5 callersMethodhasNoMoreBroadcastedMessages

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.t.cpp:357

↓ 5 callersMethodhasProperty

src/groups/bmq/bmqa/bmqa_messageproperties.cpp:271

↓ 5 callersMethodhash

src/groups/mwc/mwcst/mwcst_value.cpp:60

↓ 5 callersMethodhashValue

src/groups/mwc/mwcst/mwcst_stringkey.h:274

↓ 5 callersMethodheartbeatCheckPeriodMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9660

↓ 5 callersMethodheartbeatMissCount

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9665

↓ 5 callersMethodhighInterval

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10265

↓ 5 callersMethodhighWatermark2

src/groups/mwc/mwcc/mwcc_monitoredqueue.h:760

↓ 5 callersMethodhighWatermarkRatio

src/groups/mqb/mqbu/mqbu_resourceusagemonitor.h:567

↓ 5 callersMethodid

src/groups/bmq/bmqt/bmqt_subscription.h:311

↓ 5 callersMethodimport

src/groups/mwc/mwcio/mwcio_ntcchannel.cpp:1116

↓ 5 callersMethodisComplete

src/groups/mwc/mwcio/mwcio_ntcchannel.cpp:460

↓ 5 callersMethodisDatum

src/groups/mwc/mwct/mwct_propertybag.h:325

↓ 5 callersMethodisEmpty

src/groups/bmq/bmqt/bmqt_queueflags.h:283

↓ 5 callersMethodisEnabled

src/groups/mwc/mwctst/mwctst_scopedlogobserver.cpp:121

↓ 5 callersMethodisHeartbeatReqEvent

src/groups/bmq/bmqp/bmqp_event.h:512

↓ 5 callersMethodisRunning

src/groups/mwc/mwcu/mwcu_operationchain.cpp:322

↓ 5 callersMethodisSessionEvent

src/groups/bmq/bmqa/bmqa_event.cpp:75

↓ 5 callersMethodisUndefinedValue

src/groups/mwc/mwcstm/mwcstm_values.h:2187

↓ 5 callersMethoditerateAndInvoke

src/groups/bmq/bmqimp/bmqimp_messagecorrelationidcontainer.cpp:233

↓ 5 callersMethodleaderNodeId

src/groups/mqb/mqbc/mqbc_electorinfo.h:364

↓ 5 callersMethodleaderSyncDelayMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9675

↓ 5 callersMethodledger

src/groups/mqb/mqbc/mqbc_clusterstateledgerutil.t.cpp:192

↓ 5 callersMethodloadCurrentFiles

src/groups/mqb/mqbs/mqbs_filestore.cpp:7331

↓ 5 callersMethodloadIndex

PUBLIC ACCESSORS

src/groups/bmq/bmqp/bmqp_messageproperties.cpp:195

↓ 5 callersMethodloadQueueUri

src/groups/mqb/mqbs/mqbs_qlistfileiterator.cpp:275

↓ 5 callersMethodloadQueueUriHash

src/groups/mqb/mqbs/mqbs_qlistfileiterator.cpp:293

↓ 5 callersMethodloadRejectMessageIterator

src/groups/bmq/bmqp/bmqp_event.h:621

↓ 5 callersMethodload_factor

src/groups/mwc/mwcc/mwcc_orderedhashmap.h:1606

↓ 5 callersMethodlowInterval

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10260

↓ 5 callersMethodlowThreshold

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10250

↓ 5 callersMethodlowWatermark

src/groups/mqb/mqbcfg/mqbcfg_messages.h:12587

↓ 5 callersMethodlowWatermarkRatio

src/groups/mqb/mqbu/mqbu_resourceusagemonitor.h:561

↓ 5 callersMethodmaxAttemptsStorageSync

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11897

↓ 5 callersMethodmaxConnections

src/groups/mqb/mqbcfg/mqbcfg_messages.h:12582

↓ 5 callersMethodmaxGroups

src/groups/mqb/mqbconfm/mqbconfm_messages.h:6124

↓ 5 callersMethodmaxIdleTime

src/groups/mqb/mqbconfm/mqbconfm_messages.h:7725

↓ 5 callersMethodmaxRandomWaitTimeoutMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9640

↓ 5 callersMethodmemResident

src/groups/mwc/mwcsys/mwcsys_statmonitor.h:462

↓ 5 callersMethodmemVirtual

src/groups/mwc/mwcsys/mwcsys_statmonitor.h:467

↓ 5 callersMethodmessagePropertyHeaderSize

src/groups/bmq/bmqp/bmqp_protocol.h:4012

↓ 5 callersMethodminCppSdkVersion

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10061

↓ 5 callersMethodminJavaSdkVersion

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10066

↓ 5 callersMethodmiscWorkThreadPool

src/groups/mqb/mqbblp/mqbblp_queuestate.h:535

↓ 5 callersMethodnextInBucket

src/groups/mwc/mwcc/mwcc_orderedhashmap.h:827

↓ 5 callersMethodnumAssignedQueues

src/groups/mqb/mqbc/mqbc_clusterstate.h:1057

↓ 5 callersMethodnumPendingReopenQueueRequests

src/groups/mqb/mqbblp/mqbblp_clusterqueuehelper.h:1345

↓ 5 callersMethodnumProcessors

src/groups/mqb/mqbcfg/mqbcfg_messages.h:12954

↓ 5 callersMethodopenQueue

src/groups/mqb/mqbblp/mqbblp_domain.cpp:570

↓ 5 callersMethodopenTimeoutMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10813

↓ 5 callersMethodparent

src/groups/mqb/mqbu/mqbu_capacitymeter.h:444

↓ 5 callersMethodpartitionSequenceNumber

src/groups/mqb/mqbs/mqbs_filestoreprotocol.h:2595

↓ 5 callersMethodpartitionSyncDataReqTimeoutMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11917

↓ 5 callersMethodpartitionSyncStateReqTimeoutMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11912

↓ 5 callersMethodpeerInstanceId

src/groups/mqb/mqbc/mqbc_clusternodesession.h:454

↓ 5 callersMethodpendingUnassignment

src/groups/mqb/mqbc/mqbc_clusterstate.h:850

↓ 5 callersFunctionprintRecord

src/groups/mqb/mqbs/mqbs_filestoreprotocolprinter.cpp:327

↓ 5 callersMethodprocess

src/groups/mwc/mwcu/mwcu_atomicstate.cpp:26

↓ 5 callersMethodprocessPacket

src/groups/bmq/bmqimp/bmqimp_brokersession.cpp:5694

↓ 5 callersMethodprocessPrimaryStateRequest

src/groups/mqb/mqbc/mqbc_storagemanager.cpp:3096

↓ 5 callersMethodprotocolVersion

src/groups/mqb/mqbc/mqbc_clusterstateledgerprotocol.h:443

↓ 5 callersMethodqueueHandle

src/groups/mqb/mqbi/mqbi_storage.h:727

↓ 5 callersFunctionqueuePerformance

src/groups/bmq/bmqimp/bmqimp_eventqueue.t.cpp:131

↓ 5 callersMethodqueueRecordHeader

src/groups/mqb/mqbs/mqbs_qlistfileiterator.h:267

↓ 5 callersMethodqueueStatContext

src/groups/mqb/mqbblp/mqbblp_domain.h:399

↓ 5 callersMethodrebalance

src/groups/mqb/mqbconfm/mqbconfm_messages.h:6119

↓ 5 callersMethodreopenMaxAttempts

src/groups/mqb/mqbcfg/mqbcfg_messages.h:10838

↓ 5 callersMethodrequestGroupId

src/groups/bmq/bmqimp/bmqimp_queue.h:591

↓ 5 callersMethodreserveOnDisk

src/groups/mqb/mqbsi/mqbsi_log.h:546

↓ 5 callersMethodreset

src/groups/mqb/mqbnet/mqbnet_channel.cpp:52

↓ 5 callersMethodrotateBytes

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11541

↓ 5 callersMethodrotateDays

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11546

↓ 5 callersFunctionrun

Start the Application in the specified `taskEnv` and wait until termination (if the optionally specified `wait` is true). Return 0 on success, or a n

src/applications/bmqbrkr/bmqbrkr.m.cpp:566

↓ 5 callersFunctionrunTest

-------------- Free Functions --------------

src/groups/mwc/mwctst/mwctst_testhelper.cpp:106

↓ 5 callersMethodscoutingResultTimeoutMs

src/groups/mqb/mqbcfg/mqbcfg_messages.h:9645

← previous next →1,201–1,300 of 9,318, ranked by callers