1// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: cleanup.proto
3
4package gitalypb
5
6import (
7	context "context"
8	fmt "fmt"
9	proto "github.com/golang/protobuf/proto"
10	grpc "google.golang.org/grpc"
11	codes "google.golang.org/grpc/codes"
12	status "google.golang.org/grpc/status"
13	math "math"
14)
15
16// Reference imports to suppress errors if they are not otherwise used.
17var _ = proto.Marshal
18var _ = fmt.Errorf
19var _ = math.Inf
20
21// This is a compile-time assertion to ensure that this generated file
22// is compatible with the proto package it is being compiled against.
23// A compilation error at this line likely means your copy of the
24// proto package needs to be updated.
25const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
26
27type ApplyBfgObjectMapStreamRequest struct {
28	// Only available on the first message
29	Repository *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
30	// A raw object-map file as generated by BFG: https://rtyley.github.io/bfg-repo-cleaner
31	// Each line in the file has two object SHAs, space-separated - the original
32	// SHA of the object, and the SHA after BFG has rewritten the object.
33	ObjectMap            []byte   `protobuf:"bytes,2,opt,name=object_map,json=objectMap,proto3" json:"object_map,omitempty"`
34	XXX_NoUnkeyedLiteral struct{} `json:"-"`
35	XXX_unrecognized     []byte   `json:"-"`
36	XXX_sizecache        int32    `json:"-"`
37}
38
39func (m *ApplyBfgObjectMapStreamRequest) Reset()         { *m = ApplyBfgObjectMapStreamRequest{} }
40func (m *ApplyBfgObjectMapStreamRequest) String() string { return proto.CompactTextString(m) }
41func (*ApplyBfgObjectMapStreamRequest) ProtoMessage()    {}
42func (*ApplyBfgObjectMapStreamRequest) Descriptor() ([]byte, []int) {
43	return fileDescriptor_1b19e990e4662c9c, []int{0}
44}
45
46func (m *ApplyBfgObjectMapStreamRequest) XXX_Unmarshal(b []byte) error {
47	return xxx_messageInfo_ApplyBfgObjectMapStreamRequest.Unmarshal(m, b)
48}
49func (m *ApplyBfgObjectMapStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
50	return xxx_messageInfo_ApplyBfgObjectMapStreamRequest.Marshal(b, m, deterministic)
51}
52func (m *ApplyBfgObjectMapStreamRequest) XXX_Merge(src proto.Message) {
53	xxx_messageInfo_ApplyBfgObjectMapStreamRequest.Merge(m, src)
54}
55func (m *ApplyBfgObjectMapStreamRequest) XXX_Size() int {
56	return xxx_messageInfo_ApplyBfgObjectMapStreamRequest.Size(m)
57}
58func (m *ApplyBfgObjectMapStreamRequest) XXX_DiscardUnknown() {
59	xxx_messageInfo_ApplyBfgObjectMapStreamRequest.DiscardUnknown(m)
60}
61
62var xxx_messageInfo_ApplyBfgObjectMapStreamRequest proto.InternalMessageInfo
63
64func (m *ApplyBfgObjectMapStreamRequest) GetRepository() *Repository {
65	if m != nil {
66		return m.Repository
67	}
68	return nil
69}
70
71func (m *ApplyBfgObjectMapStreamRequest) GetObjectMap() []byte {
72	if m != nil {
73		return m.ObjectMap
74	}
75	return nil
76}
77
78type ApplyBfgObjectMapStreamResponse struct {
79	Entries              []*ApplyBfgObjectMapStreamResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
80	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
81	XXX_unrecognized     []byte                                   `json:"-"`
82	XXX_sizecache        int32                                    `json:"-"`
83}
84
85func (m *ApplyBfgObjectMapStreamResponse) Reset()         { *m = ApplyBfgObjectMapStreamResponse{} }
86func (m *ApplyBfgObjectMapStreamResponse) String() string { return proto.CompactTextString(m) }
87func (*ApplyBfgObjectMapStreamResponse) ProtoMessage()    {}
88func (*ApplyBfgObjectMapStreamResponse) Descriptor() ([]byte, []int) {
89	return fileDescriptor_1b19e990e4662c9c, []int{1}
90}
91
92func (m *ApplyBfgObjectMapStreamResponse) XXX_Unmarshal(b []byte) error {
93	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse.Unmarshal(m, b)
94}
95func (m *ApplyBfgObjectMapStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
96	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse.Marshal(b, m, deterministic)
97}
98func (m *ApplyBfgObjectMapStreamResponse) XXX_Merge(src proto.Message) {
99	xxx_messageInfo_ApplyBfgObjectMapStreamResponse.Merge(m, src)
100}
101func (m *ApplyBfgObjectMapStreamResponse) XXX_Size() int {
102	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse.Size(m)
103}
104func (m *ApplyBfgObjectMapStreamResponse) XXX_DiscardUnknown() {
105	xxx_messageInfo_ApplyBfgObjectMapStreamResponse.DiscardUnknown(m)
106}
107
108var xxx_messageInfo_ApplyBfgObjectMapStreamResponse proto.InternalMessageInfo
109
110func (m *ApplyBfgObjectMapStreamResponse) GetEntries() []*ApplyBfgObjectMapStreamResponse_Entry {
111	if m != nil {
112		return m.Entries
113	}
114	return nil
115}
116
117// We send back each parsed entry in the request's object map so the client
118// can take action
119type ApplyBfgObjectMapStreamResponse_Entry struct {
120	Type                 ObjectType `protobuf:"varint,1,opt,name=type,proto3,enum=gitaly.ObjectType" json:"type,omitempty"`
121	OldOid               string     `protobuf:"bytes,2,opt,name=old_oid,json=oldOid,proto3" json:"old_oid,omitempty"`
122	NewOid               string     `protobuf:"bytes,3,opt,name=new_oid,json=newOid,proto3" json:"new_oid,omitempty"`
123	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
124	XXX_unrecognized     []byte     `json:"-"`
125	XXX_sizecache        int32      `json:"-"`
126}
127
128func (m *ApplyBfgObjectMapStreamResponse_Entry) Reset()         { *m = ApplyBfgObjectMapStreamResponse_Entry{} }
129func (m *ApplyBfgObjectMapStreamResponse_Entry) String() string { return proto.CompactTextString(m) }
130func (*ApplyBfgObjectMapStreamResponse_Entry) ProtoMessage()    {}
131func (*ApplyBfgObjectMapStreamResponse_Entry) Descriptor() ([]byte, []int) {
132	return fileDescriptor_1b19e990e4662c9c, []int{1, 0}
133}
134
135func (m *ApplyBfgObjectMapStreamResponse_Entry) XXX_Unmarshal(b []byte) error {
136	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry.Unmarshal(m, b)
137}
138func (m *ApplyBfgObjectMapStreamResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
139	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry.Marshal(b, m, deterministic)
140}
141func (m *ApplyBfgObjectMapStreamResponse_Entry) XXX_Merge(src proto.Message) {
142	xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry.Merge(m, src)
143}
144func (m *ApplyBfgObjectMapStreamResponse_Entry) XXX_Size() int {
145	return xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry.Size(m)
146}
147func (m *ApplyBfgObjectMapStreamResponse_Entry) XXX_DiscardUnknown() {
148	xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry.DiscardUnknown(m)
149}
150
151var xxx_messageInfo_ApplyBfgObjectMapStreamResponse_Entry proto.InternalMessageInfo
152
153func (m *ApplyBfgObjectMapStreamResponse_Entry) GetType() ObjectType {
154	if m != nil {
155		return m.Type
156	}
157	return ObjectType_UNKNOWN
158}
159
160func (m *ApplyBfgObjectMapStreamResponse_Entry) GetOldOid() string {
161	if m != nil {
162		return m.OldOid
163	}
164	return ""
165}
166
167func (m *ApplyBfgObjectMapStreamResponse_Entry) GetNewOid() string {
168	if m != nil {
169		return m.NewOid
170	}
171	return ""
172}
173
174func init() {
175	proto.RegisterType((*ApplyBfgObjectMapStreamRequest)(nil), "gitaly.ApplyBfgObjectMapStreamRequest")
176	proto.RegisterType((*ApplyBfgObjectMapStreamResponse)(nil), "gitaly.ApplyBfgObjectMapStreamResponse")
177	proto.RegisterType((*ApplyBfgObjectMapStreamResponse_Entry)(nil), "gitaly.ApplyBfgObjectMapStreamResponse.Entry")
178}
179
180func init() { proto.RegisterFile("cleanup.proto", fileDescriptor_1b19e990e4662c9c) }
181
182var fileDescriptor_1b19e990e4662c9c = []byte{
183	// 344 bytes of a gzipped FileDescriptorProto
184	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x91, 0x41, 0x4f, 0xc2, 0x30,
185	0x14, 0xc7, 0x53, 0xc0, 0x21, 0x05, 0x39, 0xf4, 0x02, 0x59, 0xa2, 0x12, 0x0e, 0xb8, 0x83, 0x6c,
186	0x3a, 0x39, 0x78, 0x15, 0x63, 0x3c, 0x19, 0x92, 0xe1, 0xc9, 0x0b, 0xe9, 0xb6, 0xe7, 0xac, 0x19,
187	0x6b, 0xed, 0x0a, 0xa4, 0xdf, 0xc0, 0x6f, 0xa0, 0x9f, 0xc8, 0x9b, 0x5f, 0xc8, 0x93, 0xb1, 0x15,
188	0xf5, 0x42, 0xf0, 0xd6, 0xfe, 0x7f, 0x7d, 0xff, 0xf7, 0xfe, 0xaf, 0x78, 0x2f, 0xc9, 0x81, 0x16,
189	0x0b, 0xe1, 0x0b, 0xc9, 0x15, 0x27, 0x4e, 0xc6, 0x14, 0xcd, 0xb5, 0x8b, 0x73, 0x56, 0x28, 0xab,
190	0xb9, 0xad, 0xf2, 0x81, 0x4a, 0x48, 0xed, 0xad, 0xaf, 0xf1, 0xc1, 0x85, 0x10, 0xb9, 0x1e, 0xdf,
191	0x67, 0x93, 0xf8, 0x11, 0x12, 0x75, 0x43, 0xc5, 0x54, 0x49, 0xa0, 0xf3, 0x08, 0x9e, 0x16, 0x50,
192	0x2a, 0x72, 0x8e, 0xb1, 0x04, 0xc1, 0x4b, 0xa6, 0xb8, 0xd4, 0x5d, 0xd4, 0x43, 0x5e, 0x33, 0x24,
193	0xbe, 0x35, 0xf6, 0xa3, 0x1f, 0x32, 0xae, 0xbd, 0xbe, 0x1d, 0xa3, 0xe8, 0xcf, 0x5b, 0xb2, 0x8f,
194	0x31, 0x37, 0x9e, 0xb3, 0x39, 0x15, 0xdd, 0x4a, 0x0f, 0x79, 0xad, 0xa8, 0xc1, 0xd7, 0x5d, 0xfa,
195	0xef, 0x08, 0x1f, 0x6e, 0xec, 0x5d, 0x0a, 0x5e, 0x94, 0x40, 0xae, 0x71, 0x1d, 0x0a, 0x25, 0x19,
196	0x94, 0x5d, 0xd4, 0xab, 0x7a, 0xcd, 0x70, 0xb8, 0xee, 0xbc, 0xa5, 0xd2, 0xbf, 0x2a, 0x94, 0xd4,
197	0xd1, 0xba, 0xda, 0xa5, 0x78, 0xc7, 0x28, 0x64, 0x80, 0x6b, 0x4a, 0x0b, 0x30, 0x41, 0xda, 0xbf,
198	0x41, 0xac, 0xcd, 0xad, 0x16, 0x10, 0x19, 0x4e, 0x3a, 0xb8, 0xce, 0xf3, 0x74, 0xc6, 0x59, 0x6a,
199	0x26, 0x6f, 0x44, 0x0e, 0xcf, 0xd3, 0x09, 0x4b, 0xbf, 0x40, 0x01, 0x2b, 0x03, 0xaa, 0x16, 0x14,
200	0xb0, 0x9a, 0xb0, 0x34, 0x7c, 0x46, 0xb8, 0x7d, 0x69, 0xd7, 0x3f, 0x05, 0xb9, 0x64, 0x09, 0x90,
201	0x25, 0xee, 0x6c, 0x98, 0x93, 0x0c, 0xb6, 0x06, 0x31, 0xeb, 0x77, 0x8f, 0xfe, 0x19, 0xb8, 0xef,
202	0x7c, 0xbc, 0x78, 0x95, 0x5d, 0xe4, 0xa1, 0x13, 0x34, 0x1e, 0xdd, 0x85, 0x19, 0x53, 0x39, 0x8d,
203	0xfd, 0x84, 0xcf, 0x03, 0x7b, 0x1c, 0x72, 0x99, 0x05, 0xd6, 0x2b, 0x58, 0x9e, 0x8e, 0x02, 0xf3,
204	0xff, 0x41, 0xc6, 0xbf, 0x35, 0x11, 0xc7, 0x8e, 0x91, 0xce, 0x3e, 0x03, 0x00, 0x00, 0xff, 0xff,
205	0xd0, 0xc2, 0x1d, 0xd0, 0x45, 0x02, 0x00, 0x00,
206}
207
208// Reference imports to suppress errors if they are not otherwise used.
209var _ context.Context
210var _ grpc.ClientConn
211
212// This is a compile-time assertion to ensure that this generated file
213// is compatible with the grpc package it is being compiled against.
214const _ = grpc.SupportPackageIsVersion4
215
216// CleanupServiceClient is the client API for CleanupService service.
217//
218// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
219type CleanupServiceClient interface {
220	ApplyBfgObjectMapStream(ctx context.Context, opts ...grpc.CallOption) (CleanupService_ApplyBfgObjectMapStreamClient, error)
221}
222
223type cleanupServiceClient struct {
224	cc *grpc.ClientConn
225}
226
227func NewCleanupServiceClient(cc *grpc.ClientConn) CleanupServiceClient {
228	return &cleanupServiceClient{cc}
229}
230
231func (c *cleanupServiceClient) ApplyBfgObjectMapStream(ctx context.Context, opts ...grpc.CallOption) (CleanupService_ApplyBfgObjectMapStreamClient, error) {
232	stream, err := c.cc.NewStream(ctx, &_CleanupService_serviceDesc.Streams[0], "/gitaly.CleanupService/ApplyBfgObjectMapStream", opts...)
233	if err != nil {
234		return nil, err
235	}
236	x := &cleanupServiceApplyBfgObjectMapStreamClient{stream}
237	return x, nil
238}
239
240type CleanupService_ApplyBfgObjectMapStreamClient interface {
241	Send(*ApplyBfgObjectMapStreamRequest) error
242	Recv() (*ApplyBfgObjectMapStreamResponse, error)
243	grpc.ClientStream
244}
245
246type cleanupServiceApplyBfgObjectMapStreamClient struct {
247	grpc.ClientStream
248}
249
250func (x *cleanupServiceApplyBfgObjectMapStreamClient) Send(m *ApplyBfgObjectMapStreamRequest) error {
251	return x.ClientStream.SendMsg(m)
252}
253
254func (x *cleanupServiceApplyBfgObjectMapStreamClient) Recv() (*ApplyBfgObjectMapStreamResponse, error) {
255	m := new(ApplyBfgObjectMapStreamResponse)
256	if err := x.ClientStream.RecvMsg(m); err != nil {
257		return nil, err
258	}
259	return m, nil
260}
261
262// CleanupServiceServer is the server API for CleanupService service.
263type CleanupServiceServer interface {
264	ApplyBfgObjectMapStream(CleanupService_ApplyBfgObjectMapStreamServer) error
265}
266
267// UnimplementedCleanupServiceServer can be embedded to have forward compatible implementations.
268type UnimplementedCleanupServiceServer struct {
269}
270
271func (*UnimplementedCleanupServiceServer) ApplyBfgObjectMapStream(srv CleanupService_ApplyBfgObjectMapStreamServer) error {
272	return status.Errorf(codes.Unimplemented, "method ApplyBfgObjectMapStream not implemented")
273}
274
275func RegisterCleanupServiceServer(s *grpc.Server, srv CleanupServiceServer) {
276	s.RegisterService(&_CleanupService_serviceDesc, srv)
277}
278
279func _CleanupService_ApplyBfgObjectMapStream_Handler(srv interface{}, stream grpc.ServerStream) error {
280	return srv.(CleanupServiceServer).ApplyBfgObjectMapStream(&cleanupServiceApplyBfgObjectMapStreamServer{stream})
281}
282
283type CleanupService_ApplyBfgObjectMapStreamServer interface {
284	Send(*ApplyBfgObjectMapStreamResponse) error
285	Recv() (*ApplyBfgObjectMapStreamRequest, error)
286	grpc.ServerStream
287}
288
289type cleanupServiceApplyBfgObjectMapStreamServer struct {
290	grpc.ServerStream
291}
292
293func (x *cleanupServiceApplyBfgObjectMapStreamServer) Send(m *ApplyBfgObjectMapStreamResponse) error {
294	return x.ServerStream.SendMsg(m)
295}
296
297func (x *cleanupServiceApplyBfgObjectMapStreamServer) Recv() (*ApplyBfgObjectMapStreamRequest, error) {
298	m := new(ApplyBfgObjectMapStreamRequest)
299	if err := x.ServerStream.RecvMsg(m); err != nil {
300		return nil, err
301	}
302	return m, nil
303}
304
305var _CleanupService_serviceDesc = grpc.ServiceDesc{
306	ServiceName: "gitaly.CleanupService",
307	HandlerType: (*CleanupServiceServer)(nil),
308	Methods:     []grpc.MethodDesc{},
309	Streams: []grpc.StreamDesc{
310		{
311			StreamName:    "ApplyBfgObjectMapStream",
312			Handler:       _CleanupService_ApplyBfgObjectMapStream_Handler,
313			ServerStreams: true,
314			ClientStreams: true,
315		},
316	},
317	Metadata: "cleanup.proto",
318}
319