// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        (unknown)
// source: runtime/v1/bulk_ingest.proto

package runtimev1

import (
	v1 "github.com/pingcap-inc/nexuscrm-contract/wire-go/gen/common/v1"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

type BulkIngestOperation int32

const (
	BulkIngestOperation_BULK_INGEST_OPERATION_UNSPECIFIED BulkIngestOperation = 0
	BulkIngestOperation_BULK_INGEST_OPERATION_INSERT      BulkIngestOperation = 1
	BulkIngestOperation_BULK_INGEST_OPERATION_UPDATE      BulkIngestOperation = 2
	BulkIngestOperation_BULK_INGEST_OPERATION_UPSERT      BulkIngestOperation = 3
	BulkIngestOperation_BULK_INGEST_OPERATION_DELETE      BulkIngestOperation = 4
)

// Enum value maps for BulkIngestOperation.
var (
	BulkIngestOperation_name = map[int32]string{
		0: "BULK_INGEST_OPERATION_UNSPECIFIED",
		1: "BULK_INGEST_OPERATION_INSERT",
		2: "BULK_INGEST_OPERATION_UPDATE",
		3: "BULK_INGEST_OPERATION_UPSERT",
		4: "BULK_INGEST_OPERATION_DELETE",
	}
	BulkIngestOperation_value = map[string]int32{
		"BULK_INGEST_OPERATION_UNSPECIFIED": 0,
		"BULK_INGEST_OPERATION_INSERT":      1,
		"BULK_INGEST_OPERATION_UPDATE":      2,
		"BULK_INGEST_OPERATION_UPSERT":      3,
		"BULK_INGEST_OPERATION_DELETE":      4,
	}
)

func (x BulkIngestOperation) Enum() *BulkIngestOperation {
	p := new(BulkIngestOperation)
	*p = x
	return p
}

func (x BulkIngestOperation) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (BulkIngestOperation) Descriptor() protoreflect.EnumDescriptor {
	return file_runtime_v1_bulk_ingest_proto_enumTypes[0].Descriptor()
}

func (BulkIngestOperation) Type() protoreflect.EnumType {
	return &file_runtime_v1_bulk_ingest_proto_enumTypes[0]
}

func (x BulkIngestOperation) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use BulkIngestOperation.Descriptor instead.
func (BulkIngestOperation) EnumDescriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{0}
}

type BulkIngestState int32

const (
	BulkIngestState_BULK_INGEST_STATE_UNSPECIFIED     BulkIngestState = 0
	BulkIngestState_BULK_INGEST_STATE_OPEN            BulkIngestState = 1
	BulkIngestState_BULK_INGEST_STATE_UPLOAD_COMPLETE BulkIngestState = 2
	BulkIngestState_BULK_INGEST_STATE_IN_PROGRESS     BulkIngestState = 3
	BulkIngestState_BULK_INGEST_STATE_COMPLETE        BulkIngestState = 4
	BulkIngestState_BULK_INGEST_STATE_FAILED          BulkIngestState = 5
	BulkIngestState_BULK_INGEST_STATE_ABORTED         BulkIngestState = 6
)

// Enum value maps for BulkIngestState.
var (
	BulkIngestState_name = map[int32]string{
		0: "BULK_INGEST_STATE_UNSPECIFIED",
		1: "BULK_INGEST_STATE_OPEN",
		2: "BULK_INGEST_STATE_UPLOAD_COMPLETE",
		3: "BULK_INGEST_STATE_IN_PROGRESS",
		4: "BULK_INGEST_STATE_COMPLETE",
		5: "BULK_INGEST_STATE_FAILED",
		6: "BULK_INGEST_STATE_ABORTED",
	}
	BulkIngestState_value = map[string]int32{
		"BULK_INGEST_STATE_UNSPECIFIED":     0,
		"BULK_INGEST_STATE_OPEN":            1,
		"BULK_INGEST_STATE_UPLOAD_COMPLETE": 2,
		"BULK_INGEST_STATE_IN_PROGRESS":     3,
		"BULK_INGEST_STATE_COMPLETE":        4,
		"BULK_INGEST_STATE_FAILED":          5,
		"BULK_INGEST_STATE_ABORTED":         6,
	}
)

func (x BulkIngestState) Enum() *BulkIngestState {
	p := new(BulkIngestState)
	*p = x
	return p
}

func (x BulkIngestState) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (BulkIngestState) Descriptor() protoreflect.EnumDescriptor {
	return file_runtime_v1_bulk_ingest_proto_enumTypes[1].Descriptor()
}

