// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.6.1 // - protoc v5.29.5 // source: proto/mc_proxy/v1/admin.proto package mcproxyv1 import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.64.0 or later. const _ = grpc.SupportPackageIsVersion9 const ( ProxyAdminService_ListRoutes_FullMethodName = "/mc_proxy.v1.ProxyAdminService/ListRoutes" ProxyAdminService_AddRoute_FullMethodName = "/mc_proxy.v1.ProxyAdminService/AddRoute" ProxyAdminService_RemoveRoute_FullMethodName = "/mc_proxy.v1.ProxyAdminService/RemoveRoute" ProxyAdminService_GetFirewallRules_FullMethodName = "/mc_proxy.v1.ProxyAdminService/GetFirewallRules" ProxyAdminService_AddFirewallRule_FullMethodName = "/mc_proxy.v1.ProxyAdminService/AddFirewallRule" ProxyAdminService_RemoveFirewallRule_FullMethodName = "/mc_proxy.v1.ProxyAdminService/RemoveFirewallRule" ProxyAdminService_SetListenerMaxConnections_FullMethodName = "/mc_proxy.v1.ProxyAdminService/SetListenerMaxConnections" ProxyAdminService_ListL7Policies_FullMethodName = "/mc_proxy.v1.ProxyAdminService/ListL7Policies" ProxyAdminService_AddL7Policy_FullMethodName = "/mc_proxy.v1.ProxyAdminService/AddL7Policy" ProxyAdminService_RemoveL7Policy_FullMethodName = "/mc_proxy.v1.ProxyAdminService/RemoveL7Policy" ProxyAdminService_GetStatus_FullMethodName = "/mc_proxy.v1.ProxyAdminService/GetStatus" ) // ProxyAdminServiceClient is the client API for ProxyAdminService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type ProxyAdminServiceClient interface { // Routes ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error) AddRoute(ctx context.Context, in *AddRouteRequest, opts ...grpc.CallOption) (*AddRouteResponse, error) RemoveRoute(ctx context.Context, in *RemoveRouteRequest, opts ...grpc.CallOption) (*RemoveRouteResponse, error) // Firewall GetFirewallRules(ctx context.Context, in *GetFirewallRulesRequest, opts ...grpc.CallOption) (*GetFirewallRulesResponse, error) AddFirewallRule(ctx context.Context, in *AddFirewallRuleRequest, opts ...grpc.CallOption) (*AddFirewallRuleResponse, error) RemoveFirewallRule(ctx context.Context, in *RemoveFirewallRuleRequest, opts ...grpc.CallOption) (*RemoveFirewallRuleResponse, error) // Connection limits SetListenerMaxConnections(ctx context.Context, in *SetListenerMaxConnectionsRequest, opts ...grpc.CallOption) (*SetListenerMaxConnectionsResponse, error) // L7 policies ListL7Policies(ctx context.Context, in *ListL7PoliciesRequest, opts ...grpc.CallOption) (*ListL7PoliciesResponse, error) AddL7Policy(ctx context.Context, in *AddL7PolicyRequest, opts ...grpc.CallOption) (*AddL7PolicyResponse, error) RemoveL7Policy(ctx context.Context, in *RemoveL7PolicyRequest, opts ...grpc.CallOption) (*RemoveL7PolicyResponse, error) // Status GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error) } type proxyAdminServiceClient struct { cc grpc.ClientConnInterface } func NewProxyAdminServiceClient(cc grpc.ClientConnInterface) ProxyAdminServiceClient { return &proxyAdminServiceClient{cc} } func (c *proxyAdminServiceClient) ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ListRoutesResponse) err := c.cc.Invoke(ctx, ProxyAdminService_ListRoutes_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) AddRoute(ctx context.Context, in *AddRouteRequest, opts ...grpc.CallOption) (*AddRouteResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(AddRouteResponse) err := c.cc.Invoke(ctx, ProxyAdminService_AddRoute_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) RemoveRoute(ctx context.Context, in *RemoveRouteRequest, opts ...grpc.CallOption) (*RemoveRouteResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(RemoveRouteResponse) err := c.cc.Invoke(ctx, ProxyAdminService_RemoveRoute_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) GetFirewallRules(ctx context.Context, in *GetFirewallRulesRequest, opts ...grpc.CallOption) (*GetFirewallRulesResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(GetFirewallRulesResponse) err := c.cc.Invoke(ctx, ProxyAdminService_GetFirewallRules_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) AddFirewallRule(ctx context.Context, in *AddFirewallRuleRequest, opts ...grpc.CallOption) (*AddFirewallRuleResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(AddFirewallRuleResponse) err := c.cc.Invoke(ctx, ProxyAdminService_AddFirewallRule_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) RemoveFirewallRule(ctx context.Context, in *RemoveFirewallRuleRequest, opts ...grpc.CallOption) (*RemoveFirewallRuleResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(RemoveFirewallRuleResponse) err := c.cc.Invoke(ctx, ProxyAdminService_RemoveFirewallRule_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) SetListenerMaxConnections(ctx context.Context, in *SetListenerMaxConnectionsRequest, opts ...grpc.CallOption) (*SetListenerMaxConnectionsResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(SetListenerMaxConnectionsResponse) err := c.cc.Invoke(ctx, ProxyAdminService_SetListenerMaxConnections_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) ListL7Policies(ctx context.Context, in *ListL7PoliciesRequest, opts ...grpc.CallOption) (*ListL7PoliciesResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ListL7PoliciesResponse) err := c.cc.Invoke(ctx, ProxyAdminService_ListL7Policies_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) AddL7Policy(ctx context.Context, in *AddL7PolicyRequest, opts ...grpc.CallOption) (*AddL7PolicyResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(AddL7PolicyResponse) err := c.cc.Invoke(ctx, ProxyAdminService_AddL7Policy_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) RemoveL7Policy(ctx context.Context, in *RemoveL7PolicyRequest, opts ...grpc.CallOption) (*RemoveL7PolicyResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(RemoveL7PolicyResponse) err := c.cc.Invoke(ctx, ProxyAdminService_RemoveL7Policy_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *proxyAdminServiceClient) GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(GetStatusResponse) err := c.cc.Invoke(ctx, ProxyAdminService_GetStatus_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } // ProxyAdminServiceServer is the server API for ProxyAdminService service. // All implementations must embed UnimplementedProxyAdminServiceServer // for forward compatibility. type ProxyAdminServiceServer interface { // Routes ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error) AddRoute(context.Context, *AddRouteRequest) (*AddRouteResponse, error) RemoveRoute(context.Context, *RemoveRouteRequest) (*RemoveRouteResponse, error) // Firewall GetFirewallRules(context.Context, *GetFirewallRulesRequest) (*GetFirewallRulesResponse, error) AddFirewallRule(context.Context, *AddFirewallRuleRequest) (*AddFirewallRuleResponse, error) RemoveFirewallRule(context.Context, *RemoveFirewallRuleRequest) (*RemoveFirewallRuleResponse, error) // Connection limits SetListenerMaxConnections(context.Context, *SetListenerMaxConnectionsRequest) (*SetListenerMaxConnectionsResponse, error) // L7 policies ListL7Policies(context.Context, *ListL7PoliciesRequest) (*ListL7PoliciesResponse, error) AddL7Policy(context.Context, *AddL7PolicyRequest) (*AddL7PolicyResponse, error) RemoveL7Policy(context.Context, *RemoveL7PolicyRequest) (*RemoveL7PolicyResponse, error) // Status GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error) mustEmbedUnimplementedProxyAdminServiceServer() } // UnimplementedProxyAdminServiceServer must be embedded to have // forward compatible implementations. // // NOTE: this should be embedded by value instead of pointer to avoid a nil // pointer dereference when methods are called. type UnimplementedProxyAdminServiceServer struct{} func (UnimplementedProxyAdminServiceServer) ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error) { return nil, status.Error(codes.Unimplemented, "method ListRoutes not implemented") } func (UnimplementedProxyAdminServiceServer) AddRoute(context.Context, *AddRouteRequest) (*AddRouteResponse, error) { return nil, status.Error(codes.Unimplemented, "method AddRoute not implemented") } func (UnimplementedProxyAdminServiceServer) RemoveRoute(context.Context, *RemoveRouteRequest) (*RemoveRouteResponse, error) { return nil, status.Error(codes.Unimplemented, "method RemoveRoute not implemented") } func (UnimplementedProxyAdminServiceServer) GetFirewallRules(context.Context, *GetFirewallRulesRequest) (*GetFirewallRulesResponse, error) { return nil, status.Error(codes.Unimplemented, "method GetFirewallRules not implemented") } func (UnimplementedProxyAdminServiceServer) AddFirewallRule(context.Context, *AddFirewallRuleRequest) (*AddFirewallRuleResponse, error) { return nil, status.Error(codes.Unimplemented, "method AddFirewallRule not implemented") } func (UnimplementedProxyAdminServiceServer) RemoveFirewallRule(context.Context, *RemoveFirewallRuleRequest) (*RemoveFirewallRuleResponse, error) { return nil, status.Error(codes.Unimplemented, "method RemoveFirewallRule not implemented") } func (UnimplementedProxyAdminServiceServer) SetListenerMaxConnections(context.Context, *SetListenerMaxConnectionsRequest) (*SetListenerMaxConnectionsResponse, error) { return nil, status.Error(codes.Unimplemented, "method SetListenerMaxConnections not implemented") } func (UnimplementedProxyAdminServiceServer) ListL7Policies(context.Context, *ListL7PoliciesRequest) (*ListL7PoliciesResponse, error) { return nil, status.Error(codes.Unimplemented, "method ListL7Policies not implemented") } func (UnimplementedProxyAdminServiceServer) AddL7Policy(context.Context, *AddL7PolicyRequest) (*AddL7PolicyResponse, error) { return nil, status.Error(codes.Unimplemented, "method AddL7Policy not implemented") } func (UnimplementedProxyAdminServiceServer) RemoveL7Policy(context.Context, *RemoveL7PolicyRequest) (*RemoveL7PolicyResponse, error) { return nil, status.Error(codes.Unimplemented, "method RemoveL7Policy not implemented") } func (UnimplementedProxyAdminServiceServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error) { return nil, status.Error(codes.Unimplemented, "method GetStatus not implemented") } func (UnimplementedProxyAdminServiceServer) mustEmbedUnimplementedProxyAdminServiceServer() {} func (UnimplementedProxyAdminServiceServer) testEmbeddedByValue() {} // UnsafeProxyAdminServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ProxyAdminServiceServer will // result in compilation errors. type UnsafeProxyAdminServiceServer interface { mustEmbedUnimplementedProxyAdminServiceServer() } func RegisterProxyAdminServiceServer(s grpc.ServiceRegistrar, srv ProxyAdminServiceServer) { // If the following call panics, it indicates UnimplementedProxyAdminServiceServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { t.testEmbeddedByValue() } s.RegisterService(&ProxyAdminService_ServiceDesc, srv) } func _ProxyAdminService_ListRoutes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListRoutesRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).ListRoutes(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_ListRoutes_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).ListRoutes(ctx, req.(*ListRoutesRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_AddRoute_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AddRouteRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).AddRoute(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_AddRoute_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).AddRoute(ctx, req.(*AddRouteRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_RemoveRoute_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RemoveRouteRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).RemoveRoute(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_RemoveRoute_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).RemoveRoute(ctx, req.(*RemoveRouteRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_GetFirewallRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetFirewallRulesRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).GetFirewallRules(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_GetFirewallRules_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).GetFirewallRules(ctx, req.(*GetFirewallRulesRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_AddFirewallRule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AddFirewallRuleRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).AddFirewallRule(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_AddFirewallRule_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).AddFirewallRule(ctx, req.(*AddFirewallRuleRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_RemoveFirewallRule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RemoveFirewallRuleRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).RemoveFirewallRule(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_RemoveFirewallRule_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).RemoveFirewallRule(ctx, req.(*RemoveFirewallRuleRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_SetListenerMaxConnections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SetListenerMaxConnectionsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).SetListenerMaxConnections(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_SetListenerMaxConnections_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).SetListenerMaxConnections(ctx, req.(*SetListenerMaxConnectionsRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_ListL7Policies_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListL7PoliciesRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).ListL7Policies(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_ListL7Policies_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).ListL7Policies(ctx, req.(*ListL7PoliciesRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_AddL7Policy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AddL7PolicyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).AddL7Policy(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_AddL7Policy_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).AddL7Policy(ctx, req.(*AddL7PolicyRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_RemoveL7Policy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RemoveL7PolicyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).RemoveL7Policy(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_RemoveL7Policy_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).RemoveL7Policy(ctx, req.(*RemoveL7PolicyRequest)) } return interceptor(ctx, in, info, handler) } func _ProxyAdminService_GetStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetStatusRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ProxyAdminServiceServer).GetStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: ProxyAdminService_GetStatus_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProxyAdminServiceServer).GetStatus(ctx, req.(*GetStatusRequest)) } return interceptor(ctx, in, info, handler) } // ProxyAdminService_ServiceDesc is the grpc.ServiceDesc for ProxyAdminService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ProxyAdminService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mc_proxy.v1.ProxyAdminService", HandlerType: (*ProxyAdminServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListRoutes", Handler: _ProxyAdminService_ListRoutes_Handler, }, { MethodName: "AddRoute", Handler: _ProxyAdminService_AddRoute_Handler, }, { MethodName: "RemoveRoute", Handler: _ProxyAdminService_RemoveRoute_Handler, }, { MethodName: "GetFirewallRules", Handler: _ProxyAdminService_GetFirewallRules_Handler, }, { MethodName: "AddFirewallRule", Handler: _ProxyAdminService_AddFirewallRule_Handler, }, { MethodName: "RemoveFirewallRule", Handler: _ProxyAdminService_RemoveFirewallRule_Handler, }, { MethodName: "SetListenerMaxConnections", Handler: _ProxyAdminService_SetListenerMaxConnections_Handler, }, { MethodName: "ListL7Policies", Handler: _ProxyAdminService_ListL7Policies_Handler, }, { MethodName: "AddL7Policy", Handler: _ProxyAdminService_AddL7Policy_Handler, }, { MethodName: "RemoveL7Policy", Handler: _ProxyAdminService_RemoveL7Policy_Handler, }, { MethodName: "GetStatus", Handler: _ProxyAdminService_GetStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/mc_proxy/v1/admin.proto", }