1
0

stats_grpc.pb.go 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173
  1. package v2rayapi
  2. import (
  3. context "context"
  4. grpc "google.golang.org/grpc"
  5. codes "google.golang.org/grpc/codes"
  6. status "google.golang.org/grpc/status"
  7. )
  8. // This is a compile-time assertion to ensure that this generated file
  9. // is compatible with the grpc package it is being compiled against.
  10. // Requires gRPC-Go v1.32.0 or later.
  11. const _ = grpc.SupportPackageIsVersion7
  12. // StatsServiceClient is the client API for StatsService service.
  13. //
  14. // 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.
  15. type StatsServiceClient interface {
  16. GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)
  17. QueryStats(ctx context.Context, in *QueryStatsRequest, opts ...grpc.CallOption) (*QueryStatsResponse, error)
  18. GetSysStats(ctx context.Context, in *SysStatsRequest, opts ...grpc.CallOption) (*SysStatsResponse, error)
  19. }
  20. type statsServiceClient struct {
  21. cc grpc.ClientConnInterface
  22. }
  23. func NewStatsServiceClient(cc grpc.ClientConnInterface) StatsServiceClient {
  24. return &statsServiceClient{cc}
  25. }
  26. func (c *statsServiceClient) GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error) {
  27. out := new(GetStatsResponse)
  28. err := c.cc.Invoke(ctx, "/experimental.v2rayapi.StatsService/GetStats", in, out, opts...)
  29. if err != nil {
  30. return nil, err
  31. }
  32. return out, nil
  33. }
  34. func (c *statsServiceClient) QueryStats(ctx context.Context, in *QueryStatsRequest, opts ...grpc.CallOption) (*QueryStatsResponse, error) {
  35. out := new(QueryStatsResponse)
  36. err := c.cc.Invoke(ctx, "/experimental.v2rayapi.StatsService/QueryStats", in, out, opts...)
  37. if err != nil {
  38. return nil, err
  39. }
  40. return out, nil
  41. }
  42. func (c *statsServiceClient) GetSysStats(ctx context.Context, in *SysStatsRequest, opts ...grpc.CallOption) (*SysStatsResponse, error) {
  43. out := new(SysStatsResponse)
  44. err := c.cc.Invoke(ctx, "/experimental.v2rayapi.StatsService/GetSysStats", in, out, opts...)
  45. if err != nil {
  46. return nil, err
  47. }
  48. return out, nil
  49. }
  50. // StatsServiceServer is the server API for StatsService service.
  51. // All implementations must embed UnimplementedStatsServiceServer
  52. // for forward compatibility
  53. type StatsServiceServer interface {
  54. GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)
  55. QueryStats(context.Context, *QueryStatsRequest) (*QueryStatsResponse, error)
  56. GetSysStats(context.Context, *SysStatsRequest) (*SysStatsResponse, error)
  57. mustEmbedUnimplementedStatsServiceServer()
  58. }
  59. // UnimplementedStatsServiceServer must be embedded to have forward compatible implementations.
  60. type UnimplementedStatsServiceServer struct{}
  61. func (UnimplementedStatsServiceServer) GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error) {
  62. return nil, status.Errorf(codes.Unimplemented, "method GetStats not implemented")
  63. }
  64. func (UnimplementedStatsServiceServer) QueryStats(context.Context, *QueryStatsRequest) (*QueryStatsResponse, error) {
  65. return nil, status.Errorf(codes.Unimplemented, "method QueryStats not implemented")
  66. }
  67. func (UnimplementedStatsServiceServer) GetSysStats(context.Context, *SysStatsRequest) (*SysStatsResponse, error) {
  68. return nil, status.Errorf(codes.Unimplemented, "method GetSysStats not implemented")
  69. }
  70. func (UnimplementedStatsServiceServer) mustEmbedUnimplementedStatsServiceServer() {}
  71. // UnsafeStatsServiceServer may be embedded to opt out of forward compatibility for this service.
  72. // Use of this interface is not recommended, as added methods to StatsServiceServer will
  73. // result in compilation errors.
  74. type UnsafeStatsServiceServer interface {
  75. mustEmbedUnimplementedStatsServiceServer()
  76. }
  77. func RegisterStatsServiceServer(s grpc.ServiceRegistrar, srv StatsServiceServer) {
  78. s.RegisterService(&StatsService_ServiceDesc, srv)
  79. }
  80. func _StatsService_GetStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  81. in := new(GetStatsRequest)
  82. if err := dec(in); err != nil {
  83. return nil, err
  84. }
  85. if interceptor == nil {
  86. return srv.(StatsServiceServer).GetStats(ctx, in)
  87. }
  88. info := &grpc.UnaryServerInfo{
  89. Server: srv,
  90. FullMethod: "/experimental.v2rayapi.StatsService/GetStats",
  91. }
  92. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  93. return srv.(StatsServiceServer).GetStats(ctx, req.(*GetStatsRequest))
  94. }
  95. return interceptor(ctx, in, info, handler)
  96. }
  97. func _StatsService_QueryStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  98. in := new(QueryStatsRequest)
  99. if err := dec(in); err != nil {
  100. return nil, err
  101. }
  102. if interceptor == nil {
  103. return srv.(StatsServiceServer).QueryStats(ctx, in)
  104. }
  105. info := &grpc.UnaryServerInfo{
  106. Server: srv,
  107. FullMethod: "/experimental.v2rayapi.StatsService/QueryStats",
  108. }
  109. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  110. return srv.(StatsServiceServer).QueryStats(ctx, req.(*QueryStatsRequest))
  111. }
  112. return interceptor(ctx, in, info, handler)
  113. }
  114. func _StatsService_GetSysStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  115. in := new(SysStatsRequest)
  116. if err := dec(in); err != nil {
  117. return nil, err
  118. }
  119. if interceptor == nil {
  120. return srv.(StatsServiceServer).GetSysStats(ctx, in)
  121. }
  122. info := &grpc.UnaryServerInfo{
  123. Server: srv,
  124. FullMethod: "/experimental.v2rayapi.StatsService/GetSysStats",
  125. }
  126. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  127. return srv.(StatsServiceServer).GetSysStats(ctx, req.(*SysStatsRequest))
  128. }
  129. return interceptor(ctx, in, info, handler)
  130. }
  131. // StatsService_ServiceDesc is the grpc.ServiceDesc for StatsService service.
  132. // It's only intended for direct use with grpc.RegisterService,
  133. // and not to be introspected or modified (even as a copy)
  134. var StatsService_ServiceDesc = grpc.ServiceDesc{
  135. ServiceName: "experimental.v2rayapi.StatsService",
  136. HandlerType: (*StatsServiceServer)(nil),
  137. Methods: []grpc.MethodDesc{
  138. {
  139. MethodName: "GetStats",
  140. Handler: _StatsService_GetStats_Handler,
  141. },
  142. {
  143. MethodName: "QueryStats",
  144. Handler: _StatsService_QueryStats_Handler,
  145. },
  146. {
  147. MethodName: "GetSysStats",
  148. Handler: _StatsService_GetSysStats_Handler,
  149. },
  150. },
  151. Streams: []grpc.StreamDesc{},
  152. Metadata: "experimental/v2rayapi/stats.proto",
  153. }