Subscription management

You can simply create subscription:

import com.github.fsanaulla.core.utils.constants.Destinations._

influx.createSubscription("subsName", "dbName", "rpName", Destinations.ALL, Seq("host1", "host2"))
res0: Future[Result]

To drop subscription:

influx.dropSubscription("subsName", "dbName", "rpName")
res0: Future[Result]

Show subscriptions:

influx.showSubscriptionsInfo()
res0: Future[QueryResult[SubscriptionInfo]]

To show database related subscriptions:

influx.showSubscriptions("dbName")
res0: Future[QueryResult[Subscription]]

There is no update method in subs api, so it’s just simulation using drop and create:

import com.github.fsanaulla.core.utils.constants.Destinations._

influx.updateSubscription("subsName", "dbName", "rpName", Destinations.ALL, Seq("host1", "host2"))
res0: Future[Result]