global:
  serverConnectors:
    - id: polaris
      protocol: grpc
      addresses:
        # The IP address needs to be replaced with the client access IP address of the North Star engine you created.
        - 127.0.0.1:8091
  # Description: Configuration related to monitoring and log data reporting
  statReporter:
    # Description: Whether to Enable Reporting
    enable: true
    plugin:
      prometheus:
        type: push
        # Description: Configure the pushgateway IP address, effective only when type == push
        # The IP address needs to be replaced with the client access IP address of the North Star engine you created.
        address: 127.0.0.1:9091
        # Description: Set the execution interval for pushing metric data to pushgateway
        # Range: [1s:...], Default value: 10s
        pushInterval: 10s

import com.tencent.polaris.factory.api.DiscoveryAPIFactory;

public static void main(String[] args) throws Exception {    
    ProviderAPI providerAPI = DiscoveryAPIFactory.createProviderAPI();
}

public class InstanceRegisterRequest extends CommonProviderBaseEntity {
    // ...
}

InstanceRegisterResponse registerResp = providerAPI.registerInstance(registerRequest)

import com.tencent.polaris.factory.api.DiscoveryAPIFactory;


public static void main(String[] args) throws Exception {
    ConsumerAPI consumerAPI = DiscoveryAPIFactory.createConsumerAPI();
}

GetAllInstancesRequest request = new GetAllInstancesRequest();
// Set the service namespace
request.setNamespace(String namespace);
// Set the service name
request.setService(String service);
// Set the timeout period
request.setTimeoutMs(long timeoutMs);

// Call ConsumerAPI to execute the request
consumerAPI.getAllInstance(request);

GetInstancesRequest request = new GetInstancesRequest();
// Set the service namespace
request.setNamespace(String namespace);
// Set the service name
request.setService(String service);

// Optional, set caller service information, only for routing rule matching
SourceService serviceInfo = new SourceService();
// Set the caller service namespace
serviceInfo.setNamespace(String namespace);
// Set the caller service name
serviceInfo.setService(String service);
// Set the request Tag information for the caller
serviceInfo.setArguments(Set<RouteArgument> arguments);
request.setServiceInfo(serviceInfo);

// Set the timeout period
request.setTimeoutMs(long timeoutMs);

// Call ConsumerAPI to execute the request
consumerAPI.getInstances(request);

public class Criteria {
    /**
     * Specify the CLB policy
     */
    private String lbPolicy;
    /**
     * key for consistent hashing
     */
    private String hashKey;
}

GetOneInstanceRequest request = new GetOneInstanceRequest();
// Set the service namespace
request.setNamespace(String namespace);
// Set the service name
request.setService(String service);
// Optional. The metadata, only used for filtering by the dstMetadata routing plugin.
request.setMetadata(Map<String, String> metadata);
// Optional. Set the fallback mechanism for metadata routing.
// The currently supported fallback mechanisms for metadata routing are as follows:
// - Default: no failover: METADATAFAILOVERNONE("metadataFailoverNone")
// - Failover to return all nodes: METADATAFAILOVERALL("metadataFailoverAll")
// - Returning nodes without the metadata routing key: METADATAFAILOVERNOTKEY("metadataFailoverNoKey")
request.setMetadataFailoverType();
// Optional. Corresponds to the Method in the request Tag of custom routing rules
request.setMethod(String method);

// If you need to use Hash load balancing, it needs to be set
Criteria criteria = new Criteria();
request.setCriteria(criteria);

// Optional, set caller service information, only for routing rule matching
SourceService serviceInfo = new SourceService();
// Set the caller service namespace
serviceInfo.setNamespace(String namespace);
// Set the caller service name
serviceInfo.setService(String service);
// Set the request Tag information for the caller
serviceInfo.setArguments(Set<RouteArgument> arguments);
request.setServiceInfo(serviceInfo);

// Set the timeout period
request.setTimeoutMs(long timeoutMs);

// Call ConsumerAPI to execute the request
consumerAPI.getOneInstance(request);