func (BulkIngestState) Type() protoreflect.EnumType {
	return &file_runtime_v1_bulk_ingest_proto_enumTypes[1]
}

func (x BulkIngestState) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use BulkIngestState.Descriptor instead.
func (BulkIngestState) EnumDescriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{1}
}

type BulkIngestFailureCode int32

const (
	BulkIngestFailureCode_BULK_INGEST_FAILURE_CODE_UNSPECIFIED       BulkIngestFailureCode = 0
	BulkIngestFailureCode_BULK_INGEST_FAILURE_CODE_PROCESSING_FAILED BulkIngestFailureCode = 1
)

// Enum value maps for BulkIngestFailureCode.
var (
	BulkIngestFailureCode_name = map[int32]string{
		0: "BULK_INGEST_FAILURE_CODE_UNSPECIFIED",
		1: "BULK_INGEST_FAILURE_CODE_PROCESSING_FAILED",
	}
	BulkIngestFailureCode_value = map[string]int32{
		"BULK_INGEST_FAILURE_CODE_UNSPECIFIED":       0,
		"BULK_INGEST_FAILURE_CODE_PROCESSING_FAILED": 1,
	}
)

func (x BulkIngestFailureCode) Enum() *BulkIngestFailureCode {
	p := new(BulkIngestFailureCode)
	*p = x
	return p
}

func (x BulkIngestFailureCode) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (BulkIngestFailureCode) Descriptor() protoreflect.EnumDescriptor {
	return file_runtime_v1_bulk_ingest_proto_enumTypes[2].Descriptor()
}

func (BulkIngestFailureCode) Type() protoreflect.EnumType {
	return &file_runtime_v1_bulk_ingest_proto_enumTypes[2]
}

func (x BulkIngestFailureCode) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use BulkIngestFailureCode.Descriptor instead.
func (BulkIngestFailureCode) EnumDescriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{2}
}

type BulkIngestJob struct {
	state                  protoimpl.MessageState `protogen:"open.v1"`
	Id                     string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ObjectId               string                 `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	Operation              BulkIngestOperation    `protobuf:"varint,3,opt,name=operation,proto3,enum=nexuscrm.runtime.v1.BulkIngestOperation" json:"operation,omitempty"`
	State                  BulkIngestState        `protobuf:"varint,4,opt,name=state,proto3,enum=nexuscrm.runtime.v1.BulkIngestState" json:"state,omitempty"`
	CreatedById            string                 `protobuf:"bytes,5,opt,name=created_by_id,json=createdById,proto3" json:"created_by_id,omitempty"`
	CreatedAt              string                 `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ModifiedAt             string                 `protobuf:"bytes,7,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	FailureCode            BulkIngestFailureCode  `protobuf:"varint,8,opt,name=failure_code,json=failureCode,proto3,enum=nexuscrm.runtime.v1.BulkIngestFailureCode" json:"failure_code,omitempty"`
	ExternalIdFieldName    string                 `protobuf:"bytes,9,opt,name=external_id_field_name,json=externalIdFieldName,proto3" json:"external_id_field_name,omitempty"`
	NumberRecordsProcessed uint64                 `protobuf:"varint,10,opt,name=number_records_processed,json=numberRecordsProcessed,proto3" json:"number_records_processed,omitempty"`
	NumberRecordsFailed    uint64                 `protobuf:"varint,11,opt,name=number_records_failed,json=numberRecordsFailed,proto3" json:"number_records_failed,omitempty"`
	TotalProcessingTime    uint64                 `protobuf:"varint,12,opt,name=total_processing_time,json=totalProcessingTime,proto3" json:"total_processing_time,omitempty"`
	ActiveProcessingTime   uint64                 `protobuf:"varint,13,opt,name=active_processing_time,json=activeProcessingTime,proto3" json:"active_processing_time,omitempty"`
	ClientVersion          float64                `protobuf:"fixed64,14,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	unknownFields          protoimpl.UnknownFields
	sizeCache              protoimpl.SizeCache
}

func (x *BulkIngestJob) Reset() {
	*x = BulkIngestJob{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BulkIngestJob) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BulkIngestJob) ProtoMessage() {}

func (x *BulkIngestJob) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BulkIngestJob.ProtoReflect.Descriptor instead.
func (*BulkIngestJob) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{0}
}

func (x *BulkIngestJob) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *BulkIngestJob) GetObjectId() string {
	if x != nil {
		return x.ObjectId
	}
	return ""
}

func (x *BulkIngestJob) GetOperation() BulkIngestOperation {
	if x != nil {
		return x.Operation
	}
	return BulkIngestOperation_BULK_INGEST_OPERATION_UNSPECIFIED
}

