@@ -215,7 +215,7 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
215215 }
216216
217217 case taskList .FullCommand ():
218- if res , err := nc .TaskList (* taskListPrefix , * taskListLimit , * taskListSkip ); err != nil {
218+ if res , err := nc .TaskList (* taskListPrefix , * taskListLimit , * taskListSkip , & nexus. ListOpts { LimitByDepth : true , Depth : * taskListDepth , Filter : * taskListFilter } ); err != nil {
219219 log .Println (err )
220220 return
221221 } else {
@@ -289,7 +289,7 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
289289 case userList .FullCommand ():
290290 log .Printf ("Listing users on \" %s\" " , * userListPrefix )
291291
292- if res , err := nc .UserList (* userListPrefix , * userListLimit , * userListSkip ); err != nil {
292+ if res , err := nc .UserList (* userListPrefix , * userListLimit , * userListSkip , & nexus. ListOpts { LimitByDepth : true , Depth : * userListDepth , Filter : * userListFilter } ); err != nil {
293293 log .Println (err )
294294 return
295295 } else {
@@ -399,7 +399,7 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
399399 }
400400
401401 case sessionsList .FullCommand ():
402- if res , err := nc .SessionList (* sessionsListPrefix , * sessionsListLimit , * sessionsListSkip ); err != nil {
402+ if res , err := nc .SessionList (* sessionsListPrefix , * sessionsListLimit , * sessionsListSkip , & nexus. ListOpts { LimitByDepth : true , Depth : * sessionsListDepth , Filter : * sessionsListFilter } ); err != nil {
403403 log .Println (err )
404404 return
405405 } else {
@@ -666,6 +666,24 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
666666 log .Println ("Result:" , res )
667667 }
668668
669+ case chanList .FullCommand ():
670+ if res , err := nc .TopicList (* chanListPrefix , * chanListLimit , * chanListSkip , & nexus.ListOpts {LimitByDepth : true , Depth : * chanListDepth , Filter : * chanListFilter }); err != nil {
671+ log .Println (err )
672+ return
673+ } else {
674+ table := tablewriter .NewWriter (os .Stdout )
675+ table .SetHeader ([]string {"Topic" , "Subscribers" })
676+ table .SetBorders (tablewriter.Border {Left : false , Top : false , Right : false , Bottom : false })
677+ for _ , topic := range res {
678+ table .Append ([]string {topic .Topic , fmt .Sprintf ("%d" , topic .Subscribers )})
679+
680+ }
681+
682+ table .Render () // Send output
683+ fmt .Println ()
684+
685+ }
686+
669687 case syncLock .FullCommand ():
670688 if res , err := nc .Lock (* syncLockName ); err != nil {
671689 log .Println (err )
@@ -682,6 +700,24 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
682700 log .Println ("Result:" , res )
683701 }
684702
703+ case syncList .FullCommand ():
704+ if res , err := nc .LockList (* syncListPrefix , * syncListLimit , * syncListSkip , & nexus.ListOpts {LimitByDepth : true , Depth : * syncListDepth , Filter : * syncListFilter }); err != nil {
705+ log .Println (err )
706+ return
707+ } else {
708+ table := tablewriter .NewWriter (os .Stdout )
709+ table .SetHeader ([]string {"ID" , "Owner" })
710+ table .SetBorders (tablewriter.Border {Left : false , Top : false , Right : false , Bottom : false })
711+ for _ , lock := range res {
712+ table .Append ([]string {lock .Id , lock .Owner })
713+
714+ }
715+
716+ table .Render () // Send output
717+ fmt .Println ()
718+
719+ }
720+
685721 case chanPubJ .FullCommand ():
686722 var msg map [string ]interface {}
687723 if json .Unmarshal ([]byte (* chanPubJMsg ), & msg ) != nil {
0 commit comments