Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConditionConfig ¶
type Config ¶
type Config struct { Enable bool BackendURL string `mapstructure:"backend_url"` TTL helper.Duration CleanupInterval helper.Duration `mapstructure:"cleanup_interval"` Timeout helper.Duration ShutdownWaitTime helper.Duration `mapstructure:"shutdown_wait_time"` QueueSize int `mapstructure:"queue_size"` Workers int Conditions []ConditionConfig AutoRetry helper.AutoRetry `mapstructure:"auto_retry"` }
type Correlate ¶
type Correlate struct {
// contains filtered or unexported fields
}
func NewCorrelate ¶
func (*Correlate) CorrelateWorker ¶
func (c *Correlate) CorrelateWorker()
func (*Correlate) SendChannel ¶
Click to show internal directories.
Click to hide internal directories.