Skip to content

Commit 6a99b95

Browse files
appleboyappleboy
committed
docs: add new flow
Signed-off-by: Bo-Yi.Wu <appleboy.tw@gmail.com>
1 parent db01a05 commit 6a99b95

8 files changed

+500
-4
lines changed

‎README.md

+4-4
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,13 @@ Queue is a Golang library for spawning and managing a Goroutine pool, allowing y
1717

1818
## Queue Scenario
1919

20-
In Single Container or VM
20+
Simple Queue service using Ring Buffer as default backend.
2121

22-
![queue01](./images/flow.svg)
22+
![queue01](./images/flow-01.svg)
2323

24-
Multile Container with Queue service like NSQ, NATs or Redis
24+
Change Queue service like NSQ, NATs or Redis.
2525

26-
![queue02](./images/queue-02.png)
26+
![queue02](./images/flow-02.svg)
2727

2828
## Requirements
2929

‎images/flow.d2 ‎images/flow-01.d2

File renamed without changes.

‎images/flow.svg ‎images/flow-01.svg

File renamed without changes.

‎images/flow-02.d2

+339
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,339 @@
1+
direction: right
2+
3+
user01: User01 {
4+
shape: person
5+
style: {
6+
multiple: true
7+
bold: true
8+
font-size: 28
9+
}
10+
}
11+
12+
user02: User02 {
13+
shape: person
14+
style: {
15+
multiple: true
16+
bold: true
17+
font-size: 28
18+
}
19+
}
20+
21+
user03: User03 {
22+
shape: person
23+
style: {
24+
multiple: true
25+
bold: true
26+
font-size: 28
27+
}
28+
}
29+
30+
user04: User04 {
31+
shape: person
32+
style: {
33+
multiple: true
34+
bold: true
35+
font-size: 28
36+
}
37+
}
38+
39+
user01 -> container.task01: Create Task {
40+
style: {
41+
animated: true
42+
bold: true
43+
font-size: 28
44+
}
45+
}
46+
user02 -> container.task02: Create Task {
47+
style: {
48+
animated: true
49+
bold: true
50+
font-size: 28
51+
}
52+
}
53+
54+
user03 -> container.task03: Create Task {
55+
style: {
56+
animated: true
57+
bold: true
58+
font-size: 28
59+
}
60+
}
61+
62+
user04 -> container.task04: Create Task {
63+
style: {
64+
animated: true
65+
bold: true
66+
font-size: 28
67+
}
68+
}
69+
70+
container: Application {
71+
direction: right
72+
style: {
73+
bold: true
74+
font-size: 28
75+
}
76+
icon: https://icons.terrastruct.com/dev%2Fgo.svg
77+
78+
task01: {
79+
icon: https://icons.terrastruct.com/essentials%2F092-graph%20bar.svg
80+
style: {
81+
multiple: true
82+
bold: true
83+
font-size: 32
84+
}
85+
}
86+
87+
task02: {
88+
icon: https://icons.terrastruct.com/essentials%2F095-download.svg
89+
style: {
90+
multiple: true
91+
bold: true
92+
font-size: 32
93+
}
94+
}
95+
96+
task03: {
97+
icon: https://icons.terrastruct.com/essentials%2F195-attachment.svg
98+
style: {
99+
multiple: true
100+
bold: true
101+
font-size: 32
102+
}
103+
}
104+
105+
task04: {
106+
icon: https://icons.terrastruct.com/essentials%2F213-alarm.svg
107+
style: {
108+
multiple: true
109+
bold: true
110+
font-size: 32
111+
}
112+
}
113+
114+
queue: Queue Library {
115+
icon: https://icons.terrastruct.com/dev%2Fgo.svg
116+
style: {
117+
bold: true
118+
font-size: 32
119+
fill: honeydew
120+
}
121+
producer01: Producer01 {
122+
style: {
123+
bold: true
124+
font-size: 32
125+
fill: PapayaWhip
126+
fill-pattern: grain
127+
border-radius: 8
128+
font: mono
129+
}
130+
}
131+
132+
producer02: Producer02 {
133+
style: {
134+
bold: true
135+
font-size: 32
136+
fill: PapayaWhip
137+
fill-pattern: grain
138+
border-radius: 8
139+
font: mono
140+
}
141+
}
142+
143+
producer03: Producer03 {
144+
style: {
145+
bold: true
146+
font-size: 32
147+
fill: PapayaWhip
148+
fill-pattern: grain
149+
border-radius: 8
150+
font: mono
151+
}
152+
}
153+
154+
producer04: Producer04 {
155+
style: {
156+
bold: true
157+
font-size: 32
158+
fill: PapayaWhip
159+
fill-pattern: grain
160+
border-radius: 8
161+
font: mono
162+
}
163+
}
164+
165+
consumer01: Consumer01 {
166+
style: {
167+
bold: true
168+
font-size: 32
169+
fill: PapayaWhip
170+
fill-pattern: grain
171+
border-radius: 8
172+
font: mono
173+
}
174+
}
175+
176+
consumer02: Consumer02 {
177+
style: {
178+
bold: true
179+
font-size: 32
180+
fill: PapayaWhip
181+
fill-pattern: grain
182+
border-radius: 8
183+
font: mono
184+
}
185+
}
186+
187+
consumer03: Consumer03 {
188+
style: {
189+
bold: true
190+
font-size: 32
191+
fill: PapayaWhip
192+
fill-pattern: grain
193+
border-radius: 8
194+
font: mono
195+
}
196+
}
197+
198+
consumer04: Consumer04 {
199+
style: {
200+
bold: true
201+
font-size: 32
202+
fill: PapayaWhip
203+
fill-pattern: grain
204+
border-radius: 8
205+
font: mono
206+
}
207+
}
208+
209+
database: Ring\nBuffer {
210+
shape: cylinder
211+
style: {
212+
bold: true
213+
font-size: 32
214+
fill-pattern: lines
215+
font: mono
216+
}
217+
}
218+
219+
redis: Redis {
220+
icon: https://icons.terrastruct.com/dev%2Fredis.svg
221+
shape: image
222+
style: {
223+
bold: true
224+
font-size: 32
225+
font: mono
226+
}
227+
}
228+
229+
rabbitmq: RabbotMQ {
230+
icon: ./rabbitmq.svg
231+
shape: image
232+
style: {
233+
bold: true
234+
font-size: 32
235+
font: mono
236+
}
237+
}
238+
239+
nats: NATS {
240+
icon: ./nats.svg
241+
shape: image
242+
style: {
243+
bold: true
244+
font-size: 32
245+
font: mono
246+
}
247+
}
248+
249+
producer01 -> database
250+
producer02 -> redis
251+
producer03 -> rabbitmq
252+
producer04 -> nats
253+
database -> consumer01
254+
redis -> consumer02
255+
rabbitmq -> consumer03
256+
nats -> consumer04
257+
}
258+
259+
worker01: {
260+
icon: https://icons.terrastruct.com/essentials%2F092-graph%20bar.svg
261+
style: {
262+
bold: true
263+
font-size: 32
264+
}
265+
}
266+
267+
worker02: {
268+
icon: https://icons.terrastruct.com/essentials%2F095-download.svg
269+
style: {
270+
bold: true
271+
font-size: 32
272+
}
273+
}
274+
275+
worker03: {
276+
icon: https://icons.terrastruct.com/essentials%2F092-graph%20bar.svg
277+
style: {
278+
bold: true
279+
font-size: 32
280+
}
281+
}
282+
283+
worker04: {
284+
icon: https://icons.terrastruct.com/essentials%2F213-alarm.svg
285+
style: {
286+
bold: true
287+
font-size: 32
288+
}
289+
}
290+
291+
task01 -> queue.producer01: Enqueue Task {
292+
style: {
293+
bold: true
294+
font-size: 28
295+
}
296+
}
297+
task02 -> queue.producer02: Enqueue Task {
298+
style: {
299+
bold: true
300+
font-size: 28
301+
}
302+
}
303+
task03 -> queue.producer03: Enqueue Task {
304+
style: {
305+
bold: true
306+
font-size: 28
307+
}
308+
}
309+
task04 -> queue.producer04: Enqueue Task {
310+
style: {
311+
bold: true
312+
font-size: 28
313+
}
314+
}
315+
queue.consumer01 -> worker01: dispatch task {
316+
style: {
317+
bold: true
318+
font-size: 28
319+
}
320+
}
321+
queue.consumer02 -> worker02: dispatch task {
322+
style: {
323+
bold: true
324+
font-size: 28
325+
}
326+
}
327+
queue.consumer03 -> worker03: dispatch task {
328+
style: {
329+
bold: true
330+
font-size: 28
331+
}
332+
}
333+
queue.consumer04 -> worker04: dispatch task {
334+
style: {
335+
bold: true
336+
font-size: 28
337+
}
338+
}
339+
}

0 commit comments

Comments
 (0)