func (x *BulkIngestJob) GetState() BulkIngestState {
	if x != nil {
		return x.State
	}
	return BulkIngestState_BULK_INGEST_STATE_UNSPECIFIED
}

func (x *BulkIngestJob) GetCreatedById() string {
	if x != nil {
		return x.CreatedById
	}
	return ""
}

func (x *BulkIngestJob) GetCreatedAt() string {
	if x != nil {
		return x.CreatedAt
	}
	return ""
}

func (x *BulkIngestJob) GetModifiedAt() string {
	if x != nil {
		return x.ModifiedAt
	}
	return ""
}

func (x *BulkIngestJob) GetFailureCode() BulkIngestFailureCode {
	if x != nil {
		return x.FailureCode
	}
	return BulkIngestFailureCode_BULK_INGEST_FAILURE_CODE_UNSPECIFIED
}

func (x *BulkIngestJob) GetExternalIdFieldName() string {
	if x != nil {
		return x.ExternalIdFieldName
	}
	return ""
}

func (x *BulkIngestJob) GetNumberRecordsProcessed() uint64 {
	if x != nil {
		return x.NumberRecordsProcessed
	}
	return 0
}

func (x *BulkIngestJob) GetNumberRecordsFailed() uint64 {
	if x != nil {
		return x.NumberRecordsFailed
	}
	return 0
}

func (x *BulkIngestJob) GetTotalProcessingTime() uint64 {
	if x != nil {
		return x.TotalProcessingTime
	}
	return 0
}

func (x *BulkIngestJob) GetActiveProcessingTime() uint64 {
	if x != nil {
		return x.ActiveProcessingTime
	}
	return 0
}

func (x *BulkIngestJob) GetClientVersion() float64 {
	if x != nil {
		return x.ClientVersion
	}
	return 0
}

type CreateBulkIngestJobRequest struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	ObjectId            string                 `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	Operation           BulkIngestOperation    `protobuf:"varint,2,opt,name=operation,proto3,enum=nexuscrm.runtime.v1.BulkIngestOperation" json:"operation,omitempty"`
	ExternalIdFieldName string                 `protobuf:"bytes,3,opt,name=external_id_field_name,json=externalIdFieldName,proto3" json:"external_id_field_name,omitempty"`
	ClientVersion       float64                `protobuf:"fixed64,4,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

func (x *CreateBulkIngestJobRequest) Reset() {
	*x = CreateBulkIngestJobRequest{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreateBulkIngestJobRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreateBulkIngestJobRequest) ProtoMessage() {}

func (x *CreateBulkIngestJobRequest) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CreateBulkIngestJobRequest.ProtoReflect.Descriptor instead.
func (*CreateBulkIngestJobRequest) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{1}
}

func (x *CreateBulkIngestJobRequest) GetObjectId() string {
	if x != nil {
		return x.ObjectId
	}
	return ""
}

func (x *CreateBulkIngestJobRequest) GetOperation() BulkIngestOperation {
	if x != nil {
		return x.Operation
	}
	return BulkIngestOperation_BULK_INGEST_OPERATION_UNSPECIFIED
}

func (x *CreateBulkIngestJobRequest) GetExternalIdFieldName() string {
	if x != nil {
		return x.ExternalIdFieldName
	}
	return ""
}

func (x *CreateBulkIngestJobRequest) GetClientVersion() float64 {
	if x != nil {
		return x.ClientVersion
	}
	return 0
}

type CreateBulkIngestJobResponse struct {
	state         protoimpl.MessageState  `protogen:"open.v1"`
	Job           *BulkIngestJob          `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Receipts      *v1.ConsistencyReceipts `protobuf:"bytes,2,opt,name=receipts,proto3" json:"receipts,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CreateBulkIngestJobResponse) Reset() {
	*x = CreateBulkIngestJobResponse{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreateBulkIngestJobResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreateBulkIngestJobResponse) ProtoMessage() {}

func (x *CreateBulkIngestJobResponse) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CreateBulkIngestJobResponse.ProtoReflect.Descriptor instead.
func (*CreateBulkIngestJobResponse) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{2}
}

func (x *CreateBulkIngestJobResponse) GetJob() *BulkIngestJob {
	if x != nil {
		return x.Job
	}
	return nil
}

func (x *CreateBulkIngestJobResponse) GetReceipts() *v1.ConsistencyReceipts {
	if x != nil {
		return x.Receipts
	}
	return nil
}

type ReadBulkIngestJobRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	JobId         string                 `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReadBulkIngestJobRequest) Reset() {
	*x = ReadBulkIngestJobRequest{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReadBulkIngestJobRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReadBulkIngestJobRequest) ProtoMessage() {}

func (x *ReadBulkIngestJobRequest) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ReadBulkIngestJobRequest.ProtoReflect.Descriptor instead.
func (*ReadBulkIngestJobRequest) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{3}
}

func (x *ReadBulkIngestJobRequest) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

type ReadBulkIngestJobResponse struct {
	state         protoimpl.MessageState  `protogen:"open.v1"`
	Job           *BulkIngestJob          `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Receipts      *v1.ConsistencyReceipts `protobuf:"bytes,2,opt,name=receipts,proto3" json:"receipts,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReadBulkIngestJobResponse) Reset() {
	*x = ReadBulkIngestJobResponse{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReadBulkIngestJobResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReadBulkIngestJobResponse) ProtoMessage() {}

func (x *ReadBulkIngestJobResponse) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ReadBulkIngestJobResponse.ProtoReflect.Descriptor instead.
func (*ReadBulkIngestJobResponse) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{4}
}

func (x *ReadBulkIngestJobResponse) GetJob() *BulkIngestJob {
	if x != nil {
		return x.Job
	}
	return nil
}

func (x *ReadBulkIngestJobResponse) GetReceipts() *v1.ConsistencyReceipts {
	if x != nil {
		return x.Receipts
	}
	return nil
}

type CloseBulkIngestJobRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	JobId         string                 `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	State         BulkIngestState        `protobuf:"varint,2,opt,name=state,proto3,enum=nexuscrm.runtime.v1.BulkIngestState" json:"state,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CloseBulkIngestJobRequest) Reset() {
	*x = CloseBulkIngestJobRequest{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CloseBulkIngestJobRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CloseBulkIngestJobRequest) ProtoMessage() {}

func (x *CloseBulkIngestJobRequest) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CloseBulkIngestJobRequest.ProtoReflect.Descriptor instead.
func (*CloseBulkIngestJobRequest) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{5}
}

func (x *CloseBulkIngestJobRequest) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *CloseBulkIngestJobRequest) GetState() BulkIngestState {
	if x != nil {
		return x.State
	}
	return BulkIngestState_BULK_INGEST_STATE_UNSPECIFIED
}

type CloseBulkIngestJobResponse struct {
	state         protoimpl.MessageState  `protogen:"open.v1"`
	Job           *BulkIngestJob          `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Receipts      *v1.ConsistencyReceipts `protobuf:"bytes,2,opt,name=receipts,proto3" json:"receipts,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CloseBulkIngestJobResponse) Reset() {
	*x = CloseBulkIngestJobResponse{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CloseBulkIngestJobResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CloseBulkIngestJobResponse) ProtoMessage() {}

func (x *CloseBulkIngestJobResponse) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CloseBulkIngestJobResponse.ProtoReflect.Descriptor instead.
func (*CloseBulkIngestJobResponse) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{6}
}

func (x *CloseBulkIngestJobResponse) GetJob() *BulkIngestJob {
	if x != nil {
		return x.Job
	}
	return nil
}

func (x *CloseBulkIngestJobResponse) GetReceipts() *v1.ConsistencyReceipts {
	if x != nil {
		return x.Receipts
	}
	return nil
}

type UploadBulkIngestDataHeader struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	JobId         string                 `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ContentLength *uint64                `protobuf:"varint,2,opt,name=content_length,json=contentLength,proto3,oneof" json:"content_length,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *UploadBulkIngestDataHeader) Reset() {
	*x = UploadBulkIngestDataHeader{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UploadBulkIngestDataHeader) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UploadBulkIngestDataHeader) ProtoMessage() {}

func (x *UploadBulkIngestDataHeader) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use UploadBulkIngestDataHeader.ProtoReflect.Descriptor instead.
func (*UploadBulkIngestDataHeader) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{7}
}

func (x *UploadBulkIngestDataHeader) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *UploadBulkIngestDataHeader) GetContentLength() uint64 {
	if x != nil && x.ContentLength != nil {
		return *x.ContentLength
	}
	return 0
}

type UploadBulkIngestDataRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Value:
	//
	//	*UploadBulkIngestDataRequest_Header
	//	*UploadBulkIngestDataRequest_Data
	Value         isUploadBulkIngestDataRequest_Value `protobuf_oneof:"value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *UploadBulkIngestDataRequest) Reset() {
	*x = UploadBulkIngestDataRequest{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UploadBulkIngestDataRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UploadBulkIngestDataRequest) ProtoMessage() {}

func (x *UploadBulkIngestDataRequest) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use UploadBulkIngestDataRequest.ProtoReflect.Descriptor instead.
func (*UploadBulkIngestDataRequest) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{8}
}

