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