ModTime time.Time `json:"modTime"` // ModTime of the object `xl.meta`.
	Name    string    `json:"name"`
	Dir     bool      `json:"dir"`
	Mode    uint32    `json:"mode"`
}

// ErasureInfo holds erasure coding and bitrot related information.
type ErasureInfo struct {
	// Algorithm is the string representation of erasure-coding-algorithm
	Algorithm string `json:"algorithm"`
	// DataBlocks is the number of data blocks for erasure-coding

                return enc;
            }
        }
        return null;
    }

    /**
     * Processes field configurations to handle field overwriting rules.
     * Creates a new data map with fields processed according to their configuration.
     *
     * @param dataMap the original data map to process
     * @param fieldConfigs the field configurations to apply

	target.producer = producer

	yes, err := target.isActive()
	if err != nil {
		return err
	}
	if !yes {
		return store.ErrNotConnected
	}

	return nil
}

// NewKafkaTarget - creates new Kafka target with auth credentials.
func NewKafkaTarget(id string, args KafkaArgs, loggerOnce logger.LogOnce) (*KafkaTarget, error) {
	var queueStore store.Store[event.Event]
	if args.QueueDir != "" {

            IllegalArgumentException.class,
            () -> InetAddresses.fromIPv4BigInteger(BigInteger.valueOf(-1L)));
    assertThat(expected)
        .hasMessageThat()
        .isEqualTo("BigInteger must be greater than or equal to 0");
  }

  public void testFromIpv6BigIntegerThrowsLessThanZero() {
    IllegalArgumentException expected =
        assertThrows(
            IllegalArgumentException.class,

                try {
                    list.add(new LabelTypePattern(labelType.getValue(), includedPaths, excludedPaths));
                } catch (final Exception e) {
                    logger.warn("Failed to create label pattern: label={}, includedPaths={}, excludedPaths={}", labelType.getValue(),
                            includedPaths, excludedPaths, e);
                }
            }
        }

        return getSessionManager().getAttribute(Constants.SEARCH_ENGINE_API_ACCESS_TOKEN, String.class)
                .map(token -> ADMIN_SERVER + token)
                .orElseThrow(() -> new FessSystemException("Cannot create an access token."));
    }

    /**
     * Generates and saves a new access token for the current session.
     * The token is used to authenticate API requests.
     */
    public void saveToken() {

        assertEquals(message, exception.getMessage());
        assertEquals(complexMessageCode, exception.getMessageCode());
    }

    @Test
    public void test_causeChainPropagation() {
        // Setup - create a chain of exceptions
        final IllegalArgumentException rootCause = new IllegalArgumentException("Invalid character in query");

        for (int i = 1; i < chains.size(); i++) {
            assertEquals("user" + i, chains.get(i).lastLoadedUser.getName());
        }
    }

    // Helper method to create test user
    private User createTestUser(String username) {
        User user = new User();
        user.setName(username);
        return user;
    }

    // Test implementation of AuthenticationChain

    protected void setUpChild() throws Exception {
        queryCommand = new TermQueryCommand();
        queryCommand.register();
    }

    private void setQueryType(final String queryType) {
        // Re-create the base FessConfig with the new query type
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

        // Test getMailReturnPath
        assertEquals("root@localhost", fessEnv.getMailReturnPath());
    }

    // Test custom properties
    public void xtest_customProperties() {
        // Create custom FessEnv with custom properties
        FessEnv.SimpleImpl customEnv = new FessEnv.SimpleImpl() {
            protected Properties prepareProperties() {
                Properties props = new Properties();