- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for init (0.17 sec)
-
internal/event/target/amqp.go
if !filepath.IsAbs(a.QueueDir) { return errors.New("queueDir path should be absolute") } } return nil } // AMQPTarget - AMQP target type AMQPTarget struct { initOnce once.Init id event.TargetID args AMQPArgs conn *amqp091.Connection connMutex sync.Mutex store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0)