form

Type Members

1. case class AddMultipleTopicsPartitions(topics: Seq[TopicSelect], brokers: Seq[BrokerSelect], partitions: Int, readVersions: Seq[ReadVersion]) extends TopicOperation with Product with Serializable

   

2. case class AddTopicPartitions(topic: String, brokers: Seq[BrokerSelect], partitions: Int, readVersion: Int) extends TopicOperation with Product with Serializable

   

3. case class BrokerSelect(id: Int, host: String, selected: Boolean) extends Product with Serializable

   

4. case class ClusterOperation extends Product with Serializable

   

5. case class CreateLogkafka(logkafka_id: String, log_path: String, configs: List[LKConfig]) extends LogkafkaOperation with Product with Serializable

   

6. case class CreateTopic(topic: String, partitions: Int, replication: Int, configs: List[TConfig]) extends TopicOperation with Product with Serializable

   

7. case class DeleteLogkafka(logkafka_id: String, log_path: String) extends LogkafkaOperation with Product with Serializable

   

8. case class DeleteTopic(topic: String) extends TopicOperation with Product with Serializable

   

9. case class GenerateAssignment(brokers: Seq[BrokerSelect]) extends Product with Serializable

   

10. case class GenerateMultipleAssignments(topics: Seq[TopicSelect], brokers: Seq[BrokerSelect]) extends Product with Serializable

    

11. case class LKConfig(name: String, value: Option[String]) extends Product with Serializable

    

12. sealed trait LogkafkaOperation extends AnyRef

    

13. sealed trait Operation extends AnyRef

    

14. sealed trait PreferredReplicaElectionOperation extends AnyRef

    

15. case class ReadVersion(topic: String, version: Int) extends Product with Serializable

    

16. sealed abstract class ReassignPartitionOperation extends EnumEntry with Snakecase with Uppercase

    

17. case class RunMultipleAssignments(topics: Seq[TopicSelect]) extends Product with Serializable

    

18. case class TConfig(name: String, value: Option[String]) extends Product with Serializable

    

19. sealed trait TopicOperation extends AnyRef

    

20. case class TopicSelect(name: String, selected: Boolean) extends Product with Serializable

    

21. case class Unknown(operation: String) extends Operation with Product with Serializable

    

22. case class UnknownLKO(op: String) extends LogkafkaOperation with Product with Serializable

    

23. case class UnknownPREO(op: String) extends PreferredReplicaElectionOperation with Product with Serializable

    

24. case class UnknownTO(op: String) extends TopicOperation with Product with Serializable

    

25. case class UpdateLogkafkaConfig(logkafka_id: String, log_path: String, configs: List[LKConfig]) extends LogkafkaOperation with Product with Serializable

    

26. case class UpdateTopicConfig(topic: String, configs: List[TConfig], readVersion: Int) extends TopicOperation with Product with Serializable