this.event = checkNotNull(event);
  }

  /**
   * Returns the object that originated this event (not the object that originated the
   * wrapped event). This is generally an {@link EventBus}.
   *
   * @return the source of this event.
   */
  public Object getSource() {
    return source;
  }

  /**
   * Returns the wrapped, 'dead' event, which the system was unable to deliver to any registered

        return ((Map<?, ?>) value).isEmpty();
      } else if (value instanceof Optional) {
        return !((Optional) value).isPresent();
      } else if (value.getClass().isArray()) {
        return Array.getLength(value) == 0;
      }
      return false;
    }

    /**
     * Returns a string in the format specified by {@link MoreObjects#toStringHelper(Object)}.
     *

    @Override
    public String asTableDbName() {
        return asEsIndexType();
    }

    @Override
    protected String asEsIndex() {
        return "fess_log.search_log";
    }

    @Override
    public String asEsIndexType() {
        return "search_log";
    }

    @Override
    public String asEsSearchType() {
        return "search_log";
    }

    @Override

    @Override
    public String asTableDbName() {
        return asEsIndexType();
    }

    @Override
    protected String asEsIndex() {
        return "fess_config.file_config";
    }

    @Override
    public String asEsIndexType() {
        return "file_config";
    }

    @Override
    public String asEsSearchType() {
        return "file_config";
    }

    @Override

    /**
     * Gets the status code for this message.
     *
     * @return the status
     */
    public final int getStatus() {
        return this.status;
    }

    /**
     * Gets the session identifier for this message.
     *
     * @return the sessionId
     */
    public long getSessionId() {
        return this.sessionId;
    }

    /**
     * @param sessionId

    /**
     * Get RDMA channel information
     *
     * @return RDMA channel info, or null if not using RDMA
     */
    public RdmaChannelInfo getRdmaChannelInfo() {
        return rdmaChannelInfo;
    }

    /**
     * Get write data
     *
     * @return data to write
     */
    public byte[] getData() {
        return data;
    }

    /**
     * {@inheritDoc}
     *

        return queryBuilder.queryName(queryName);
    }

    /**
     * Returns the query name.
     *
     * @return the query name
     */
    @Override
    public String queryName() {
        return queryBuilder.queryName();
    }

    /**
     * Returns the boost value.
     *
     * @return the boost value
     */
    @Override
    public float boost() {

		return err
	}

	if !r.Source.Creds.Empty() {
		if err := r.Source.Creds.Validate(); err != nil {
			return err
		}
	}
	if r.Target.Endpoint == "" && !r.Target.Creds.Empty() {
		return errInvalidArgument
	}

	if r.Source.Endpoint == "" && !r.Source.Creds.Empty() {
		return errInvalidArgument
	}

	if r.Source.Endpoint != "" && !r.Source.Type.isMinio() && !r.Source.ValidPath() {

 */
@Experimental
public interface Event {

    /**
     * Gets the type of the event.
     *
     * @return the type of the event, never {@code null}
     */
    @Nonnull
    EventType getType();

    /**
     * Gets the session from which this event originates.
     *
     * @return the current session, never {@code null}
     */
    @Nonnull
    Session getSession();

    /**

    /**
     * Gets the original stopword.
     *
     * @return The original stopword.
     */
    public String getInput() {
        return input;
    }

    /**
     * Gets the value of the stopword.
     *
     * @return The stopword value, or an empty string if null.
     */
    public String getInputValue() {
        if (input == null) {
            return StringUtil.EMPTY;
        }
        return input;
    }