Class Link

java.lang.Object
io.confluent.kafkarest.entities.Link
public abstract class Link extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    Link.Builder
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static Link.Builder
    builder()
     
    static Link
    create(String linkName, String remoteClusterId, org.apache.kafka.common.Uuid clusterLinkId, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode linkMode, com.google.common.collect.ImmutableList<String> topics, org.apache.kafka.common.ClusterLinkError linkError, String linkErrorMessage, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState linkState, com.google.common.collect.ImmutableList<org.apache.kafka.clients.admin.ClusterLinkTaskDescription> tasks, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState remoteLinkState)
     
    static Link
    fromClusterLinkDescription(org.apache.kafka.clients.admin.ClusterLinkDescription description)
     
    abstract Map<org.apache.kafka.common.replica.ReplicaStatus.MirrorInfo.StateCategory, Integer>
    getCategoryCounts()
     
    abstract org.apache.kafka.common.Uuid
    getClusterLinkId()
     
    abstract org.apache.kafka.common.ClusterLinkError
    getLinkError()
     
    abstract String
    getLinkErrorMessage()
     
    abstract UUID
    getLinkId()
     
    abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode
    getLinkMode()
     
    abstract String
    getLinkName()
     
    abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState
    getLinkState()
     
    abstract String
    getRemoteClusterId()
     
    abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState
    getRemoteLinkState()
     
    abstract com.google.common.collect.ImmutableList<org.apache.kafka.clients.admin.ClusterLinkTaskDescription>
    getTasks()
     
    abstract com.google.common.collect.ImmutableList<String>
    getTopics()
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • getRemoteClusterId

      public abstract String getRemoteClusterId()

    • getLinkName

      public abstract String getLinkName()

    • getLinkId

      public abstract UUID getLinkId()

    • getClusterLinkId

      public abstract org.apache.kafka.common.Uuid getClusterLinkId()

    • getLinkMode

      public abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode getLinkMode()

    • getTopics

      public abstract com.google.common.collect.ImmutableList<String> getTopics()

    • getLinkError

      public abstract org.apache.kafka.common.ClusterLinkError getLinkError()

    • getLinkErrorMessage

      public abstract String getLinkErrorMessage()

    • getLinkState

      public abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState getLinkState()

    • getTasks

      public abstract com.google.common.collect.ImmutableList<org.apache.kafka.clients.admin.ClusterLinkTaskDescription> getTasks()

    • getRemoteLinkState

      public abstract org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState getRemoteLinkState()

    • getCategoryCounts

      @Nullable public abstract Map<org.apache.kafka.common.replica.ReplicaStatus.MirrorInfo.StateCategory, Integer> getCategoryCounts()

    • create

      public static Link create(String linkName, String remoteClusterId, org.apache.kafka.common.Uuid clusterLinkId, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode linkMode, com.google.common.collect.ImmutableList<String> topics, org.apache.kafka.common.ClusterLinkError linkError, String linkErrorMessage, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState linkState, com.google.common.collect.ImmutableList<org.apache.kafka.clients.admin.ClusterLinkTaskDescription> tasks, org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState remoteLinkState)

    • fromClusterLinkDescription

      public static Link fromClusterLinkDescription(org.apache.kafka.clients.admin.ClusterLinkDescription description)

    • builder

      public static Link.Builder builder()