mirror of
https://github.com/chrislusf/seaweedfs
synced 2025-06-29 08:12:47 +02:00
02773a6107
* rename * set agent address * refactor * add agent sub * pub messages * grpc new client * can publish records via agent * send init message with session id * fmt * check cancelled request while waiting * use sessionId * handle possible nil stream * subscriber process messages * separate debug port * use atomic int64 * less logs * minor * skip io.EOF * rename * remove unused * use saved offsets * do not reuse session, since always session id is new after restart remove last active ts from SessionEntry * simplify printing * purge unused * just proxy the subscription, skipping the session step * adjust offset types * subscribe offset type and possible value * start after the known tsns * avoid wrongly set startPosition * move * remove * refactor * typo * fix * fix changed path
32 lines
851 B
YAML
32 lines
851 B
YAML
services:
|
|
server:
|
|
image: chrislusf/seaweedfs:local
|
|
ports:
|
|
- 9333:9333
|
|
- 19333:19333
|
|
- 8888:8888
|
|
- 18888:18888
|
|
command: "server -ip=server -filer -volume.max=0 -master.volumeSizeLimitMB=8 -volume.preStopSeconds=1"
|
|
healthcheck:
|
|
test: curl -f http://localhost:8888/healthz
|
|
mq_broker:
|
|
image: chrislusf/seaweedfs:local
|
|
ports:
|
|
- 17777:17777
|
|
command: "mq.broker -master=server:9333 -ip=mq_broker"
|
|
depends_on:
|
|
server:
|
|
condition: service_healthy
|
|
mq_agent:
|
|
image: chrislusf/seaweedfs:local
|
|
ports:
|
|
- 16777:16777
|
|
command: "mq.agent -broker=mq_broker:17777 -port=16777"
|
|
depends_on:
|
|
- mq_broker
|
|
mq_client:
|
|
image: chrislusf/seaweedfs:local
|
|
# run a custom command instead of entrypoint
|
|
command: "ls -al"
|
|
depends_on:
|
|
- mq_agent
|