eventbus

type Options struct {
	MaxRetries     int           `json:"maxRetries" mapstructure:"maxRetries"`
	SyncPeriod     time.Duration `json:"syncPeriod" mapstructure:"syncPeriod"`
	BatchSize      int           `json:"batchSize" mapstructure:"batchSize"`
	Workers        int           `json:"workers" mapstructure:"workers"`
	DequeueTimeout time.Duration `json:"dequeueTimeout" mapstructure:"dequeueTimeout"`
	RunningTimeout time.Duration `json:"runningTimeout" mapstructure:"runningTimeout"`
}