1// Code generated by protoc-gen-go-drpc. DO NOT EDIT. 2// protoc-gen-go-drpc version: v0.0.24 3// source: inspector.proto 4 5package internalpb 6 7import ( 8 bytes "bytes" 9 context "context" 10 errors "errors" 11 12 jsonpb "github.com/gogo/protobuf/jsonpb" 13 proto "github.com/gogo/protobuf/proto" 14 15 drpc "storj.io/drpc" 16 drpcerr "storj.io/drpc/drpcerr" 17) 18 19type drpcEncoding_File_inspector_proto struct{} 20 21func (drpcEncoding_File_inspector_proto) Marshal(msg drpc.Message) ([]byte, error) { 22 return proto.Marshal(msg.(proto.Message)) 23} 24 25func (drpcEncoding_File_inspector_proto) Unmarshal(buf []byte, msg drpc.Message) error { 26 return proto.Unmarshal(buf, msg.(proto.Message)) 27} 28 29func (drpcEncoding_File_inspector_proto) JSONMarshal(msg drpc.Message) ([]byte, error) { 30 var buf bytes.Buffer 31 err := new(jsonpb.Marshaler).Marshal(&buf, msg.(proto.Message)) 32 if err != nil { 33 return nil, err 34 } 35 return buf.Bytes(), nil 36} 37 38func (drpcEncoding_File_inspector_proto) JSONUnmarshal(buf []byte, msg drpc.Message) error { 39 return jsonpb.Unmarshal(bytes.NewReader(buf), msg.(proto.Message)) 40} 41 42type DRPCHealthInspectorClient interface { 43 DRPCConn() drpc.Conn 44 45 ObjectHealth(ctx context.Context, in *ObjectHealthRequest) (*ObjectHealthResponse, error) 46 SegmentHealth(ctx context.Context, in *SegmentHealthRequest) (*SegmentHealthResponse, error) 47} 48 49type drpcHealthInspectorClient struct { 50 cc drpc.Conn 51} 52 53func NewDRPCHealthInspectorClient(cc drpc.Conn) DRPCHealthInspectorClient { 54 return &drpcHealthInspectorClient{cc} 55} 56 57func (c *drpcHealthInspectorClient) DRPCConn() drpc.Conn { return c.cc } 58 59func (c *drpcHealthInspectorClient) ObjectHealth(ctx context.Context, in *ObjectHealthRequest) (*ObjectHealthResponse, error) { 60 out := new(ObjectHealthResponse) 61 err := c.cc.Invoke(ctx, "/satellite.inspector.HealthInspector/ObjectHealth", drpcEncoding_File_inspector_proto{}, in, out) 62 if err != nil { 63 return nil, err 64 } 65 return out, nil 66} 67 68func (c *drpcHealthInspectorClient) SegmentHealth(ctx context.Context, in *SegmentHealthRequest) (*SegmentHealthResponse, error) { 69 out := new(SegmentHealthResponse) 70 err := c.cc.Invoke(ctx, "/satellite.inspector.HealthInspector/SegmentHealth", drpcEncoding_File_inspector_proto{}, in, out) 71 if err != nil { 72 return nil, err 73 } 74 return out, nil 75} 76 77type DRPCHealthInspectorServer interface { 78 ObjectHealth(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error) 79 SegmentHealth(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error) 80} 81 82type DRPCHealthInspectorUnimplementedServer struct{} 83 84func (s *DRPCHealthInspectorUnimplementedServer) ObjectHealth(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error) { 85 return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented) 86} 87 88func (s *DRPCHealthInspectorUnimplementedServer) SegmentHealth(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error) { 89 return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented) 90} 91 92type DRPCHealthInspectorDescription struct{} 93 94func (DRPCHealthInspectorDescription) NumMethods() int { return 2 } 95 96func (DRPCHealthInspectorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) { 97 switch n { 98 case 0: 99 return "/satellite.inspector.HealthInspector/ObjectHealth", drpcEncoding_File_inspector_proto{}, 100 func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) { 101 return srv.(DRPCHealthInspectorServer). 102 ObjectHealth( 103 ctx, 104 in1.(*ObjectHealthRequest), 105 ) 106 }, DRPCHealthInspectorServer.ObjectHealth, true 107 case 1: 108 return "/satellite.inspector.HealthInspector/SegmentHealth", drpcEncoding_File_inspector_proto{}, 109 func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) { 110 return srv.(DRPCHealthInspectorServer). 111 SegmentHealth( 112 ctx, 113 in1.(*SegmentHealthRequest), 114 ) 115 }, DRPCHealthInspectorServer.SegmentHealth, true 116 default: 117 return "", nil, nil, nil, false 118 } 119} 120 121func DRPCRegisterHealthInspector(mux drpc.Mux, impl DRPCHealthInspectorServer) error { 122 return mux.Register(impl, DRPCHealthInspectorDescription{}) 123} 124 125type DRPCHealthInspector_ObjectHealthStream interface { 126 drpc.Stream 127 SendAndClose(*ObjectHealthResponse) error 128} 129 130type drpcHealthInspector_ObjectHealthStream struct { 131 drpc.Stream 132} 133 134func (x *drpcHealthInspector_ObjectHealthStream) SendAndClose(m *ObjectHealthResponse) error { 135 if err := x.MsgSend(m, drpcEncoding_File_inspector_proto{}); err != nil { 136 return err 137 } 138 return x.CloseSend() 139} 140 141type DRPCHealthInspector_SegmentHealthStream interface { 142 drpc.Stream 143 SendAndClose(*SegmentHealthResponse) error 144} 145 146type drpcHealthInspector_SegmentHealthStream struct { 147 drpc.Stream 148} 149 150func (x *drpcHealthInspector_SegmentHealthStream) SendAndClose(m *SegmentHealthResponse) error { 151 if err := x.MsgSend(m, drpcEncoding_File_inspector_proto{}); err != nil { 152 return err 153 } 154 return x.CloseSend() 155} 156