@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @import scalaz.{\/} @(cluster:String, errorOrTopics: kafka.manager.ApiError \/ kafka.manager.TopicListExtended )(implicit af: features.ApplicationFeatures, messages: play.api.i18n.Messages, menus: models.navigation.Menus, request:RequestHeader) @theMenu = { @views.html.navigation.clusterMenu(cluster,"Topic","List",menus.clusterMenus(cluster)( errorOrTopics.toOption.map(_.clusterContext.clusterFeatures).getOrElse(kafka.manager.features.ClusterFeatures.default))) } @topicScripts = { @if(errorOrTopics.fold(err=>false,tl=>tl.list.headOption.map(opt => opt._2.map(ti => ti.clusterContext.config.displaySizeEnabled).getOrElse(false)).getOrElse(false))){ } else { } } @main( "Topic List", menu = theMenu, breadcrumbs=views.html.navigation.breadCrumbs(models.navigation.BreadCrumbs.withViewAndCluster("Topics",cluster)), scripts=topicScripts) {
@features.app(features.KMTopicManagerFeature) {

Operations

@features.app(features.KMReassignPartitionsFeature) { }
Generate Partition Assignments Run Partition Assignments Add Partitions
}

Topics

@errorOrTopics.fold( views.html.errors.onApiError(_), tl => views.html.topic.topicListContent( cluster,tl.list.map(t => (t, tl.deleteSet(t._1))), tl.underReassignments, tl.list.headOption.map(opt => opt._2.map(ti => ti.clusterContext.config.pollConsumers).getOrElse(false)).getOrElse(false), tl.list.headOption.map(opt => opt._2.map(ti => ti.clusterContext.config.displaySizeEnabled).getOrElse(false)).getOrElse(false)))
}