update

Hunter0x7c7

2022-08-11 b8230139fb40edea387617b6accd8371e37eda58

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
// Code generated by protoc-gen-go-grpc. DO NOT EDIT. 
// versions: 
// - protoc-gen-go-grpc v1.2.0 
// - protoc             v3.17.3 
// source: app/observatory/command/command.proto 
 
package command 
 
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.32.0 or later. 
const _ = grpc.SupportPackageIsVersion7 
 
// ObservatoryServiceClient is the client API for ObservatoryService 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 ObservatoryServiceClient interface { 
    GetOutboundStatus(ctx context.Context, in *GetOutboundStatusRequest, opts ...grpc.CallOption) (*GetOutboundStatusResponse, error) 
} 
 
type observatoryServiceClient struct { 
    cc grpc.ClientConnInterface 
} 
 
func NewObservatoryServiceClient(cc grpc.ClientConnInterface) ObservatoryServiceClient { 
    return &observatoryServiceClient{cc} 
} 
 
func (c *observatoryServiceClient) GetOutboundStatus(ctx context.Context, in *GetOutboundStatusRequest, opts ...grpc.CallOption) (*GetOutboundStatusResponse, error) { 
    out := new(GetOutboundStatusResponse) 
    err := c.cc.Invoke(ctx, "/v2ray.core.app.observatory.command.ObservatoryService/GetOutboundStatus", in, out, opts...) 
    if err != nil { 
        return nil, err 
    } 
    return out, nil 
} 
 
// ObservatoryServiceServer is the server API for ObservatoryService service. 
// All implementations must embed UnimplementedObservatoryServiceServer 
// for forward compatibility 
type ObservatoryServiceServer interface { 
    GetOutboundStatus(context.Context, *GetOutboundStatusRequest) (*GetOutboundStatusResponse, error) 
    mustEmbedUnimplementedObservatoryServiceServer() 
} 
 
// UnimplementedObservatoryServiceServer must be embedded to have forward compatible implementations. 
type UnimplementedObservatoryServiceServer struct { 
} 
 
func (UnimplementedObservatoryServiceServer) GetOutboundStatus(context.Context, *GetOutboundStatusRequest) (*GetOutboundStatusResponse, error) { 
    return nil, status.Errorf(codes.Unimplemented, "method GetOutboundStatus not implemented") 
} 
func (UnimplementedObservatoryServiceServer) mustEmbedUnimplementedObservatoryServiceServer() {} 
 
// UnsafeObservatoryServiceServer may be embedded to opt out of forward compatibility for this service. 
// Use of this interface is not recommended, as added methods to ObservatoryServiceServer will 
// result in compilation errors. 
type UnsafeObservatoryServiceServer interface { 
    mustEmbedUnimplementedObservatoryServiceServer() 
} 
 
func RegisterObservatoryServiceServer(s grpc.ServiceRegistrar, srv ObservatoryServiceServer) { 
    s.RegisterService(&ObservatoryService_ServiceDesc, srv) 
} 
 
func _ObservatoryService_GetOutboundStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 
    in := new(GetOutboundStatusRequest) 
    if err := dec(in); err != nil { 
        return nil, err 
    } 
    if interceptor == nil { 
        return srv.(ObservatoryServiceServer).GetOutboundStatus(ctx, in) 
    } 
    info := &grpc.UnaryServerInfo{ 
        Server:     srv, 
        FullMethod: "/v2ray.core.app.observatory.command.ObservatoryService/GetOutboundStatus", 
    } 
    handler := func(ctx context.Context, req interface{}) (interface{}, error) { 
        return srv.(ObservatoryServiceServer).GetOutboundStatus(ctx, req.(*GetOutboundStatusRequest)) 
    } 
    return interceptor(ctx, in, info, handler) 
} 
 
// ObservatoryService_ServiceDesc is the grpc.ServiceDesc for ObservatoryService service. 
// It's only intended for direct use with grpc.RegisterService, 
// and not to be introspected or modified (even as a copy) 
var ObservatoryService_ServiceDesc = grpc.ServiceDesc{ 
    ServiceName: "v2ray.core.app.observatory.command.ObservatoryService", 
    HandlerType: (*ObservatoryServiceServer)(nil), 
    Methods: []grpc.MethodDesc{ 
        { 
            MethodName: "GetOutboundStatus", 
            Handler:    _ObservatoryService_GetOutboundStatus_Handler, 
        }, 
    }, 
    Streams:  []grpc.StreamDesc{}, 
    Metadata: "app/observatory/command/command.proto", 
}