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