...
1
2
3
4
5
6
7 package proto
8
9 import (
10 context "context"
11 grpc "google.golang.org/grpc"
12 codes "google.golang.org/grpc/codes"
13 status "google.golang.org/grpc/status"
14 )
15
16
17
18
19 const _ = grpc.SupportPackageIsVersion7
20
21
22
23
24 type PublisherClient interface {
25 SubmitToSingleCTWithResult(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Result, error)
26 }
27
28 type publisherClient struct {
29 cc grpc.ClientConnInterface
30 }
31
32 func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient {
33 return &publisherClient{cc}
34 }
35
36 func (c *publisherClient) SubmitToSingleCTWithResult(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Result, error) {
37 out := new(Result)
38 err := c.cc.Invoke(ctx, "/Publisher/SubmitToSingleCTWithResult", in, out, opts...)
39 if err != nil {
40 return nil, err
41 }
42 return out, nil
43 }
44
45
46
47
48 type PublisherServer interface {
49 SubmitToSingleCTWithResult(context.Context, *Request) (*Result, error)
50 mustEmbedUnimplementedPublisherServer()
51 }
52
53
54 type UnimplementedPublisherServer struct {
55 }
56
57 func (UnimplementedPublisherServer) SubmitToSingleCTWithResult(context.Context, *Request) (*Result, error) {
58 return nil, status.Errorf(codes.Unimplemented, "method SubmitToSingleCTWithResult not implemented")
59 }
60 func (UnimplementedPublisherServer) mustEmbedUnimplementedPublisherServer() {}
61
62
63
64
65 type UnsafePublisherServer interface {
66 mustEmbedUnimplementedPublisherServer()
67 }
68
69 func RegisterPublisherServer(s grpc.ServiceRegistrar, srv PublisherServer) {
70 s.RegisterService(&Publisher_ServiceDesc, srv)
71 }
72
73 func _Publisher_SubmitToSingleCTWithResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
74 in := new(Request)
75 if err := dec(in); err != nil {
76 return nil, err
77 }
78 if interceptor == nil {
79 return srv.(PublisherServer).SubmitToSingleCTWithResult(ctx, in)
80 }
81 info := &grpc.UnaryServerInfo{
82 Server: srv,
83 FullMethod: "/Publisher/SubmitToSingleCTWithResult",
84 }
85 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
86 return srv.(PublisherServer).SubmitToSingleCTWithResult(ctx, req.(*Request))
87 }
88 return interceptor(ctx, in, info, handler)
89 }
90
91
92
93
94 var Publisher_ServiceDesc = grpc.ServiceDesc{
95 ServiceName: "Publisher",
96 HandlerType: (*PublisherServer)(nil),
97 Methods: []grpc.MethodDesc{
98 {
99 MethodName: "SubmitToSingleCTWithResult",
100 Handler: _Publisher_SubmitToSingleCTWithResult_Handler,
101 },
102 },
103 Streams: []grpc.StreamDesc{},
104 Metadata: "publisher.proto",
105 }
106
View as plain text