func (x *UploadBulkIngestDataRequest) GetValue() isUploadBulkIngestDataRequest_Value {
	if x != nil {
		return x.Value
	}
	return nil
}

func (x *UploadBulkIngestDataRequest) GetHeader() *UploadBulkIngestDataHeader {
	if x != nil {
		if x, ok := x.Value.(*UploadBulkIngestDataRequest_Header); ok {
			return x.Header
		}
	}
	return nil
}

func (x *UploadBulkIngestDataRequest) GetData() []byte {
	if x != nil {
		if x, ok := x.Value.(*UploadBulkIngestDataRequest_Data); ok {
			return x.Data
		}
	}
	return nil
}

type isUploadBulkIngestDataRequest_Value interface {
	isUploadBulkIngestDataRequest_Value()
}

type UploadBulkIngestDataRequest_Header struct {
	Header *UploadBulkIngestDataHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type UploadBulkIngestDataRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

func (*UploadBulkIngestDataRequest_Header) isUploadBulkIngestDataRequest_Value() {}

func (*UploadBulkIngestDataRequest_Data) isUploadBulkIngestDataRequest_Value() {}

type UploadBulkIngestDataResponse struct {
	state         protoimpl.MessageState  `protogen:"open.v1"`
	JobId         string                  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Receipts      *v1.ConsistencyReceipts `protobuf:"bytes,2,opt,name=receipts,proto3" json:"receipts,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *UploadBulkIngestDataResponse) Reset() {
	*x = UploadBulkIngestDataResponse{}
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UploadBulkIngestDataResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UploadBulkIngestDataResponse) ProtoMessage() {}

func (x *UploadBulkIngestDataResponse) ProtoReflect() protoreflect.Message {
	mi := &file_runtime_v1_bulk_ingest_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use UploadBulkIngestDataResponse.ProtoReflect.Descriptor instead.
func (*UploadBulkIngestDataResponse) Descriptor() ([]byte, []int) {
	return file_runtime_v1_bulk_ingest_proto_rawDescGZIP(), []int{9}
}

func (x *UploadBulkIngestDataResponse) GetJobId() string {
	if x != nil {
		return x.JobId
	}
	return ""
}

func (x *UploadBulkIngestDataResponse) GetReceipts() *v1.ConsistencyReceipts {
	if x != nil {
		return x.Receipts
	}
	return nil
}

var File_runtime_v1_bulk_ingest_proto protoreflect.FileDescriptor

const file_runtime_v1_bulk_ingest_proto_rawDesc = "" +
	"\n" +
	"\x1cruntime/v1/bulk_ingest.proto\x12\x13nexuscrm.runtime.v1\x1a\x16common/v1/common.proto\"\xa7\x05\n" +
	"\rBulkIngestJob\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x1b\n" +
	"\tobject_id\x18\x02 \x01(\tR\bobjectId\x12F\n" +
	"\toperation\x18\x03 \x01(\x0e2(.nexuscrm.runtime.v1.BulkIngestOperationR\toperation\x12:\n" +
	"\x05state\x18\x04 \x01(\x0e2$.nexuscrm.runtime.v1.BulkIngestStateR\x05state\x12\"\n" +
	"\rcreated_by_id\x18\x05 \x01(\tR\vcreatedById\x12\x1d\n" +
	"\n" +
	"created_at\x18\x06 \x01(\tR\tcreatedAt\x12\x1f\n" +
	"\vmodified_at\x18\a \x01(\tR\n" +
	"modifiedAt\x12M\n" +
	"\ffailure_code\x18\b \x01(\x0e2*.nexuscrm.runtime.v1.BulkIngestFailureCodeR\vfailureCode\x123\n" +
	"\x16external_id_field_name\x18\t \x01(\tR\x13externalIdFieldName\x128\n" +
	"\x18number_records_processed\x18\n" +
	" \x01(\x04R\x16numberRecordsProcessed\x122\n" +
	"\x15number_records_failed\x18\v \x01(\x04R\x13numberRecordsFailed\x122\n" +
	"\x15total_processing_time\x18\f \x01(\x04R\x13totalProcessingTime\x124\n" +
	"\x16active_processing_time\x18\r \x01(\x04R\x14activeProcessingTime\x12%\n" +
	"\x0eclient_version\x18\x0e \x01(\x01R\rclientVersion\"\xdd\x01\n" +
	"\x1aCreateBulkIngestJobRequest\x12\x1b\n" +
	"\tobject_id\x18\x01 \x01(\tR\bobjectId\x12F\n" +
	"\toperation\x18\x02 \x01(\x0e2(.nexuscrm.runtime.v1.BulkIngestOperationR\toperation\x123\n" +
	"\x16external_id_field_name\x18\x03 \x01(\tR\x13externalIdFieldName\x12%\n" +
	"\x0eclient_version\x18\x04 \x01(\x01R\rclientVersion\"\x98\x01\n" +
	"\x1bCreateBulkIngestJobResponse\x124\n" +
	"\x03job\x18\x01 \x01(\v2\".nexuscrm.runtime.v1.BulkIngestJobR\x03job\x12C\n" +
	"\breceipts\x18\x02 \x01(\v2'.nexuscrm.common.v1.ConsistencyReceiptsR\breceipts\"1\n" +
	"\x18ReadBulkIngestJobRequest\x12\x15\n" +
	"\x06job_id\x18\x01 \x01(\tR\x05jobId\"\x96\x01\n" +
	"\x19ReadBulkIngestJobResponse\x124\n" +
	"\x03job\x18\x01 \x01(\v2\".nexuscrm.runtime.v1.BulkIngestJobR\x03job\x12C\n" +
	"\breceipts\x18\x02 \x01(\v2'.nexuscrm.common.v1.ConsistencyReceiptsR\breceipts\"n\n" +
	"\x19CloseBulkIngestJobRequest\x12\x15\n" +
	"\x06job_id\x18\x01 \x01(\tR\x05jobId\x12:\n" +
	"\x05state\x18\x02 \x01(\x0e2$.nexuscrm.runtime.v1.BulkIngestStateR\x05state\"\x97\x01\n" +
	"\x1aCloseBulkIngestJobResponse\x124\n" +
	"\x03job\x18\x01 \x01(\v2\".nexuscrm.runtime.v1.BulkIngestJobR\x03job\x12C\n" +
	"\breceipts\x18\x02 \x01(\v2'.nexuscrm.common.v1.ConsistencyReceiptsR\breceipts\"r\n" +
	"\x1aUploadBulkIngestDataHeader\x12\x15\n" +
	"\x06job_id\x18\x01 \x01(\tR\x05jobId\x12*\n" +
	"\x0econtent_length\x18\x02 \x01(\x04H\x00R\rcontentLength\x88\x01\x01B\x11\n" +
	"\x0f_content_length\"\x87\x01\n" +
	"\x1bUploadBulkIngestDataRequest\x12I\n" +
	"\x06header\x18\x01 \x01(\v2/.nexuscrm.runtime.v1.UploadBulkIngestDataHeaderH\x00R\x06header\x12\x14\n" +
	"\x04data\x18\x02 \x01(\fH\x00R\x04dataB\a\n" +
	"\x05value\"z\n" +
	"\x1cUploadBulkIngestDataResponse\x12\x15\n" +
	"\x06job_id\x18\x01 \x01(\tR\x05jobId\x12C\n" +
	"\breceipts\x18\x02 \x01(\v2'.nexuscrm.common.v1.ConsistencyReceiptsR\breceipts*\xc4\x01\n" +
	"\x13BulkIngestOperation\x12%\n" +
	"!BULK_INGEST_OPERATION_UNSPECIFIED\x10\x00\x12 \n" +
	"\x1cBULK_INGEST_OPERATION_INSERT\x10\x01\x12 \n" +
	"\x1cBULK_INGEST_OPERATION_UPDATE\x10\x02\x12 \n" +
	"\x1cBULK_INGEST_OPERATION_UPSERT\x10\x03\x12 \n" +
	"\x1cBULK_INGEST_OPERATION_DELETE\x10\x04*\xf7\x01\n" +
	"\x0fBulkIngestState\x12!\n" +
	"\x1dBULK_INGEST_STATE_UNSPECIFIED\x10\x00\x12\x1a\n" +
	"\x16BULK_INGEST_STATE_OPEN\x10\x01\x12%\n" +
	"!BULK_INGEST_STATE_UPLOAD_COMPLETE\x10\x02\x12!\n" +
	"\x1dBULK_INGEST_STATE_IN_PROGRESS\x10\x03\x12\x1e\n" +
	"\x1aBULK_INGEST_STATE_COMPLETE\x10\x04\x12\x1c\n" +
	"\x18BULK_INGEST_STATE_FAILED\x10\x05\x12\x1d\n" +
	"\x19BULK_INGEST_STATE_ABORTED\x10\x06*q\n" +
	"\x15BulkIngestFailureCode\x12(\n" +
	"$BULK_INGEST_FAILURE_CODE_UNSPECIFIED\x10\x00\x12.\n" +
	"*BULK_INGEST_FAILURE_CODE_PROCESSING_FAILED\x10\x012\xf7\x03\n" +
	"\x11BulkIngestService\x12x\n" +
	"\x13CreateBulkIngestJob\x12/.nexuscrm.runtime.v1.CreateBulkIngestJobRequest\x1a0.nexuscrm.runtime.v1.CreateBulkIngestJobResponse\x12r\n" +
	"\x11ReadBulkIngestJob\x12-.nexuscrm.runtime.v1.ReadBulkIngestJobRequest\x1a..nexuscrm.runtime.v1.ReadBulkIngestJobResponse\x12u\n" +
	"\x12CloseBulkIngestJob\x12..nexuscrm.runtime.v1.CloseBulkIngestJobRequest\x1a/.nexuscrm.runtime.v1.CloseBulkIngestJobResponse\x12}\n" +
	"\x14UploadBulkIngestData\x120.nexuscrm.runtime.v1.UploadBulkIngestDataRequest\x1a1.nexuscrm.runtime.v1.UploadBulkIngestDataResponse(\x01BKZIgithub.com/pingcap-inc/nexuscrm-contract/wire-go/gen/runtime/v1;runtimev1b\x06proto3"

var (
	file_runtime_v1_bulk_ingest_proto_rawDescOnce sync.Once
	file_runtime_v1_bulk_ingest_proto_rawDescData []byte
)

func file_runtime_v1_bulk_ingest_proto_rawDescGZIP() []byte {
	file_runtime_v1_bulk_ingest_proto_rawDescOnce.Do(func() {
		file_runtime_v1_bulk_ingest_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_runtime_v1_bulk_ingest_proto_rawDesc), len(file_runtime_v1_bulk_ingest_proto_rawDesc)))
	})
	return file_runtime_v1_bulk_ingest_proto_rawDescData
}

var file_runtime_v1_bulk_ingest_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_runtime_v1_bulk_ingest_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
var file_runtime_v1_bulk_ingest_proto_goTypes = []any{
	(BulkIngestOperation)(0),             // 0: nexuscrm.runtime.v1.BulkIngestOperation
	(BulkIngestState)(0),                 // 1: nexuscrm.runtime.v1.BulkIngestState
	(BulkIngestFailureCode)(0),           // 2: nexuscrm.runtime.v1.BulkIngestFailureCode
	(*BulkIngestJob)(nil),                // 3: nexuscrm.runtime.v1.BulkIngestJob
	(*CreateBulkIngestJobRequest)(nil),   // 4: nexuscrm.runtime.v1.CreateBulkIngestJobRequest
	(*CreateBulkIngestJobResponse)(nil),  // 5: nexuscrm.runtime.v1.CreateBulkIngestJobResponse
	(*ReadBulkIngestJobRequest)(nil),     // 6: nexuscrm.runtime.v1.ReadBulkIngestJobRequest
	(*ReadBulkIngestJobResponse)(nil),    // 7: nexuscrm.runtime.v1.ReadBulkIngestJobResponse
	(*CloseBulkIngestJobRequest)(nil),    // 8: nexuscrm.runtime.v1.CloseBulkIngestJobRequest
	(*CloseBulkIngestJobResponse)(nil),   // 9: nexuscrm.runtime.v1.CloseBulkIngestJobResponse
	(*UploadBulkIngestDataHeader)(nil),   // 10: nexuscrm.runtime.v1.UploadBulkIngestDataHeader
	(*UploadBulkIngestDataRequest)(nil),  // 11: nexuscrm.runtime.v1.UploadBulkIngestDataRequest
	(*UploadBulkIngestDataResponse)(nil), // 12: nexuscrm.runtime.v1.UploadBulkIngestDataResponse
	(*v1.ConsistencyReceipts)(nil),       // 13: nexuscrm.common.v1.ConsistencyReceipts
}
var file_runtime_v1_bulk_ingest_proto_depIdxs = []int32{
	0,  // 0: nexuscrm.runtime.v1.BulkIngestJob.operation:type_name -> nexuscrm.runtime.v1.BulkIngestOperation
	1,  // 1: nexuscrm.runtime.v1.BulkIngestJob.state:type_name -> nexuscrm.runtime.v1.BulkIngestState
	2,  // 2: nexuscrm.runtime.v1.BulkIngestJob.failure_code:type_name -> nexuscrm.runtime.v1.BulkIngestFailureCode
	0,  // 3: nexuscrm.runtime.v1.CreateBulkIngestJobRequest.operation:type_name -> nexuscrm.runtime.v1.BulkIngestOperation
	3,  // 4: nexuscrm.runtime.v1.CreateBulkIngestJobResponse.job:type_name -> nexuscrm.runtime.v1.BulkIngestJob
	13, // 5: nexuscrm.runtime.v1.CreateBulkIngestJobResponse.receipts:type_name -> nexuscrm.common.v1.ConsistencyReceipts
	3,  // 6: nexuscrm.runtime.v1.ReadBulkIngestJobResponse.job:type_name -> nexuscrm.runtime.v1.BulkIngestJob
	13, // 7: nexuscrm.runtime.v1.ReadBulkIngestJobResponse.receipts:type_name -> nexuscrm.common.v1.ConsistencyReceipts
	1,  // 8: nexuscrm.runtime.v1.CloseBulkIngestJobRequest.state:type_name -> nexuscrm.runtime.v1.BulkIngestState
	3,  // 9: nexuscrm.runtime.v1.CloseBulkIngestJobResponse.job:type_name -> nexuscrm.runtime.v1.BulkIngestJob
	13, // 10: nexuscrm.runtime.v1.CloseBulkIngestJobResponse.receipts:type_name -> nexuscrm.common.v1.ConsistencyReceipts
	10, // 11: nexuscrm.runtime.v1.UploadBulkIngestDataRequest.header:type_name -> nexuscrm.runtime.v1.UploadBulkIngestDataHeader
	13, // 12: nexuscrm.runtime.v1.UploadBulkIngestDataResponse.receipts:type_name -> nexuscrm.common.v1.ConsistencyReceipts
	4,  // 13: nexuscrm.runtime.v1.BulkIngestService.CreateBulkIngestJob:input_type -> nexuscrm.runtime.v1.CreateBulkIngestJobRequest
	6,  // 14: nexuscrm.runtime.v1.BulkIngestService.ReadBulkIngestJob:input_type -> nexuscrm.runtime.v1.ReadBulkIngestJobRequest
	8,  // 15: nexuscrm.runtime.v1.BulkIngestService.CloseBulkIngestJob:input_type -> nexuscrm.runtime.v1.CloseBulkIngestJobRequest
	11, // 16: nexuscrm.runtime.v1.BulkIngestService.UploadBulkIngestData:input_type -> nexuscrm.runtime.v1.UploadBulkIngestDataRequest
	5,  // 17: nexuscrm.runtime.v1.BulkIngestService.CreateBulkIngestJob:output_type -> nexuscrm.runtime.v1.CreateBulkIngestJobResponse
	7,  // 18: nexuscrm.runtime.v1.BulkIngestService.ReadBulkIngestJob:output_type -> nexuscrm.runtime.v1.ReadBulkIngestJobResponse
	9,  // 19: nexuscrm.runtime.v1.BulkIngestService.CloseBulkIngestJob:output_type -> nexuscrm.runtime.v1.CloseBulkIngestJobResponse
	12, // 20: nexuscrm.runtime.v1.BulkIngestService.UploadBulkIngestData:output_type -> nexuscrm.runtime.v1.UploadBulkIngestDataResponse
	17, // [17:21] is the sub-list for method output_type
	13, // [13:17] is the sub-list for method input_type
	13, // [13:13] is the sub-list for extension type_name
	13, // [13:13] is the sub-list for extension extendee
	0,  // [0:13] is the sub-list for field type_name
}

func init() { file_runtime_v1_bulk_ingest_proto_init() }
func file_runtime_v1_bulk_ingest_proto_init() {
	if File_runtime_v1_bulk_ingest_proto != nil {
		return
	}
	file_runtime_v1_bulk_ingest_proto_msgTypes[7].OneofWrappers = []any{}
	file_runtime_v1_bulk_ingest_proto_msgTypes[8].OneofWrappers = []any{
		(*UploadBulkIngestDataRequest_Header)(nil),
		(*UploadBulkIngestDataRequest_Data)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_runtime_v1_bulk_ingest_proto_rawDesc), len(file_runtime_v1_bulk_ingest_proto_rawDesc)),
			NumEnums:      3,
			NumMessages:   10,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_runtime_v1_bulk_ingest_proto_goTypes,
		DependencyIndexes: file_runtime_v1_bulk_ingest_proto_depIdxs,
		EnumInfos:         file_runtime_v1_bulk_ingest_proto_enumTypes,
		MessageInfos:      file_runtime_v1_bulk_ingest_proto_msgTypes,
	}.Build()
	File_runtime_v1_bulk_ingest_proto = out.File
	file_runtime_v1_bulk_ingest_proto_goTypes = nil
	file_runtime_v1_bulk_ingest_proto_depIdxs = nil
}