go-workers-multipool-Class_Diagram.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" contentScriptType="application/ecmascript" contentStyleType="text/css" height="685px" preserveAspectRatio="none" style="width:1374px;height:685px;" version="1.1" viewBox="0 0 1374 685" width="1374px" zoomAndPan="magnify"><defs/><g><text fill="#000000" font-family="sans-serif" font-size="18" lengthAdjust="spacingAndGlyphs" textLength="475" x="455.5" y="16.708">https://github.com/ericbrisrubio/go-workers-multipool</text><!--MD5=[10ad930ee69173cd9d3aa754f8a8a48b]
cluster manager--><polygon fill="#FFFFFF" points="22,44.9531,97,44.9531,104,67.25,542,67.25,542,335.9531,22,335.9531,22,44.9531" style="stroke: #000000; stroke-width: 1.5;"/><line style="stroke: #000000; stroke-width: 1.5;" x1="22" x2="104" y1="67.25" y2="67.25"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="69" x="26" y="59.9482">manager</text><!--MD5=[11ff06a06e229bcdef1dab44f5b0a7ed]
cluster pool--><polygon fill="#FFFFFF" points="566,89.9531,606,89.9531,613,112.25,1201,112.25,1201,673.9531,566,673.9531,566,89.9531" style="stroke: #000000; stroke-width: 1.5;"/><line style="stroke: #000000; stroke-width: 1.5;" x1="566" x2="613" y1="112.25" y2="112.25"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="34" x="570" y="104.9482">pool</text><!--MD5=[93b1f10045dc706ac2bd80dc0504e18b]
cluster goworkerpool--><polygon fill="#FFFFFF" points="1225,140.9531,1342,140.9531,1349,163.25,1352,163.25,1352,239.9531,1225,239.9531,1225,140.9531" style="stroke: #000000; stroke-width: 1.5;"/><line style="stroke: #000000; stroke-width: 1.5;" x1="1225" x2="1349" y1="163.25" y2="163.25"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacingAndGlyphs" textLength="111" x="1229" y="155.9482">goworkerpool</text><!--MD5=[fa66c4203ab045d195e5f19e9d99aa7b]
class manager.Manager--><rect fill="#FEFECE" height="240.0703" id="manager.Manager" rx="5" ry="5" style="stroke: #A80036; stroke-width: 1.5;" width="489" x="37.5" y="79.9531"/><ellipse cx="250.25" cy="95.9531" fill="#7FFFD4" rx="11" ry="11" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M249.7344,96.5156 Q247.875,95.8125 247.2188,95.0469 Q246.5781,94.2656 246.5781,92.9531 Q246.5781,91.2656 247.6563,90.2969 Q248.7344,89.3281 250.6094,89.3281 Q251.4688,89.3281 252.3125,89.5313 Q253.1719,89.7188 254.0156,90.1094 L254.0156,92.5 Q253.2344,91.9375 252.4063,91.6563 Q251.5938,91.3594 250.7969,91.3594 Q249.9219,91.3594 249.4375,91.7188 Q248.9688,92.0781 248.9688,92.7344 Q248.9688,93.25 249.3125,93.5938 Q249.6563,93.9219 250.75,94.3281 L251.8125,94.7344 Q253.2969,95.2813 254,96.1875 Q254.7188,97.0938 254.7188,98.4688 Q254.7188,100.3438 253.6094,101.2656 Q252.5,102.1875 250.25,102.1875 Q249.3281,102.1875 248.4063,101.9688 Q247.4844,101.75 246.625,101.3281 L246.625,98.7969 Q247.5938,99.4844 248.5156,99.8281 Q249.4375,100.1719 250.3281,100.1719 Q251.2344,100.1719 251.7344,99.7656 Q252.2344,99.3438 252.2344,98.6094 Q252.2344,98.0469 251.8906,97.6406 Q251.5625,97.2188 250.9375,96.9688 L249.7344,96.5156 Z "/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="55" x="270.75" y="100.1074">Manager</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="38.5" x2="525.5" y1="111.9531" y2="111.9531"/><rect fill="none" height="6" style="stroke: #C82930; stroke-width: 1.0;" width="6" x="45.5" y="119.9531"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="81" x="57.5" y="126.1636">poolsInitializer</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="25" x="142.5" y="126.1636">map</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="55" x="167.5" y="126.1636">[string]int</text><rect fill="none" height="6" style="stroke: #C82930; stroke-width: 1.0;" width="6" x="45.5" y="132.7578"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="31" x="57.5" y="138.9683">pools</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="25" x="92.5" y="138.9683">map</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="128" x="117.5" y="138.9683">[string]pool.Descriptor</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="38.5" x2="525.5" y1="145.5625" y2="145.5625"/><rect fill="#F24D5C" height="6" style="stroke: #C82930; stroke-width: 1.0;" width="6" x="45.5" y="153.5625"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="185" x="57.5" y="159.7729">isPoolDefined(poolID string) bool</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="0" x="61.5" y="172.5776"/><ellipse cx="48.5" cy="182.1719" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="463" x="57.5" y="185.3823">AddPool(poolID string, initialWorkers int, maxJobsInQueue int, verbose bool) error</text><ellipse cx="48.5" cy="194.9766" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="165" x="57.5" y="198.187">StartPool(poolID string) error</text><ellipse cx="48.5" cy="207.7813" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="194" x="57.5" y="210.9917">SetFunc(poolID string, workerFunc</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="24" x="255.5" y="210.9917">func</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="4" x="279.5" y="210.9917">(</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="283.5" y="210.9917">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="83" x="333.5" y="210.9917">{}) bool) error</text><ellipse cx="48.5" cy="220.5859" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="195" x="57.5" y="223.7964">AddTaskToPool(poolID string, data</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="256.5" y="223.7964">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="51" x="306.5" y="223.7964">{}) error</text><ellipse cx="48.5" cy="233.3906" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="287" x="57.5" y="236.6011">AddWorkersToPool(poolID string, amount int) error</text><ellipse cx="48.5" cy="246.1953" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="297" x="57.5" y="249.4058">KillWorkersFromPool(poolID string, amount int) error</text><ellipse cx="48.5" cy="259" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="316" x="57.5" y="262.2104">EditPoolWorkersAmount(poolID string, amount int) error</text><ellipse cx="48.5" cy="271.8047" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="247" x="57.5" y="275.0151">PauseWorkersFromPool(poolID string) error</text><ellipse cx="48.5" cy="284.6094" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="258" x="57.5" y="287.8198">ResumeWorkersFromPool(poolID string) error</text><ellipse cx="48.5" cy="297.4141" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="178" x="57.5" y="300.6245">WaitForPool(poolID string) error</text><ellipse cx="48.5" cy="310.2188" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="126" x="57.5" y="313.4292">WaitForAllPools() error</text><!--MD5=[63645ebfbe3cda1102899ca5f889d42f]
class pool.Descriptor--><rect fill="#FEFECE" height="150.4375" id="pool.Descriptor" rx="5" ry="5" style="stroke: #A80036; stroke-width: 1.5;" width="257" x="754.5" y="124.9531"/><ellipse cx="846.75" cy="140.9531" fill="#B4A7E5" rx="11" ry="11" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M842.6719,136.7188 L842.6719,134.5625 L850.0625,134.5625 L850.0625,136.7188 L847.5938,136.7188 L847.5938,144.7969 L850.0625,144.7969 L850.0625,146.9531 L842.6719,146.9531 L842.6719,144.7969 L845.1406,144.7969 L845.1406,136.7188 L842.6719,136.7188 Z "/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacingAndGlyphs" textLength="64" x="867.25" y="145.1074">Descriptor</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="755.5" x2="1010.5" y1="156.9531" y2="156.9531"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="755.5" x2="1010.5" y1="164.9531" y2="164.9531"/><ellipse cx="765.5" cy="175.9531" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="99" x="774.5" y="179.1636">SetWorkerFunc(fn</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="24" x="877.5" y="179.1636">func</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="4" x="901.5" y="179.1636">(</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="905.5" y="179.1636">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="955.5" y="179.1636">{}) bool)</text><ellipse cx="765.5" cy="188.7578" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="77" x="774.5" y="191.9683">AddTask(data</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="855.5" y="191.9683">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="51" x="905.5" y="191.9683">{}) error</text><ellipse cx="765.5" cy="201.5625" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="169" x="774.5" y="204.7729">AddWorkers(amount int) error</text><ellipse cx="765.5" cy="214.3672" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="164" x="774.5" y="217.5776">KillWorkers(amount int) error</text><ellipse cx="765.5" cy="227.1719" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="212" x="774.5" y="230.3823">EditWorkersAmount(amount int) error</text><ellipse cx="765.5" cy="239.9766" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="102" x="774.5" y="243.187">PauseAllWorkers()</text><ellipse cx="765.5" cy="252.7813" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="113" x="774.5" y="255.9917">ResumeAllWorkers()</text><ellipse cx="765.5" cy="265.5859" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="64" x="774.5" y="268.7964">Wait() error</text><!--MD5=[b334c4e7856db6af61669b99b2f020b3]
class pool.GoWorkerPoolAdapter--><rect fill="#FEFECE" height="150.4375" id="pool.GoWorkerPoolAdapter" rx="5" ry="5" style="stroke: #A80036; stroke-width: 1.5;" width="284" x="901" y="443.9531"/><ellipse cx="969.75" cy="459.9531" fill="#7FFFD4" rx="11" ry="11" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M969.2344,460.5156 Q967.375,459.8125 966.7188,459.0469 Q966.0781,458.2656 966.0781,456.9531 Q966.0781,455.2656 967.1563,454.2969 Q968.2344,453.3281 970.1094,453.3281 Q970.9688,453.3281 971.8125,453.5313 Q972.6719,453.7188 973.5156,454.1094 L973.5156,456.5 Q972.7344,455.9375 971.9063,455.6563 Q971.0938,455.3594 970.2969,455.3594 Q969.4219,455.3594 968.9375,455.7188 Q968.4688,456.0781 968.4688,456.7344 Q968.4688,457.25 968.8125,457.5938 Q969.1563,457.9219 970.25,458.3281 L971.3125,458.7344 Q972.7969,459.2813 973.5,460.1875 Q974.2188,461.0938 974.2188,462.4688 Q974.2188,464.3438 973.1094,465.2656 Q972,466.1875 969.75,466.1875 Q968.8281,466.1875 967.9063,465.9688 Q966.9844,465.75 966.125,465.3281 L966.125,462.7969 Q967.0938,463.4844 968.0156,463.8281 Q968.9375,464.1719 969.8281,464.1719 Q970.7344,464.1719 971.2344,463.7656 Q971.7344,463.3438 971.7344,462.6094 Q971.7344,462.0469 971.3906,461.6406 Q971.0625,461.2188 970.4375,460.9688 L969.2344,460.5156 Z "/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="138" x="990.25" y="464.1074">GoWorkerPoolAdapter</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="902" x2="1184" y1="475.9531" y2="475.9531"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="902" x2="1184" y1="483.9531" y2="483.9531"/><ellipse cx="912" cy="494.9531" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="99" x="921" y="498.1636">SetWorkerFunc(fn</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="24" x="1024" y="498.1636">func</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="4" x="1048" y="498.1636">(</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="1052" y="498.1636">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="1102" y="498.1636">{}) bool)</text><ellipse cx="912" cy="507.7578" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="77" x="921" y="510.9683">AddTask(data</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="1002" y="510.9683">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="51" x="1052" y="510.9683">{}) error</text><ellipse cx="912" cy="520.5625" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="169" x="921" y="523.7729">AddWorkers(amount int) error</text><ellipse cx="912" cy="533.3672" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="164" x="921" y="536.5776">KillWorkers(amount int) error</text><ellipse cx="912" cy="546.1719" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="258" x="921" y="549.3823">EditWorkersAmount(workersAmount int) error</text><ellipse cx="912" cy="558.9766" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="102" x="921" y="562.187">PauseAllWorkers()</text><ellipse cx="912" cy="571.7813" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="113" x="921" y="574.9917">ResumeAllWorkers()</text><ellipse cx="912" cy="584.5859" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="64" x="921" y="587.7964">Wait() error</text><!--MD5=[0cee053ac768cef23f20934ac4b56d34]
class pool.GoWorkerPoolMock--><rect fill="#FEFECE" height="278.4844" id="pool.GoWorkerPoolMock" rx="5" ry="5" style="stroke: #A80036; stroke-width: 1.5;" width="284" x="582" y="379.9531"/><ellipse cx="659.75" cy="395.9531" fill="#7FFFD4" rx="11" ry="11" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M659.2344,396.5156 Q657.375,395.8125 656.7188,395.0469 Q656.0781,394.2656 656.0781,392.9531 Q656.0781,391.2656 657.1563,390.2969 Q658.2344,389.3281 660.1094,389.3281 Q660.9688,389.3281 661.8125,389.5313 Q662.6719,389.7188 663.5156,390.1094 L663.5156,392.5 Q662.7344,391.9375 661.9063,391.6563 Q661.0938,391.3594 660.2969,391.3594 Q659.4219,391.3594 658.9375,391.7188 Q658.4688,392.0781 658.4688,392.7344 Q658.4688,393.25 658.8125,393.5938 Q659.1563,393.9219 660.25,394.3281 L661.3125,394.7344 Q662.7969,395.2813 663.5,396.1875 Q664.2188,397.0938 664.2188,398.4688 Q664.2188,400.3438 663.1094,401.2656 Q662,402.1875 659.75,402.1875 Q658.8281,402.1875 657.9063,401.9688 Q656.9844,401.75 656.125,401.3281 L656.125,398.7969 Q657.0938,399.4844 658.0156,399.8281 Q658.9375,400.1719 659.8281,400.1719 Q660.7344,400.1719 661.2344,399.7656 Q661.7344,399.3438 661.7344,398.6094 Q661.7344,398.0469 661.3906,397.6406 Q661.0625,397.2188 660.4375,396.9688 L659.2344,396.5156 Z "/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="120" x="680.25" y="400.1074">GoWorkerPoolMock</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="583" x2="865" y1="411.9531" y2="411.9531"/><rect fill="none" height="6" style="stroke: #C82930; stroke-width: 1.0;" width="6" x="590" y="419.9531"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="89" x="602" y="426.1636">totalWorkers int</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="0" x="606" y="438.9683"/><ellipse cx="593" cy="448.5625" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="198" x="602" y="451.7729">SetWorkerFuncHasBeenCalled bool</text><ellipse cx="593" cy="461.3672" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="188" x="602" y="464.5776">AddTaskFuncHasBeenCalled bool</text><ellipse cx="593" cy="474.1719" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="181" x="602" y="477.3823">AddWorkersHasBeenCalled bool</text><ellipse cx="593" cy="486.9766" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="176" x="602" y="490.187">KillWorkersHasBeenCalled bool</text><ellipse cx="593" cy="499.7813" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="181" x="602" y="502.9917">EditWorkersHasBeenCalled bool</text><ellipse cx="593" cy="512.5859" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="208" x="602" y="515.7964">PauseAllWorkersHasBeenCalled bool</text><ellipse cx="593" cy="525.3906" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="219" x="602" y="528.6011">ResumeAllWorkersHasBeenCalled bool</text><ellipse cx="593" cy="538.1953" fill="none" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="137" x="602" y="541.4058">WaitHasBeenCalled bool</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="583" x2="865" y1="548" y2="548"/><ellipse cx="593" cy="559" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="99" x="602" y="562.2104">SetWorkerFunc(fn</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="24" x="705" y="562.2104">func</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="4" x="729" y="562.2104">(</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="733" y="562.2104">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="783" y="562.2104">{}) bool)</text><ellipse cx="593" cy="571.8047" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="77" x="602" y="575.0151">AddTask(data</text><text fill="#0000FF" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="50" x="683" y="575.0151">interface</text><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="51" x="733" y="575.0151">{}) error</text><ellipse cx="593" cy="584.6094" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="169" x="602" y="587.8198">AddWorkers(amount int) error</text><ellipse cx="593" cy="597.4141" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="164" x="602" y="600.6245">KillWorkers(amount int) error</text><ellipse cx="593" cy="610.2188" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="258" x="602" y="613.4292">EditWorkersAmount(workersAmount int) error</text><ellipse cx="593" cy="623.0234" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="102" x="602" y="626.2339">PauseAllWorkers()</text><ellipse cx="593" cy="635.8281" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="113" x="602" y="639.0386">ResumeAllWorkers()</text><ellipse cx="593" cy="648.6328" fill="#84BE84" rx="3" ry="3" style="stroke: #038048; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacingAndGlyphs" textLength="64" x="602" y="651.8433">Wait() error</text><!--MD5=[4c5608e2748b004cebceebf0b4c223fa]
class goworkerpool.Pool--><rect fill="#FEFECE" height="48" id="goworkerpool.Pool" rx="5" ry="5" style="stroke: #A80036; stroke-width: 1.5;" width="59" x="1241.5" y="175.9531"/><ellipse cx="1256.5" cy="191.9531" fill="#ADD1B2" rx="11" ry="11" style="stroke: #A80036; stroke-width: 1.0;"/><path d="M1259.4688,197.5938 Q1258.8906,197.8906 1258.25,198.0313 Q1257.6094,198.1875 1256.9063,198.1875 Q1254.4063,198.1875 1253.0781,196.5469 Q1251.7656,194.8906 1251.7656,191.7656 Q1251.7656,188.6406 1253.0781,186.9844 Q1254.4063,185.3281 1256.9063,185.3281 Q1257.6094,185.3281 1258.25,185.4844 Q1258.9063,185.6406 1259.4688,185.9375 L1259.4688,188.6563 Q1258.8438,188.0781 1258.25,187.8125 Q1257.6563,187.5313 1257.0313,187.5313 Q1255.6875,187.5313 1255,188.6094 Q1254.3125,189.6719 1254.3125,191.7656 Q1254.3125,193.8594 1255,194.9375 Q1255.6875,196 1257.0313,196 Q1257.6563,196 1258.25,195.7344 Q1258.8438,195.4531 1259.4688,194.875 L1259.4688,197.5938 Z "/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacingAndGlyphs" textLength="27" x="1270.5" y="196.1074">Pool</text><line style="stroke: #A80036; stroke-width: 1.5;" x1="1242.5" x2="1299.5" y1="207.9531" y2="207.9531"/><line style="stroke: #A80036; stroke-width: 1.5;" x1="1242.5" x2="1299.5" y1="215.9531" y2="215.9531"/><!--MD5=[d38e57a064ea9d38e32ff201ed246a43]
reverse link goworkerpool.Pool to pool.GoWorkerPoolAdapter--><path d="M1256.98,236.3971 C1244.38,266.2951 1224.32,309.5851 1201,343.9531 C1177.17,379.0671 1146.63,414.3681 1118.76,443.9081 " fill="none" id="goworkerpool.Pool&lt;-pool.GoWorkerPoolAdapter" style="stroke: #A80036; stroke-width: 1.0;"/><polygon fill="#A80036" points="1262.06,224.0771,1256.0731,228.0967,1257.4808,235.1691,1263.4677,231.1495,1262.06,224.0771" style="stroke: #A80036; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="51" x="1072.7075" y="432.8345">extends</text><!--MD5=[1db40b993ff80291bffef1e0028f74c8]
reverse link pool.Descriptor to pool.GoWorkerPoolAdapter--><path d="M929.675,293.4281 C953.832,341.2881 982.924,398.9281 1005.584,443.8221 " fill="none" id="pool.Descriptor&lt;-pool.GoWorkerPoolAdapter" style="stroke: #A80036; stroke-width: 1.0;"/><polygon fill="none" points="923.276,296.2841,920.513,275.2751,935.774,289.9761,923.276,296.2841" style="stroke: #A80036; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="76" x="922.3959" y="432.9987">implements</text><!--MD5=[1dc9076d9b86972fe5cad0eb270b5dd3]
reverse link pool.Descriptor to pool.GoWorkerPoolMock--><path d="M836.619,293.4231 C823.075,320.4271 807.969,350.5441 793.33,379.7291 " fill="none" id="pool.Descriptor&lt;-pool.GoWorkerPoolMock" style="stroke: #A80036; stroke-width: 1.0;"/><polygon fill="none" points="830.498,290.0141,845.722,275.2751,843.012,296.2911,830.498,290.0141" style="stroke: #A80036; stroke-width: 1.0;"/><text fill="#000000" font-family="sans-serif" font-size="13" lengthAdjust="spacingAndGlyphs" textLength="76" x="719.0434" y="368.7624">implements</text><!--MD5=[e22bc88c5262c0d187089dace147dd15]
@startuml
skinparamlocked shadowing false
skinparamlocked roundCorner 10
title https://github.com/ericbrisrubio/go-workers-multipool
namespace manager {
    class Manager << (S,Aquamarine) >> {
        - poolsInitializer <font color=blue>map</font>[string]int
        - pools <font color=blue>map</font>[string]pool.Descriptor

