@@ -4,9 +4,12 @@ import (
44 "context"
55 "fmt"
66 "os"
7+ "strings"
78
8- gatewayv1alpha2 "sigs.k8s.io/gateway-api/apis/v1alpha2"
9+ "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
10+ gatewayv1beta1 "sigs.k8s.io/gateway-api/apis/v1beta1"
911
12+ "github.com/gauravkghildiyal/gwctl/pkg/resources/backends"
1013 "github.com/gauravkghildiyal/gwctl/pkg/resources/gatewayclasses"
1114 "github.com/gauravkghildiyal/gwctl/pkg/resources/gateways"
1215 "github.com/gauravkghildiyal/gwctl/pkg/resources/httproutes"
@@ -20,15 +23,15 @@ type describeFlags struct {
2023 allNamespaces bool
2124}
2225
23- func NewDescribeCommand (clients * types.Clients ) * cobra.Command {
26+ func NewDescribeCommand (params * types.Params ) * cobra.Command {
2427 flags := & describeFlags {}
2528
2629 cmd := & cobra.Command {
2730 Use : "describe {policies|httproutes|gateways|gatewayclasses} RESOURCE_NAME" ,
2831 Short : "Show details of a specific resource or group of resources" ,
2932 Args : cobra .RangeArgs (1 , 2 ),
3033 Run : func (cmd * cobra.Command , args []string ) {
31- runDescribe (args , clients , flags )
34+ runDescribe (args , params , flags )
3235 },
3336 }
3437 cmd .Flags ().StringVarP (& flags .namespace , "namespace" , "n" , "default" , "" )
@@ -37,7 +40,7 @@ func NewDescribeCommand(clients *types.Clients) *cobra.Command {
3740 return cmd
3841}
3942
40- func runDescribe (args []string , clients * types.Clients , flags * describeFlags ) {
43+ func runDescribe (args []string , params * types.Params , flags * describeFlags ) {
4144 kind := args [0 ]
4245 ns := flags .namespace
4346 if flags .allNamespaces {
@@ -46,59 +49,83 @@ func runDescribe(args []string, clients *types.Clients, flags *describeFlags) {
4649
4750 switch kind {
4851 case "policy" , "policies" :
49- policyList , err := policies .List (context .TODO (), clients , ns )
50- if err != nil {
51- panic (err )
52- }
53- policies .PrintDescribeView (clients , policyList )
52+ policyList := params .PolicyManager .GetPolicies ()
53+ policies .PrintDescribeView (params , policyList )
5454 case "httproute" , "httproutes" :
55- var httpRoutes []gatewayv1alpha2 .HTTPRoute
55+ var httpRoutes []gatewayv1beta1 .HTTPRoute
5656 if len (args ) == 1 {
5757 var err error
58- httpRoutes , err = httproutes .List (context .TODO (), clients , ns )
58+ httpRoutes , err = httproutes .List (context .TODO (), params , ns )
5959 if err != nil {
6060 panic (err )
6161 }
6262 } else {
63- httpRoute , err := httproutes .Get (context .TODO (), clients , ns , args [1 ])
63+ httpRoute , err := httproutes .Get (context .TODO (), params , ns , args [1 ])
6464 if err != nil {
6565 panic (err )
6666 }
67- httpRoutes = []gatewayv1alpha2 .HTTPRoute {httpRoute }
67+ httpRoutes = []gatewayv1beta1 .HTTPRoute {httpRoute }
6868 }
69- httproutes .PrintDescribeView (context .TODO (), clients , httpRoutes )
69+ httproutes .PrintDescribeView (context .TODO (), params , httpRoutes )
7070 case "gateway" , "gateways" :
71- var gws []gatewayv1alpha2 .Gateway
71+ var gws []gatewayv1beta1 .Gateway
7272 if len (args ) == 1 {
7373 var err error
74- gws , err = gateways .List (context .TODO (), clients , ns )
74+ gws , err = gateways .List (context .TODO (), params , ns )
7575 if err != nil {
7676 panic (err )
7777 }
7878 } else {
79- gw , err := gateways .Get (context .TODO (), clients , ns , args [1 ])
79+ gw , err := gateways .Get (context .TODO (), params , ns , args [1 ])
8080 if err != nil {
8181 panic (err )
8282 }
83- gws = []gatewayv1alpha2 .Gateway {gw }
83+ gws = []gatewayv1beta1 .Gateway {gw }
8484 }
85- gateways .PrintDescribeView (context .TODO (), clients , gws )
85+ gateways .PrintDescribeView (context .TODO (), params , gws )
8686 case "gatewayclass" , "gatewayclasses" :
87- var gwClasses []gatewayv1alpha2 .GatewayClass
87+ var gwClasses []gatewayv1beta1 .GatewayClass
8888 if len (args ) == 1 {
8989 var err error
90- gwClasses , err = gatewayclasses .List (context .TODO (), clients )
90+ gwClasses , err = gatewayclasses .List (context .TODO (), params )
91+ if err != nil {
92+ panic (err )
93+ }
94+ } else {
95+ gwc , err := gatewayclasses .Get (context .TODO (), params , args [1 ])
96+ if err != nil {
97+ panic (err )
98+ }
99+ gwClasses = []gatewayv1beta1.GatewayClass {gwc }
100+ }
101+ gatewayclasses .PrintDescribeView (context .TODO (), params , gwClasses )
102+ case "backend" , "backends" :
103+ var backendsList []unstructured.Unstructured
104+
105+ resourceType := "service"
106+ var resourceName string
107+ if len (args ) > 1 {
108+ resourceName = args [1 ]
109+ a , b , ok := strings .Cut (args [1 ], "/" )
110+ if ok {
111+ resourceType , resourceName = a , b
112+ }
113+ }
114+
115+ if resourceName == "" {
116+ var err error
117+ backendsList , err = backends .List (context .TODO (), params , resourceType , ns )
91118 if err != nil {
92119 panic (err )
93120 }
94121 } else {
95- gwc , err := gatewayclasses .Get (context .TODO (), clients , args [ 1 ] )
122+ backend , err := backends .Get (context .TODO (), params , resourceType , ns , resourceName )
96123 if err != nil {
97124 panic (err )
98125 }
99- gwClasses = []gatewayv1alpha2. GatewayClass { gwc }
126+ backendsList = []unstructured. Unstructured { backend }
100127 }
101- gatewayclasses .PrintDescribeView (context .TODO (), clients , gwClasses )
128+ backends .PrintDescribeView (context .TODO (), params , backendsList )
102129 default :
103130 fmt .Fprintf (os .Stderr , "Unrecognized RESOURCE_TYPE\n " )
104131 }
0 commit comments