this.kinds = kinds;
    }

    public void setEmptySource(final Map<String, Object> emptySource) {
        this.emptySource = emptySource;
    }

    public void setId(final String id) {
        this.id = id;
    }

    public Map<String, Object> toEmptyMap() {
        return emptySource;
    }

    protected Map<String, Object> createEmptyMap() {

            @Override
            public OptionalEntity<WebConfig> getWebConfig(final String id) {
                final WebConfig webConfig = new WebConfig();
                webConfig.setId(id);
                return OptionalEntity.of(webConfig);
            }
        }, WebConfigService.class.getCanonicalName());
    }

    public void test_sendDocuments() {
        documentSizeByQuery = 0L;

	return conn.stream.Context().Done()
}

func (conn *Connection) ID() string {
	return conn.conID
}

func (conn *Connection) Peer() string {
	return conn.peerAddr
}

func (conn *Connection) SetID(id string) {
	conn.conID = id
}

func (conn *Connection) ConnectedAt() time.Time {
	return conn.connectedAt
}

func (conn *Connection) Stop() {
	close(conn.stop)
}

		{name: "SETORD", argLength: 1, reg: flagsgp, asm: "SETPC"},                       // extract "ordered" (No Nan present) condition from arg0
		{name: "SETNAN", argLength: 1, reg: flagsgp, asm: "SETPS"},                       // extract "unordered" (Nan present) condition from arg0

	SYS_SHM_OPEN                 = 482 // { int shm_open(const char *path, int flags, \
	SYS_SHM_UNLINK               = 483 // { int shm_unlink(const char *path); }
	SYS_CPUSET                   = 484 // { int cpuset(cpusetid_t *setid); }
	SYS_CPUSET_SETID             = 485 // { int cpuset_setid(cpuwhich_t which, id_t id, \
	SYS_CPUSET_GETID             = 486 // { int cpuset_getid(cpulevel_t level, \

	SYS_SHM_OPEN                 = 482 // { int shm_open(const char *path, int flags, \
	SYS_SHM_UNLINK               = 483 // { int shm_unlink(const char *path); }
	SYS_CPUSET                   = 484 // { int cpuset(cpusetid_t *setid); }
	SYS_CPUSET_SETID             = 485 // { int cpuset_setid(cpuwhich_t which, id_t id, \
	SYS_CPUSET_GETID             = 486 // { int cpuset_getid(cpulevel_t level, \

	SYS_SHM_OPEN                 = 482 // { int shm_open(const char *path, int flags, \
	SYS_SHM_UNLINK               = 483 // { int shm_unlink(const char *path); }
	SYS_CPUSET                   = 484 // { int cpuset(cpusetid_t *setid); }
	SYS_CPUSET_SETID             = 485 // { int cpuset_setid(cpuwhich_t which, id_t id, \
	SYS_CPUSET_GETID             = 486 // { int cpuset_getid(cpulevel_t level, \

st); public java.util.List getDependencies(); public void addDependency(ComponentDependency); public void setDependencies(java.util.List); public void setIsolatedRealm(boolean); public boolean isIsolatedRealm(); public String getId(); public void setId(String); public String toString(); } org/codehaus/plexus/component/repository/exception/ComponentConfigurati.class package org.codehaus.plexus.component.repository.exception; public synchronized class ComponentConfigurati extends Exception { private...

	for _, p := range paths {
		namespace, _, pod, container, err := cluster2.ParsePath(p)
		if err != nil {
			log.Error(err.Error())
			continue
		}

		cp := params.SetNamespace(namespace).SetPod(pod).SetContainer(container)
		proxyDir := archive.ProxyOutputPath(tempDir, namespace, pod)
		switch {
		case common.IsProxyContainer(params.ClusterVersion, container):
			if !ambient.IsZtunnelPod(client, pod, namespace) {

st); public java.util.List getDependencies(); public void addDependency(ComponentDependency); public void setDependencies(java.util.List); public void setIsolatedRealm(boolean); public boolean isIsolatedRealm(); public String getId(); public void setId(String); public String toString(); } org/codehaus/plexus/component/repository/exception/ComponentConfigurati.class package org.codehaus.plexus.component.repository.exception; public synchronized class ComponentConfigurati extends Exception { private...