        - isPoolDefined(poolID string) bool

        + AddPool(poolID string, initialWorkers int, maxJobsInQueue int, verbose bool) error
        + StartPool(poolID string) error
        + SetFunc(poolID string, workerFunc <font color=blue>func</font>(<font color=blue>interface</font>{}) bool) error
        + AddTaskToPool(poolID string, data <font color=blue>interface</font>{}) error
        + AddWorkersToPool(poolID string, amount int) error
        + KillWorkersFromPool(poolID string, amount int) error
        + EditPoolWorkersAmount(poolID string, amount int) error
        + PauseWorkersFromPool(poolID string) error
        + ResumeWorkersFromPool(poolID string) error
        + WaitForPool(poolID string) error
        + WaitForAllPools() error

    }
}



namespace pool {
    interface Descriptor  {
        + SetWorkerFunc(fn <font color=blue>func</font>(<font color=blue>interface</font>{}) bool) 
        + AddTask(data <font color=blue>interface</font>{}) error
        + AddWorkers(amount int) error
        + KillWorkers(amount int) error
        + EditWorkersAmount(amount int) error
        + PauseAllWorkers() 
        + ResumeAllWorkers() 
        + Wait() error

    }
    class GoWorkerPoolAdapter << (S,Aquamarine) >> {
        + SetWorkerFunc(fn <font color=blue>func</font>(<font color=blue>interface</font>{}) bool) 
        + AddTask(data <font color=blue>interface</font>{}) error
        + AddWorkers(amount int) error
        + KillWorkers(amount int) error
        + EditWorkersAmount(workersAmount int) error
        + PauseAllWorkers() 
        + ResumeAllWorkers() 
        + Wait() error

    }
    class GoWorkerPoolMock << (S,Aquamarine) >> {
        - totalWorkers int

