wormhole-explorer/pipeline
ftocal 7992f76e56
Improve tx tracker logic without internal retries (#890)
* Improve tx tracker logic without internal retries

Co-authored-by: walker-16 <agpazos85@gmail.com>

* Add message attribute in pipeline sns

Co-authored-by: walker-16 <agpazos85@gmail.com>

---------

Co-authored-by: walker-16 <agpazos85@gmail.com>
2023-12-12 15:46:00 -03:00
..
bin Improve pipeline Makefile (#387) 2023-06-12 10:00:23 -03:00
cmd Fix [api] get transactions by address and add mongo query monitor (#707) 2023-09-25 16:50:16 -03:00
config Fix alert prefix with new enviroment values (#509) 2023-07-06 11:20:18 -03:00
healthcheck pipeline: new component (#146) 2023-02-16 11:09:57 -03:00
http/infrastructure Add pipeline prometheus metrics and opsgenie alerts (#471) 2023-07-03 11:42:44 -03:00
internal Improve tx tracker logic without internal retries (#890) 2023-12-12 15:46:00 -03:00
pipeline Add pipeline prometheus metrics and opsgenie alerts (#471) 2023-07-03 11:42:44 -03:00
topic Improve tx tracker logic without internal retries (#890) 2023-12-12 15:46:00 -03:00
watcher Add pipeline prometheus metrics and opsgenie alerts (#471) 2023-07-03 11:42:44 -03:00
.env.example pipeline: new component (#146) 2023-02-16 11:09:57 -03:00
.gitignore [PARSER/PIPELINE] Update .gitignore (#174) 2023-03-06 14:35:53 -03:00
Dockerfile Improve pipeline Makefile (#387) 2023-06-12 10:00:23 -03:00
Makefile Improve pipeline Makefile (#387) 2023-06-12 10:00:23 -03:00
README.md Add localstack config to pipeline project (#761) 2023-10-24 10:25:02 -03:00
go.mod Improve tx tracker logic without internal retries (#890) 2023-12-12 15:46:00 -03:00
go.sum Improve tx tracker logic without internal retries (#890) 2023-12-12 15:46:00 -03:00

README.md

Pipeline

Config sns topic

aws --profile localstack --endpoint-url=http://localhost:4566 sns create-topic --name vaas-pipeline.fifo --attributes FifoTopic=true,ContentBasedDeduplication=false

Config SQS FIFO with dead letter queue localstack

aws --profile localstack --endpoint-url=http://localhost:4566 sqs create-queue --queue-name=wormhole-vaa-queue-name-dlq-queue.fifo --attributes "FifoQueue=true"

aws --profile localstack --endpoint-url=http://localhost:4566 sqs create-queue --queue-name=wormhole-vaa-queue-name-queue.fifo --attributes FifoQueue=true,MessageRetentionPeriod=3600,ReceiveMessageWaitTimeSeconds=5,VisibilityTimeout=20,RedrivePolicy=""{\"deadLetterTargetArn\":\"arn:aws:sqs:us-east-1:000000000000:wormhole-vaa-queue-name-dlq-queue.fifo\",\"maxReceiveCount\":\"2\"}""

Subscribe SQS FIFO to vaas-pipeline.fifo topic

aws --profile localstack --endpoint-url=http://localhost:4566 sns subscribe --topic-arn arn:aws:sns:us-east-1:000000000000:vaas-pipeline.fifo --protocol sqs --notification-endpoint http://localhost:4566/000000000000/wormhole-vaa-queue-name-queue.fifo

Check message in the dead letter queue localstack

aws --profile localstack --endpoint-url=http://localhost:4566 sqs receive-message --queue-url=http://localhost:4566/000000000000/wormhole-vaa-queue-name-dlq-queue.fifo