wormhole-explorer/fly/queue/queue.go

package queue

// Message represents a message from a queue.
type Message interface {
	Data() []byte
	Done()
	Failed()
	IsExpired() bool
}
Fly: Deduplicate & use persistent queue for incoming VAAs (#28) * Deduplication of vaas messages Use persistent queue for vaas messages (except for pyth) Add local flag for local execution (use a memory queue) * Improve names for consumers Add deduplication in memory for all vaas messages and tests Split incoming vaas (pyth and non pyth) into different channels and tests * Check if queue message is expired * Code review updates 2022-11-21 06:18:33 -08:00			`package queue`

			`// Message represents a message from a queue.`
Fix: fly memory leaks in sqs consumer (#126) 2023-02-02 09:51:33 -08:00			`type Message interface {`
			`Data() []byte`
			`Done()`
			`Failed()`
			`IsExpired() bool`
Fly: Deduplicate & use persistent queue for incoming VAAs (#28) * Deduplication of vaas messages Use persistent queue for vaas messages (except for pyth) Add local flag for local execution (use a memory queue) * Improve names for consumers Add deduplication in memory for all vaas messages and tests Split incoming vaas (pyth and non pyth) into different channels and tests * Check if queue message is expired * Code review updates 2022-11-21 06:18:33 -08:00			`}`