/**
     * Gets the witness protocol version.
     *
     * @return the protocol version
     */
    public int getVersion() {
        return version;
    }

    /**
     * Sets the witness protocol version.
     *
     * @param version the protocol version
     */
    public void setVersion(int version) {
        this.version = version;
    }

    /**
     * Gets the share name to monitor.
     *

            // Convert int version to WitnessVersion enum
            WitnessVersion witnessVersion = (request.getVersion() >= 0x00020000) ? WitnessVersion.VERSION_2 : WitnessVersion.VERSION_1;
            message.setVersion(witnessVersion);
            message.setNetName(serverAddress.getHostName());
            message.setShareName(request.getShareName());

                // Perform RPC registration
                WitnessRegisterRequest request = new WitnessRegisterRequest();
                request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());

     *
     * @param version the witness protocol version
     */
    public void setVersion(WitnessVersion version) {
        this.version = version;
    }

    /**
     * Gets the witness protocol version.
     *
     * @return the witness protocol version
     */
    public WitnessVersion getVersion() {
        return version;
    }

    /**
     * Sets the network name (server name).
     *

                
                // Perform RPC registration
                WitnessRegisterRequest request = new WitnessRegisterRequest();
                request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());

            final EntityCreator<T, SearchResponse, SearchHit> creator) {
        return search(index, searchRequestBuilder -> {
            searchRequestBuilder.setVersion(true);
            return condition.build(searchRequestBuilder);
        }, (queryBuilder, execTime, searchResponse) -> searchResponse.map(response -> {
            final SearchHit[] hits = response.getHits().getHits();

            assertNotNull(buffer.getReferrals());
            assertEquals(2, buffer.getReferrals().length);
            assertEquals(1, buffer.getReferrals()[0].getVersion());
            assertEquals(1, buffer.getReferrals()[1].getVersion());
        }

        @ParameterizedTest
        @DisplayName("Should handle various pathConsumed values")

        final Map<String, String> item = new HashMap<>();
        item.put("type", artifact.getType().getId());
        item.put("id", artifact.getName() + ":" + artifact.getVersion());
        item.put("name", artifact.getName());
        item.put("version", artifact.getVersion());
        item.put("url", artifact.getUrl());
        return item;
    }

    private Artifact getArtifactFromInstallForm(final InstallForm form) {

        // Decode
        int decodedSize = referral.decode(testBuffer, 0, testBuffer.length);

        // Verify
        assertEquals(100, decodedSize);
        assertEquals(3, referral.getVersion());
        assertEquals(100, referral.getSize());
        assertEquals(1, referral.getServerType());
        assertEquals(0, referral.getRFlags());
        assertEquals(5, referral.getProximity());

            final RESULT entity = createEntity(source, entityType);
            final DocMeta docMeta = ((EsAbstractEntity) entity).asDocMeta();
            docMeta.id(hit.getId());
            docMeta.version(hit.getVersion());
            docMeta.seqNo(hit.getSeqNo());
            docMeta.primaryTerm(hit.getPrimaryTerm());
            list.add(entity);
        });

        list.setPageSize(size);