ps := strings.Split(arnStr, ":")
	if len(ps) != 6 || ps[0] != string(arnPrefixArn) {
		err = errors.New("invalid ARN string format")
		return arn, err
	}

	if ps[1] != string(arnPartitionMinio) {
		err = errors.New("invalid ARN - bad partition field")
		return arn, err
	}

	if ps[2] != string(arnServiceIAM) {
		err = errors.New("invalid ARN - bad service field")
		return arn, err
	}

        }

        // Test GET with non-existent ID
        response = checkMethodBase(new HashMap<>()).get("/api/admin/crawlinginfo/log/nonexistent_id").asString();
        assertEquals(1, JsonPath.from(response).getInt("response.status"));

        // Test PUT /api/admin/crawlinginfo/logs
        final Map<String, Object> putBody = new HashMap<>();
        putBody.put("size", 10);

        if (pluginFile == null) {
            throw new IllegalStateException("plugin main artifact has not been resolved for " + getId());
        }

        if (pluginFile.isFile()) {
            try {
                return new URL("jar:" + pluginFile.toURI() + "!/" + descriptor).openStream();
            } catch (MalformedURLException e) {
                throw new IllegalStateException(e);
            }
        } else {

        this.lastActivityTime = establishedTime;

        this.bytesSent = new AtomicLong();
        this.bytesReceived = new AtomicLong();
        this.requestsSent = new AtomicLong();
        this.requestsReceived = new AtomicLong();
        this.errors = new AtomicLong();

        this.isPrimary = false;
        this.pendingOperations = new CopyOnWriteArrayList<>();
    }

    /**
     * Get channel ID
     *

  }

  private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN =
      new DiscreteDomain<Integer>() {
        @Override
        public Integer next(Integer value) {
          throw new AssertionError();
        }

        @Override
        public Integer previous(Integer value) {
          throw new AssertionError();
        }

        @Override

    @Override
    public void visit(TokenVisitor visitor) {
        lexer.visit(new VisitorImpl(visitor));
    }

    private class VisitorImpl extends TokenVisitor {
        private final TokenVisitor visitor;
        private final LinkedList<String> elementStack = new LinkedList<String>();
        private final Map<String, String> attributes = new HashMap<String, String>();

        public VisitorImpl(TokenVisitor visitor) {

    ImmutableList.Builder<List<E>> axesBuilder = new ImmutableList.Builder<>(lists.size());
    for (List<? extends E> list : lists) {
      List<E> copy = ImmutableList.copyOf(list);
      if (copy.isEmpty()) {
        return ImmutableList.of();
      }
      axesBuilder.add(copy);
    }
    return new CartesianList<>(axesBuilder.build());
  }

  CartesianList(ImmutableList<List<E>> axes) {

    List<K> keys = new ArrayList<>(multimap().keySet());
    for (K key : keys) {
      resetCollection();
      assertTrue(multimap().asMap().remove(key) instanceof Set);
    }
  }

  @CollectionSize.Require(SEVERAL)
  public void testEquals() {
    resetContainer(mapEntry(k0(), v0()), mapEntry(k1(), v0()), mapEntry(k0(), v3()));
    Map<K, Collection<V>> expected = new HashMap<>();

    TestQueue<String> inner = new TestQueue<>();
    Queue<String> outer = Synchronized.queue(inner, inner.mutex);
    outer.add("foo"); // necessary because we try to remove elements later on
    return outer;
  }

  private static final class TestQueue<E> implements Queue<E> {
    private final Queue<E> delegate = new LinkedList<>();
    private final Object mutex = new Object[0]; // something Serializable

    @Override

        List<Integer> pageNumberList = new ArrayList<Integer>(1);
        relatedQueryPager.setPageNumberList(pageNumberList);
        assertEquals(pageNumberList, relatedQueryPager.getPageNumberList());

    }

    public void test_clear() {
        RelatedQueryPager relatedQueryPager = new RelatedQueryPager();
        relatedQueryPager.id = "testId";