Package dev.restate.admin.model

Class CreateSubscriptionRequest

java.lang.Object
dev.restate.admin.model.CreateSubscriptionRequest
public class CreateSubscriptionRequest extends Object
CreateSubscriptionRequest

  • Field Details

  • Constructor Details

    • CreateSubscriptionRequest

      public CreateSubscriptionRequest()

  • Method Details

    • source

      public CreateSubscriptionRequest source(String source)

    • getSource

      @Nonnull public String getSource()
      Source uri. Accepted forms: * `kafka://<cluster_name>/<topic_name>`, e.g. `kafka://my-cluster/my-topic`
      Returns:
      source

    • setSource

      public void setSource(String source)

    • sink

      public CreateSubscriptionRequest sink(String sink)

    • getSink

      @Nonnull public String getSink()
      Sink uri. Accepted forms: * `service://<service_name>/<service_name>`, e.g. `service://Counter/count`
      Returns:
      sink

    • setSink

      public void setSink(String sink)

    • options

      public CreateSubscriptionRequest options(Map<String,String> options)

    • putOptionsItem

      public CreateSubscriptionRequest putOptionsItem(String key, String optionsItem)

    • getOptions

      @Nullable public Map<String,String> getOptions()
      Additional options to apply to the subscription.
      Returns:
      options

    • setOptions

      public void setOptions(Map<String,String> options)

    • equals

      public boolean equals(Object o)
      Return true if this CreateSubscriptionRequest object is equal to o.
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • toUrlQueryString

      public String toUrlQueryString()
      Convert the instance into URL query string.
      Returns:
      URL query string

    • toUrlQueryString

      public String toUrlQueryString(String prefix)
      Convert the instance into URL query string.
      Parameters:
      prefix - prefix of the query string
      Returns:
      URL query string