docs/diagrams/pubsub_component_broker_interface.svg

<?xml version="1.0" encoding="UTF-8" standalone="no"?><svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentStyleType="text/css" height="591px" preserveAspectRatio="none" style="width:791px;height:591px;background:#FFFFFF;" version="1.1" viewBox="0 0 791 591" width="791px" zoomAndPan="magnify"><defs/><g><!--MD5=[50cc11a8820fbe89aeca4e6c9218b66c]
cluster pub--><g id="cluster_pub"><rect fill="none" height="225" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:1.0;" width="249" x="11" y="272"/><rect fill="none" height="10" style="stroke:#181818;stroke-width:1.0;" width="15" x="240" y="277"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="238" y="279"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="238" y="283"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="120" x="75.5" y="297.9951">Publisher gRPC</text></g><!--MD5=[dce5c8b17cc832792ef26dde9a08d226]
cluster ps_service--><g id="cluster_ps_service"><rect fill="none" height="225" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:1.0;" width="247" x="418" y="272"/><rect fill="none" height="10" style="stroke:#181818;stroke-width:1.0;" width="15" x="645" y="277"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="643" y="279"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="643" y="283"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="170" x="456.5" y="297.9951">PubSub Service gRPC</text></g><!--MD5=[9892c6f77c442752088fcf6c309c0000]
cluster sub--><g id="cluster_sub"><rect fill="none" height="225" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:1.0;" width="249" x="536" y="7"/><rect fill="none" height="10" style="stroke:#181818;stroke-width:1.0;" width="15" x="765" y="12"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="763" y="14"/><rect fill="none" height="2" style="stroke:#181818;stroke-width:1.0;" width="4" x="763" y="18"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="132" x="594.5" y="32.9951">Subscriber gRPC</text></g><!--MD5=[b9060e1352b009711fbb9730f967b58f]
entity Publisher--><g id="elem_Publisher"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="104" x="35" y="315"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="119" y="320"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="117" y="322"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="117" y="326"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="64" x="50" y="347.9951">Publisher</text></g><!--MD5=[ea407da26b222822f5fc0c196c93841e]
entity pub.broker--><g id="elem_pub.broker"><ellipse cx="44" cy="450" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="76" x="6" y="479.9951">pub.broker</text></g><!--MD5=[98c53b6aee5027ff39faf44ca8fdb334]
entity PubConnector--><g id="elem_PubConnector"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="140" x="88" y="427"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="208" y="432"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="206" y="434"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="206" y="438"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="100" x="103" y="459.9951">PubConnector</text></g><!--MD5=[3e42b813b56a6d688298e25af455da07]
entity Topic Mgmt--><g id="elem_Topic Mgmt"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="121" x="461.5" y="315"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="562.5" y="320"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="560.5" y="322"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="560.5" y="326"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="81" x="476.5" y="347.9951">Topic Mgmt</text></g><!--MD5=[0cfbc4f7b0e8e5a87328048c48e0677d]
entity broker.monitor--><g id="elem_broker.monitor"><ellipse cx="459" cy="450" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="102" x="408" y="479.9951">broker.monitor</text></g><!--MD5=[29a22b9cbd3ee56d482b662ce2ab413f]
entity BrokerMonitor--><g id="elem_BrokerMonitor"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="138" x="503" y="427"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="621" y="432"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="619" y="434"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="619" y="438"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="98" x="518" y="459.9951">BrokerMonitor</text></g><!--MD5=[dffc2048202062908f47a53e24d356df]
entity Subscriber--><g id="elem_Subscriber"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="114" x="579" y="50"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="673" y="55"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="671" y="57"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="671" y="61"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="74" x="594" y="82.9951">Subscriber</text></g><!--MD5=[ba5e977ba4b1ab332bd534042f1e23da]
entity sub.broker--><g id="elem_sub.broker"><ellipse cx="577" cy="185" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="75" x="539.5" y="214.9951">sub.broker</text></g><!--MD5=[78c1f2d4718ac01ff5b4f9b81d65a064]
entity SubConnector--><g id="elem_SubConnector"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="140" x="621" y="162"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="741" y="167"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="739" y="169"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="739" y="173"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="100" x="636" y="194.9951">SubConnector</text></g><!--MD5=[6c9ce80671f37feef6923a01ca2bde36]
entity publisher.proto--><g id="elem_publisher.proto"><ellipse cx="431" cy="185" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="105" x="378.5" y="214.9951">publisher.proto</text></g><!--MD5=[33c327514065c149da1266a1e46bd2be]
entity sample_publisher.proto--><g id="elem_sample_publisher.proto"><ellipse cx="247" cy="185" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="162" x="166" y="214.9951">sample_publisher.proto</text></g><!--MD5=[a7e7d7289310a33798fa93e9559be466]
entity pubsub.proto--><g id="elem_pubsub.proto"><ellipse cx="339" cy="450" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="94" x="292" y="479.9951">pubsub.proto</text></g><!--MD5=[241b36de05534b6660b3ddf6e8766aa9]
entity Broker--><g id="elem_Broker"><rect fill="#F1F1F1" height="46.2969" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="86" x="529" y="539"/><rect fill="#F1F1F1" height="10" style="stroke:#181818;stroke-width:0.5;" width="15" x="595" y="544"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="593" y="546"/><rect fill="#F1F1F1" height="2" style="stroke:#181818;stroke-width:0.5;" width="4" x="593" y="550"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="46" x="544" y="571.9951">Broker</text></g><!--MD5=[4883df70f6cd75188077a559200db30d]
link Publisher to pub.broker--><g id="link_Publisher_pub.broker"><path d="M78.3,361.26 C69.51,383.75 56.22,417.74 49.04,436.11 " fill="none" id="Publisher-to-pub.broker" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="47.18,440.86,54.1926,433.9445,49.0074,436.2059,46.746,431.0207,47.18,440.86" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[c07ffec40215ddfa1d84bef377441ea8]
link pub.broker to PubConnector--><g id="link_pub.broker_PubConnector"><path d="M53.35,450 C64.8,450 76.24,450 87.69,450 " fill="none" id="pub.broker-PubConnector" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[7b489e67fcf16fa607fdd75ae5e4ab14]
link publisher.proto to pub--><g id="link_publisher.proto_pub"><path d="M421.88,193.7 C403.925,208.845 362.4925,243.795 325.0425,275.3863 C306.3175,291.1819 288.5881,306.1378 275.2869,317.3586 C271.9616,320.1638 268.913,322.7355 266.1948,325.0286 C264.8358,326.1751 263.5593,327.252 262.3721,328.2535 C261.7785,328.7543 261.2072,329.2362 260.6591,329.6986 C260.5221,329.8142 260.3865,329.9286 260.2524,330.0417 " fill="none" id="publisher.proto-pub" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[e1fcf423b4326c89944076590c4fbd3f]
link sample_publisher.proto to pub--><g id="link_sample_publisher.proto_pub"><path d="M247.27,194.12 C247.525,201.8375 247.9412,214.4094 248.4239,228.9791 C248.6652,236.2639 248.9232,244.0482 249.1858,251.9749 C249.3172,255.9382 249.4497,259.9372 249.5819,263.9271 C249.648,265.922 249.7141,267.9147 249.7799,269.8995 C249.7963,270.3958 249.8127,270.8915 249.8292,271.3866 " fill="none" id="sample_publisher.proto-pub" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[0cbe2f24e2f26f9b8a294116831fd221]
link pub to pubsub.proto--><g id="link_pub_pubsub.proto"><path d="M260.1232,349.2751 C260.2041,349.3774 260.2855,349.4804 260.3674,349.5839 C260.5312,349.791 260.6969,350.0006 260.8647,350.2127 C261.2001,350.6368 261.5433,351.0707 261.8939,351.5141 C267.5041,358.6075 275.0206,368.1113 283.1663,378.41 C299.4575,399.0075 318.265,422.785 329.37,436.82 " fill="none" id="pub-to-pubsub.proto" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="332.65,440.97,330.1981,431.4312,329.5458,437.0504,323.9266,436.398,332.65,440.97" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[b009775042443a3925cc15ae55805b24]
link Topic Mgmt to broker.monitor--><g id="link_Topic Mgmt_broker.monitor"><path d="M509.25,361.26 C496.37,383.75 476.91,417.74 466.38,436.11 " fill="none" id="Topic Mgmt-to-broker.monitor" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="463.66,440.86,471.6023,435.036,466.1438,436.5205,464.6592,431.062,463.66,440.86" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[741f23153de0d9458e026ac843140f56]
link broker.monitor to BrokerMonitor--><g id="link_broker.monitor_BrokerMonitor"><path d="M468.27,450 C479.75,450 491.23,450 502.71,450 " fill="none" id="broker.monitor-BrokerMonitor" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[7239b8cf220456376a6c2bca6dc09b96]
link ps_service to pubsub.proto--><g id="link_ps_service_pubsub.proto"><path d="M417.9003,349.241 C417.73,349.4563 417.5576,349.6743 417.3829,349.8951 C416.6843,350.7783 415.951,351.7055 415.1858,352.673 C409.0641,360.4128 400.9031,370.7319 392.1963,381.7413 C374.7825,403.76 355.185,428.54 345.35,440.97 " fill="none" id="ps_service-pubsub.proto" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[1bba6e28d5edb2d5d124538c8e9c2111]
reverse link publisher.proto to ps_service--><g id="link_publisher.proto_ps_service"><path d="M430.56,199.4 C430.2575,208.4875 429.8281,221.4256 429.3525,235.7713 C429.1147,242.9441 428.8653,250.4688 428.6145,258.0399 C428.489,261.8255 428.3632,265.6227 428.2383,269.3934 C428.2227,269.8647 428.2071,270.3356 428.1915,270.806 C428.1837,271.0413 428.1759,271.2764 428.1681,271.5113 " fill="none" id="publisher.proto-backto-ps_service" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="430.73,194.12,426.4485,202.9895,430.5725,199.1175,434.4445,203.2415,430.73,194.12" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[a64f956284a1e5141cd10c7f8d57be27]
link Subscriber to sub.broker--><g id="link_Subscriber_sub.broker"><path d="M624.06,96.26 C612,118.75 593.77,152.74 583.91,171.11 " fill="none" id="Subscriber-to-sub.broker" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="581.37,175.86,589.1611,169.8352,583.7422,171.4586,582.1188,166.0396,581.37,175.86" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[59e5f71947d22e7e73388f42685e99c9]
link sub.broker to SubConnector--><g id="link_sub.broker_SubConnector"><path d="M586.35,185 C597.8,185 609.24,185 620.69,185 " fill="none" id="sub.broker-SubConnector" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[429a281aa57ccb5c16255d472700b8a6]
link sub to sample_publisher.proto--><g id="link_sub_sample_publisher.proto"><path d="M535.898,77.0021 C535.7202,77.0679 535.5397,77.1348 535.3565,77.2026 C534.6238,77.474 533.8482,77.7613 533.0313,78.0638 C526.4956,80.4844 517.3113,83.8859 506.22,87.9937 C484.0375,96.2094 454.2275,107.25 422.725,118.9175 C359.72,142.2525 289.945,168.095 260.88,178.86 " fill="none" id="sub-to-sample_publisher.proto" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="256.08,180.64,265.9082,181.2779,260.771,178.9095,263.1394,173.7723,256.08,180.64" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[c4849d91be93f899991a6ebe5c19fe8e]
link PubConnector to Broker--><g id="link_PubConnector_Broker"><path d="M189.59,473.27 C210.36,486.85 238.67,503.38 266,513 C353.7,543.86 462.51,554.93 523.92,558.87 " fill="none" id="PubConnector-to-Broker" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="528.98,559.18,520.2487,554.6233,523.9898,558.8663,519.7468,562.6075,528.98,559.18" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[bfae7f505b0d7fb9168c42af7407d113]
link BrokerMonitor to Broker--><g id="link_BrokerMonitor_Broker"><path d="M572,478.35 C572,495.24 572,516.82 572,533.7 " fill="none" id="BrokerMonitor-Broker" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="572,538.77,576,529.77,572,533.77,568,529.77,572,538.77" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="572,473.26,568,482.26,572,478.26,576,482.26,572,473.26" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[e306825022451acf4bc293f5e036e1f6]
link Broker to SubConnector--><g id="link_Broker_SubConnector"><path d="M615.21,546.35 C630.89,538.84 647.15,528.02 657,513 C719.26,418.01 705.27,273.11 695.95,213.29 " fill="none" id="Broker-to-SubConnector" style="stroke:#181818;stroke-width:1.0;"/><polygon fill="#181818" points="695.13,208.11,692.5968,217.6275,695.9172,213.0476,700.497,216.368,695.13,208.11" style="stroke:#181818;stroke-width:1.0;"/></g><!--MD5=[c25d274a5829b9227cb347e4cd21949c]
@startuml pubsub component diagram with broker interface
component "Publisher gRPC" as pub {
    [Publisher] - -> pub.broker
    pub.broker - [PubConnector]
}

pub -up- publisher.proto
pub -up- sample_publisher.proto
pub - -> pubsub.proto

component "PubSub Service gRPC" as ps_service {
    [Topic Mgmt] - -> broker.monitor
    broker.monitor - [BrokerMonitor]
}

ps_service - - pubsub.proto
ps_service -up-> publisher.proto

component "Subscriber gRPC" as sub {
    [Subscriber] - -> sub.broker
    sub.broker - [SubConnector]
}

sub - -> sample_publisher.proto

[PubConnector] -down-> [Broker]
[BrokerMonitor] <-down-> [Broker]
[Broker] -> [SubConnector]

@enduml

PlantUML version 1.2022.7(Mon Aug 22 10:01:30 PDT 2022)
(GPL source distribution)
Java Runtime: OpenJDK Runtime Environment
JVM: OpenJDK 64-Bit Server VM
Default Encoding: UTF-8
Language: en
Country: null
--></g></svg>