}
	for _, b := range h.kconfig.Brokers {
		if _, err := xnet.ParseHost(b.String()); err != nil {
			return err
		}
	}
	return nil
}

// Name returns the name of the target
func (h *Target) Name() string {
	return "minio-kafka-audit"
}

// Endpoint - return kafka target
func (h *Target) Endpoint() string {
	return "kafka"
}

// String - kafka string

 */
public class MsrpcShareGetInfo extends srvsvc.ShareGetInfo {

    /**
     * Creates a new request to get share information.
     *
     * @param server the server name
     * @param sharename the name of the share to query
     */
    public MsrpcShareGetInfo(final String server, final String sharename) {
        super(server, sharename, 502, new srvsvc.ShareInfo502());
        this.ptype = 0;

    MockServerClient(mockServer.host, mockServer.serverPort).use { mockServerClient ->
      mockServerClient
        .`when`(
          request()
            .withPath("/person")
            .withQueryStringParameter("name", "peter"),
        ).respond(response().withBody("Peter the person!"))

      val client =
        OkHttpClient
          .Builder()

<project>
  <modelVersion>4.0.0</modelVersion>

  <groupId>org.apache.maven.lifecycle.test</groupId>
  <artifactId>project-basic</artifactId>
  <version>1.0</version>
  <packaging>jar</packaging>

  <name>Test Project</name>
  <inceptionYear>2009</inceptionYear>

  <build>
    <pluginManagement>
      <plugins>
        <plugin>
          <groupId>org.apache.maven.plugins</groupId>

The specified file must be a Go assembly file.
The same assembler is used for all target operating systems and architectures.
The GOOS and GOARCH environment variables set the desired target.

Flags:

	-D name[=value]
		Predefine symbol name with an optional simple value.
		Can be repeated to define multiple symbols.
	-I dir1 -I dir2
		Search for #include files in dir1, dir2, etc,
		after consulting $GOROOT/pkg/$GOOS_$GOARCH.
	-S

    public String[] labelTypeIds;

    /** The CRUD operation mode for this form. */
    @ValidateTypeFailure
    public Integer crudMode;

    /** The name of the file configuration (required, maximum 200 characters). */
    @Required
    @Size(max = 200)
    public String name;

    /** The description of the file configuration (maximum 1000 characters). */
    @Size(max = 1000)
    public String description;

     *
     * @return maximum size in bytes that can be compressed
     */
    int getMaxCompressionSize();

    /**
     * Gets a human-readable name for the compression algorithm.
     *
     * @param algorithm the algorithm constant
     * @return the algorithm name
     */
    String getAlgorithmName(int algorithm);

        });

    }

    /**
     * Sets up the search conditions for group list queries based on pager criteria.
     * Configures the condition bean with ID filtering and ordering by name.
     *
     * @param cb the condition bean for building the query
     * @param groupPager the pager containing search and filter criteria
     */

                  exitLatch.countDown();
                }
              }
            },
            "Custom thread name");
    thread.start();
    enterLatch.await();
    assertFalse(task.isDone());
    String result = task.toString();
    assertThat(result).contains("Custom thread name");
    task.cancel(true);
    exitLatch.await();
  }

  @J2ktIncompatible

}

// Checks on DeleteObject arguments, bucket and object.
func checkDelObjArgs(ctx context.Context, bucket, object string) error {
	return checkBucketAndObjectNames(ctx, bucket, object)
}

// Checks bucket and object name validity, returns nil if both are valid.
func checkBucketAndObjectNames(ctx context.Context, bucket, object string) error {
	// Verify if bucket is valid.