From 521aeb823bc8fa1f0a91b540cbbac96328185f51 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Wed, 23 Jun 2021 17:41:51 +0300 Subject: - Add PQ (priority_queue) mock - Add binary heap mock - Connect first sub-plugin (ephemeral) with root jobs plugin Signed-off-by: Valery Piashchynski --- plugins/jobs/brokers/amqp/config.go | 22 ---------------------- 1 file changed, 22 deletions(-) delete mode 100644 plugins/jobs/brokers/amqp/config.go (limited to 'plugins/jobs/brokers/amqp/config.go') diff --git a/plugins/jobs/brokers/amqp/config.go b/plugins/jobs/brokers/amqp/config.go deleted file mode 100644 index a60cb486..00000000 --- a/plugins/jobs/brokers/amqp/config.go +++ /dev/null @@ -1,22 +0,0 @@ -package amqp - -import "time" - -// Config defines sqs broker configuration. -type Config struct { - // Addr of AMQP server (example: amqp://guest:guest@localhost:5672/). - Addr string - - // Timeout to allocate the connection. Default 10 seconds. - Timeout int -} - -// TimeoutDuration returns number of seconds allowed to redial -func (c *Config) TimeoutDuration() time.Duration { - timeout := c.Timeout - if timeout == 0 { - timeout = 10 - } - - return time.Duration(timeout) * time.Second -} -- cgit v1.2.3