        + SetWorkerFuncHasBeenCalled bool
        + AddTaskFuncHasBeenCalled bool
        + AddWorkersHasBeenCalled bool
        + KillWorkersHasBeenCalled bool
        + EditWorkersHasBeenCalled bool
        + PauseAllWorkersHasBeenCalled bool
        + ResumeAllWorkersHasBeenCalled bool
        + WaitHasBeenCalled bool

        + SetWorkerFunc(fn <font color=blue>func</font>(<font color=blue>interface</font>{}) bool) 
        + AddTask(data <font color=blue>interface</font>{}) error
        + AddWorkers(amount int) error
        + KillWorkers(amount int) error
        + EditWorkersAmount(workersAmount int) error
        + PauseAllWorkers() 
        + ResumeAllWorkers() 
        + Wait() error

    }
}
"goworkerpool.Pool" *- - "extends""pool.GoWorkerPoolAdapter"

"pool.Descriptor" <|- - "implements""pool.GoWorkerPoolAdapter"
"pool.Descriptor" <|- - "implements""pool.GoWorkerPoolMock"


@enduml

PlantUML version 1.2019.12(Sun Nov 03 10:24:54 UTC 2019)
(GPL source distribution)
Java Runtime: OpenJDK Runtime Environment
JVM: OpenJDK 64-Bit Server VM
Java Version: 1.8.0_242-8u242-b08-1~deb9u1-b08
Operating System: Linux
Default Encoding: ANSI_X3.4-1968
Language: en
Country: US
--></g></svg>