// Code generated by protoc-gen-go. DO NOT EDIT.
// source: repo_indexer.proto

package pb

import (
	context "context"
	fmt "fmt"
	math "math"

	proto "github.com/golang/protobuf/proto"
	timestamp "github.com/golang/protobuf/ptypes/timestamp"
	wrappers "github.com/golang/protobuf/ptypes/wrappers"
	_ "github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger/options"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type IndexRepoRequest struct {
	// id of repository to index
	RepoId               *wrappers.StringValue `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (m *IndexRepoRequest) Reset()         { *m = IndexRepoRequest{} }
func (m *IndexRepoRequest) String() string { return proto.CompactTextString(m) }
func (*IndexRepoRequest) ProtoMessage()    {}
func (*IndexRepoRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_e135b06a8245a758, []int{0}
}

func (m *IndexRepoRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IndexRepoRequest.Unmarshal(m, b)
}
func (m *IndexRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IndexRepoRequest.Marshal(b, m, deterministic)
}
func (m *IndexRepoRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IndexRepoRequest.Merge(m, src)
}
func (m *IndexRepoRequest) XXX_Size() int {
	return xxx_messageInfo_IndexRepoRequest.Size(m)
}
func (m *IndexRepoRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_IndexRepoRequest.DiscardUnknown(m)
}

var xxx_messageInfo_IndexRepoRequest proto.InternalMessageInfo

func (m *IndexRepoRequest) GetRepoId() *wrappers.StringValue {
	if m != nil {
		return m.RepoId
	}
	return nil
}

type IndexRepoResponse struct {
	// repository event
	RepoEvent *RepoEvent `protobuf:"bytes,1,opt,name=repo_event,json=repoEvent,proto3" json:"repo_event,omitempty"`
	// id of repository indexed
	RepoId               *wrappers.StringValue `protobuf:"bytes,2,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (m *IndexRepoResponse) Reset()         { *m = IndexRepoResponse{} }
func (m *IndexRepoResponse) String() string { return proto.CompactTextString(m) }
func (*IndexRepoResponse) ProtoMessage()    {}
func (*IndexRepoResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_e135b06a8245a758, []int{1}
}

func (m *IndexRepoResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IndexRepoResponse.Unmarshal(m, b)
}
func (m *IndexRepoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IndexRepoResponse.Marshal(b, m, deterministic)
}
func (m *IndexRepoResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IndexRepoResponse.Merge(m, src)
}
func (m *IndexRepoResponse) XXX_Size() int {
	return xxx_messageInfo_IndexRepoResponse.Size(m)
}
func (m *IndexRepoResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_IndexRepoResponse.DiscardUnknown(m)
}

var xxx_messageInfo_IndexRepoResponse proto.InternalMessageInfo

func (m *IndexRepoResponse) GetRepoEvent() *RepoEvent {
	if m != nil {
		return m.RepoEvent
	}
	return nil
}

func (m *IndexRepoResponse) GetRepoId() *wrappers.StringValue {
	if m != nil {
		return m.RepoId
	}
	return nil
}

type RepoEvent struct {
	// repository event id
	RepoEventId *wrappers.StringValue `protobuf:"bytes,1,opt,name=repo_event_id,json=repoEventId,proto3" json:"repo_event_id,omitempty"`
	// repository id
	RepoId *wrappers.StringValue `protobuf:"bytes,2,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// owner path, concat string group_path:user_id
	OwnerPath *wrappers.StringValue `protobuf:"bytes,3,opt,name=owner_path,json=ownerPath,proto3" json:"owner_path,omitempty"`
	// repository event status eg.[failed|successful|working|pending]
	Status *wrappers.StringValue `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// result
	Result *wrappers.StringValue `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	// repository event create time
	CreateTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// record status changed time
	StatusTime *timestamp.Timestamp `protobuf:"bytes,7,opt,name=status_time,json=statusTime,proto3" json:"status_time,omitempty"`
	// owner
	Owner                *wrappers.StringValue `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (m *RepoEvent) Reset()         { *m = RepoEvent{} }
func (m *RepoEvent) String() string { return proto.CompactTextString(m) }
func (*RepoEvent) ProtoMessage()    {}
func (*RepoEvent) Descriptor() ([]byte, []int) {
	return fileDescriptor_e135b06a8245a758, []int{2}
}

func (m *RepoEvent) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RepoEvent.Unmarshal(m, b)
}
func (m *RepoEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RepoEvent.Marshal(b, m, deterministic)
}
func (m *RepoEvent) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RepoEvent.Merge(m, src)
}
func (m *RepoEvent) XXX_Size() int {
	return xxx_messageInfo_RepoEvent.Size(m)
}
func (m *RepoEvent) XXX_DiscardUnknown() {
	xxx_messageInfo_RepoEvent.DiscardUnknown(m)
}

var xxx_messageInfo_RepoEvent proto.InternalMessageInfo

func (m *RepoEvent) GetRepoEventId() *wrappers.StringValue {
	if m != nil {
		return m.RepoEventId
	}
	return nil
}

func (m *RepoEvent) GetRepoId() *wrappers.StringValue {
	if m != nil {
		return m.RepoId
	}
	return nil
}

func (m *RepoEvent) GetOwnerPath() *wrappers.StringValue {
	if m != nil {
		return m.OwnerPath
	}
	return nil
}

func (m *RepoEvent) GetStatus() *wrappers.StringValue {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *RepoEvent) GetResult() *wrappers.StringValue {
	if m != nil {
		return m.Result
	}
	return nil
}

func (m *RepoEvent) GetCreateTime() *timestamp.Timestamp {
	if m != nil {
		return m.CreateTime
	}
	return nil
}

func (m *RepoEvent) GetStatusTime() *timestamp.Timestamp {
	if m != nil {
		return m.StatusTime
	}
	return nil
}

func (m *RepoEvent) GetOwner() *wrappers.StringValue {
	if m != nil {
		return m.Owner
	}
	return nil
}

type DescribeRepoEventsRequest struct {
	// data limit per page, default value 20, max value 200
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// data offset, default 0
	Offset uint32 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	// repository event ids
	RepoEventId []string `protobuf:"bytes,11,rep,name=repo_event_id,json=repoEventId,proto3" json:"repo_event_id,omitempty"`
	// repository ids
	RepoId []string `protobuf:"bytes,12,rep,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// owner
	Owner []string `protobuf:"bytes,13,rep,name=owner,proto3" json:"owner,omitempty"`
	// repository event status eg.[failed|successful|working|pending]
	Status               []string `protobuf:"bytes,14,rep,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DescribeRepoEventsRequest) Reset()         { *m = DescribeRepoEventsRequest{} }
func (m *DescribeRepoEventsRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeRepoEventsRequest) ProtoMessage()    {}
func (*DescribeRepoEventsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_e135b06a8245a758, []int{3}
}

func (m *DescribeRepoEventsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeRepoEventsRequest.Unmarshal(m, b)
}
func (m *DescribeRepoEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeRepoEventsRequest.Marshal(b, m, deterministic)
}
func (m *DescribeRepoEventsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeRepoEventsRequest.Merge(m, src)
}
func (m *DescribeRepoEventsRequest) XXX_Size() int {
	return xxx_messageInfo_DescribeRepoEventsRequest.Size(m)
}
func (m *DescribeRepoEventsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeRepoEventsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeRepoEventsRequest proto.InternalMessageInfo

func (m *DescribeRepoEventsRequest) GetLimit() uint32 {
	if m != nil {
		return m.Limit
	}
	return 0
}

func (m *DescribeRepoEventsRequest) GetOffset() uint32 {
	if m != nil {
		return m.Offset
	}
	return 0
}

func (m *DescribeRepoEventsRequest) GetRepoEventId() []string {
	if m != nil {
		return m.RepoEventId
	}
	return nil
}

func (m *DescribeRepoEventsRequest) GetRepoId() []string {
	if m != nil {
		return m.RepoId
	}
	return nil
}

func (m *DescribeRepoEventsRequest) GetOwner() []string {
	if m != nil {
		return m.Owner
	}
	return nil
}

func (m *DescribeRepoEventsRequest) GetStatus() []string {
	if m != nil {
		return m.Status
	}
	return nil
}

type DescribeRepoEventsResponse struct {
	// total count of repository event
	TotalCount uint32 `protobuf:"varint,1,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// list of repository event
	RepoEventSet         []*RepoEvent `protobuf:"bytes,2,rep,name=repo_event_set,json=repoEventSet,proto3" json:"repo_event_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (m *DescribeRepoEventsResponse) Reset()         { *m = DescribeRepoEventsResponse{} }
func (m *DescribeRepoEventsResponse) String() string { return proto.CompactTextString(m) }
func (*DescribeRepoEventsResponse) ProtoMessage()    {}
func (*DescribeRepoEventsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_e135b06a8245a758, []int{4}
}

func (m *DescribeRepoEventsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeRepoEventsResponse.Unmarshal(m, b)
}
func (m *DescribeRepoEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeRepoEventsResponse.Marshal(b, m, deterministic)
}
func (m *DescribeRepoEventsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeRepoEventsResponse.Merge(m, src)
}
func (m *DescribeRepoEventsResponse) XXX_Size() int {
	return xxx_messageInfo_DescribeRepoEventsResponse.Size(m)
}
func (m *DescribeRepoEventsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeRepoEventsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeRepoEventsResponse proto.InternalMessageInfo

func (m *DescribeRepoEventsResponse) GetTotalCount() uint32 {
	if m != nil {
		return m.TotalCount
	}
	return 0
}

func (m *DescribeRepoEventsResponse) GetRepoEventSet() []*RepoEvent {
	if m != nil {
		return m.RepoEventSet
	}
	return nil
}

func init() {
	proto.RegisterType((*IndexRepoRequest)(nil), "openpitrix.IndexRepoRequest")
	proto.RegisterType((*IndexRepoResponse)(nil), "openpitrix.IndexRepoResponse")
	proto.RegisterType((*RepoEvent)(nil), "openpitrix.RepoEvent")
	proto.RegisterType((*DescribeRepoEventsRequest)(nil), "openpitrix.DescribeRepoEventsRequest")
	proto.RegisterType((*DescribeRepoEventsResponse)(nil), "openpitrix.DescribeRepoEventsResponse")
}

func init() { proto.RegisterFile("repo_indexer.proto", fileDescriptor_e135b06a8245a758) }

var fileDescriptor_e135b06a8245a758 = []byte{
	// 607 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x54, 0xcd, 0x6e, 0xd3, 0x4c,
	0x14, 0x95, 0x93, 0x36, 0xfd, 0x72, 0xd3, 0xf4, 0xa3, 0xa3, 0x96, 0x1a, 0x2b, 0xb4, 0x96, 0x25,
	0x50, 0x85, 0xa8, 0xad, 0x96, 0xb2, 0x21, 0x1b, 0xca, 0x8f, 0x50, 0x76, 0xc8, 0x45, 0x2c, 0xd8,
	0x44, 0x93, 0xe4, 0xd6, 0xb5, 0x94, 0x7a, 0x86, 0x99, 0x71, 0x5b, 0x58, 0x21, 0x24, 0x5e, 0xa0,
	0x48, 0x3c, 0x06, 0x2b, 0xde, 0x84, 0x25, 0x5b, 0x1e, 0x04, 0xcd, 0x8c, 0xed, 0x86, 0x86, 0xa8,
	0x81, 0x95, 0x3d, 0x73, 0xcf, 0xb9, 0xf7, 0xdc, 0xbf, 0x01, 0x22, 0x90, 0xb3, 0x7e, 0x9a, 0x8d,
	0xf0, 0x1c, 0x45, 0xc8, 0x05, 0x53, 0x8c, 0x00, 0xe3, 0x98, 0xf1, 0x54, 0x89, 0xf4, 0xdc, 0xdb,
	0x4c, 0x18, 0x4b, 0xc6, 0x18, 0x19, 0xcb, 0x20, 0x3f, 0x8a, 0xce, 0x04, 0xe5, 0x1c, 0x85, 0xb4,
	0x58, 0x6f, 0xeb, 0xaa, 0x5d, 0xa5, 0x27, 0x28, 0x15, 0x3d, 0xe1, 0x05, 0xa0, 0x53, 0x00, 0x28,
	0x4f, 0x23, 0x9a, 0x65, 0x4c, 0x51, 0x95, 0xb2, 0xac, 0xa4, 0xdf, 0x37, 0x9f, 0xe1, 0x4e, 0x82,
	0xd9, 0x8e, 0x3c, 0xa3, 0x49, 0x82, 0x22, 0x62, 0xdc, 0x20, 0xa6, 0xd1, 0x41, 0x0f, 0x6e, 0xf4,
	0xb4, 0xd2, 0x18, 0x39, 0x8b, 0xf1, 0x6d, 0x8e, 0x52, 0x91, 0x87, 0xb0, 0x64, 0x53, 0x18, 0xb9,
	0x8e, 0xef, 0x6c, 0xb7, 0xf6, 0x3a, 0xa1, 0x8d, 0x18, 0x96, 0x92, 0xc2, 0x43, 0x25, 0xd2, 0x2c,
	0x79, 0x4d, 0xc7, 0x39, 0xc6, 0x0d, 0x0d, 0xee, 0x8d, 0x82, 0x0f, 0x0e, 0xac, 0x4e, 0xf8, 0x92,
	0x9c, 0x65, 0x12, 0xc9, 0x3e, 0x80, 0x71, 0x86, 0xa7, 0x98, 0xa9, 0xc2, 0xdf, 0x7a, 0x78, 0x59,
	0x8e, 0x50, 0xa3, 0x9f, 0x6b, 0x63, 0xdc, 0x14, 0xe5, 0xef, 0xa4, 0x84, 0xda, 0x5f, 0x48, 0xf8,
	0x51, 0x87, 0x66, 0xe5, 0x8f, 0x3c, 0x86, 0xf6, 0x65, 0xe8, 0x79, 0xb3, 0x69, 0x55, 0x22, 0x7a,
	0xa3, 0x7f, 0x94, 0x41, 0xba, 0x00, 0xec, 0x2c, 0x43, 0xd1, 0xe7, 0x54, 0x1d, 0xbb, 0xf5, 0x39,
	0x98, 0x4d, 0x83, 0x7f, 0x49, 0xd5, 0x31, 0xd9, 0x87, 0x86, 0x54, 0x54, 0xe5, 0xd2, 0x5d, 0x98,
	0x27, 0xa4, 0xc5, 0x6a, 0x96, 0x40, 0x99, 0x8f, 0x95, 0xbb, 0x38, 0x9f, 0x50, 0x8d, 0x25, 0x5d,
	0x68, 0x0d, 0x05, 0x52, 0x85, 0x7d, 0x3d, 0x63, 0x6e, 0xc3, 0x50, 0xbd, 0x29, 0xea, 0xab, 0x72,
	0x00, 0x63, 0xb0, 0x70, 0x7d, 0xa1, 0xc9, 0x36, 0xb8, 0x25, 0x2f, 0x5d, 0x4f, 0xb6, 0x70, 0x43,
	0xde, 0x83, 0x45, 0x93, 0xb2, 0xfb, 0xdf, 0x1c, 0x72, 0x2d, 0x34, 0xf8, 0xe6, 0xc0, 0xad, 0x67,
	0x28, 0x87, 0x22, 0x1d, 0x60, 0xd5, 0x65, 0x59, 0x4e, 0xed, 0x1a, 0x2c, 0x8e, 0xd3, 0x93, 0x54,
	0x99, 0xb2, 0xb5, 0x63, 0x7b, 0x20, 0x37, 0xa1, 0xc1, 0x8e, 0x8e, 0x24, 0xda, 0xba, 0xb4, 0xe3,
	0xe2, 0x44, 0x82, 0xab, 0xb3, 0xd1, 0xf2, 0xeb, 0xdb, 0xcd, 0xdf, 0xbb, 0xbf, 0x71, 0xd9, 0xfd,
	0x65, 0x63, 0x2d, 0xfb, 0xbb, 0x56, 0x8a, 0x6f, 0x9b, 0x6b, 0x7b, 0xd0, 0xa1, 0x8a, 0xc6, 0xad,
	0x58, 0xb4, 0x3d, 0x05, 0xef, 0xc1, 0xfb, 0x93, 0xea, 0x62, 0x3f, 0xb6, 0xa0, 0xa5, 0x98, 0xa2,
	0xe3, 0xfe, 0x90, 0xe5, 0xc5, 0x82, 0xb4, 0x63, 0x30, 0x57, 0x4f, 0xf5, 0x0d, 0xe9, 0xc2, 0xca,
	0x84, 0x52, 0x9d, 0x49, 0xcd, 0xaf, 0xcf, 0x5e, 0xa2, 0xe5, 0x2a, 0x83, 0x43, 0x54, 0x7b, 0x5f,
	0x6b, 0xd0, 0xd2, 0xb6, 0x9e, 0x7d, 0x8d, 0xc8, 0x27, 0x07, 0x9a, 0xd5, 0x8e, 0x92, 0xce, 0xa4,
	0x8b, 0xab, 0xcf, 0x80, 0x77, 0x7b, 0x86, 0xd5, 0x0a, 0x0f, 0xba, 0x17, 0x07, 0x9b, 0xa4, 0x73,
	0xa8, 0xa8, 0x50, 0xbe, 0x79, 0xec, 0x7c, 0x1d, 0x59, 0xa6, 0x8a, 0x89, 0x77, 0xbe, 0x11, 0xfb,
	0xf1, 0xfb, 0xcf, 0xcf, 0xb5, 0xb5, 0xe0, 0xff, 0xe8, 0x74, 0x37, 0x32, 0xb6, 0xc8, 0xe0, 0x1e,
	0x39, 0xf7, 0xc8, 0x17, 0x07, 0xc8, 0x74, 0x51, 0xc8, 0x9d, 0xc9, 0x90, 0x33, 0x5b, 0xed, 0xdd,
	0xbd, 0x0e, 0x56, 0x48, 0xdc, 0xbd, 0x38, 0xd8, 0x20, 0xeb, 0x2f, 0x50, 0x4d, 0x49, 0x93, 0x46,
	0xdb, 0x2a, 0xa9, 0xb4, 0xd9, 0xf2, 0xca, 0x27, 0x0b, 0x6f, 0x6a, 0x7c, 0x30, 0x68, 0x98, 0x31,
	0x7c, 0xf0, 0x2b, 0x00, 0x00, 0xff, 0xff, 0x44, 0x04, 0xf0, 0xba, 0xcb, 0x05, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// RepoIndexerClient is the client API for RepoIndexer service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type RepoIndexerClient interface {
	// Start index repository event
	IndexRepo(ctx context.Context, in *IndexRepoRequest, opts ...grpc.CallOption) (*IndexRepoResponse, error)
	// Get repository events
	DescribeRepoEvents(ctx context.Context, in *DescribeRepoEventsRequest, opts ...grpc.CallOption) (*DescribeRepoEventsResponse, error)
}

type repoIndexerClient struct {
	cc *grpc.ClientConn
}

func NewRepoIndexerClient(cc *grpc.ClientConn) RepoIndexerClient {
	return &repoIndexerClient{cc}
}

func (c *repoIndexerClient) IndexRepo(ctx context.Context, in *IndexRepoRequest, opts ...grpc.CallOption) (*IndexRepoResponse, error) {
	out := new(IndexRepoResponse)
	err := c.cc.Invoke(ctx, "/openpitrix.RepoIndexer/IndexRepo", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *repoIndexerClient) DescribeRepoEvents(ctx context.Context, in *DescribeRepoEventsRequest, opts ...grpc.CallOption) (*DescribeRepoEventsResponse, error) {
	out := new(DescribeRepoEventsResponse)
	err := c.cc.Invoke(ctx, "/openpitrix.RepoIndexer/DescribeRepoEvents", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// RepoIndexerServer is the server API for RepoIndexer service.
type RepoIndexerServer interface {
	// Start index repository event
	IndexRepo(context.Context, *IndexRepoRequest) (*IndexRepoResponse, error)
	// Get repository events
	DescribeRepoEvents(context.Context, *DescribeRepoEventsRequest) (*DescribeRepoEventsResponse, error)
}

// UnimplementedRepoIndexerServer can be embedded to have forward compatible implementations.
type UnimplementedRepoIndexerServer struct {
}

func (*UnimplementedRepoIndexerServer) IndexRepo(ctx context.Context, req *IndexRepoRequest) (*IndexRepoResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IndexRepo not implemented")
}
func (*UnimplementedRepoIndexerServer) DescribeRepoEvents(ctx context.Context, req *DescribeRepoEventsRequest) (*DescribeRepoEventsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeRepoEvents not implemented")
}

func RegisterRepoIndexerServer(s *grpc.Server, srv RepoIndexerServer) {
	s.RegisterService(&_RepoIndexer_serviceDesc, srv)
}

func _RepoIndexer_IndexRepo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IndexRepoRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(RepoIndexerServer).IndexRepo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/openpitrix.RepoIndexer/IndexRepo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(RepoIndexerServer).IndexRepo(ctx, req.(*IndexRepoRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _RepoIndexer_DescribeRepoEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeRepoEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(RepoIndexerServer).DescribeRepoEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/openpitrix.RepoIndexer/DescribeRepoEvents",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(RepoIndexerServer).DescribeRepoEvents(ctx, req.(*DescribeRepoEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _RepoIndexer_serviceDesc = grpc.ServiceDesc{
	ServiceName: "openpitrix.RepoIndexer",
	HandlerType: (*RepoIndexerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IndexRepo",
			Handler:    _RepoIndexer_IndexRepo_Handler,
		},
		{
			MethodName: "DescribeRepoEvents",
			Handler:    _RepoIndexer_DescribeRepoEvents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "repo_indexer.proto",
}