// Code generated by protoc-gen-go. DO NOT EDIT.

package protocol

import (
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"

	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	structpb "google.golang.org/protobuf/types/known/structpb"
)

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 BatchObjectsRequest struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	Objects          []*BatchObject         `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	ConsistencyLevel *ConsistencyLevel      `protobuf:"varint,2,opt,name=consistency_level,json=consistencyLevel,proto3,enum=weaviate.v1.ConsistencyLevel,oneof" json:"consistency_level,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*BatchObjectsRequest) ProtoMessage() {}

func (x *BatchObjectsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchObjectsRequest.ProtoReflect.Descriptor instead.
func (*BatchObjectsRequest) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{0}
}

func (x *BatchObjectsRequest) GetObjects() []*BatchObject {
	if x != nil {
		return x.Objects
	}
	return nil
}

func (x *BatchObjectsRequest) GetConsistencyLevel() ConsistencyLevel {
	if x != nil && x.ConsistencyLevel != nil {
		return *x.ConsistencyLevel
	}
	return ConsistencyLevel_CONSISTENCY_LEVEL_UNSPECIFIED
}

type BatchReferencesRequest struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	References       []*BatchReference      `protobuf:"bytes,1,rep,name=references,proto3" json:"references,omitempty"`
	ConsistencyLevel *ConsistencyLevel      `protobuf:"varint,2,opt,name=consistency_level,json=consistencyLevel,proto3,enum=weaviate.v1.ConsistencyLevel,oneof" json:"consistency_level,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*BatchReferencesRequest) ProtoMessage() {}

func (x *BatchReferencesRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchReferencesRequest.ProtoReflect.Descriptor instead.
func (*BatchReferencesRequest) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{1}
}

func (x *BatchReferencesRequest) GetReferences() []*BatchReference {
	if x != nil {
		return x.References
	}
	return nil
}

func (x *BatchReferencesRequest) GetConsistencyLevel() ConsistencyLevel {
	if x != nil && x.ConsistencyLevel != nil {
		return *x.ConsistencyLevel
	}
	return ConsistencyLevel_CONSISTENCY_LEVEL_UNSPECIFIED
}

type BatchStreamRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Message:
	//
	//	*BatchStreamRequest_Start_
	//	*BatchStreamRequest_Data_
	//	*BatchStreamRequest_Stop_
	Message       isBatchStreamRequest_Message `protobuf_oneof:"message"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchStreamRequest) ProtoMessage() {}

func (x *BatchStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchStreamRequest.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2}
}

func (x *BatchStreamRequest) GetMessage() isBatchStreamRequest_Message {
	if x != nil {
		return x.Message
	}
	return nil
}

func (x *BatchStreamRequest) GetStart() *BatchStreamRequest_Start {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamRequest_Start_); ok {
			return x.Start
		}
	}
	return nil
}

func (x *BatchStreamRequest) GetData() *BatchStreamRequest_Data {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamRequest_Data_); ok {
			return x.Data
		}
	}
	return nil
}

func (x *BatchStreamRequest) GetStop() *BatchStreamRequest_Stop {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamRequest_Stop_); ok {
			return x.Stop
		}
	}
	return nil
}

type isBatchStreamRequest_Message interface {
	isBatchStreamRequest_Message()
}

type BatchStreamRequest_Start_ struct {
	Start *BatchStreamRequest_Start `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type BatchStreamRequest_Data_ struct {
	Data *BatchStreamRequest_Data `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type BatchStreamRequest_Stop_ struct {
	Stop *BatchStreamRequest_Stop `protobuf:"bytes,3,opt,name=stop,proto3,oneof"`
}

func (*BatchStreamRequest_Start_) isBatchStreamRequest_Message() {}

func (*BatchStreamRequest_Data_) isBatchStreamRequest_Message() {}

func (*BatchStreamRequest_Stop_) isBatchStreamRequest_Message() {}

type BatchStreamReply struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Message:
	//
	//	*BatchStreamReply_Results_
	//	*BatchStreamReply_ShuttingDown_
	//	*BatchStreamReply_Shutdown_
	//	*BatchStreamReply_Started_
	//	*BatchStreamReply_Backoff_
	//	*BatchStreamReply_Acks_
	//	*BatchStreamReply_OutOfMemory_
	Message       isBatchStreamReply_Message `protobuf_oneof:"message"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchStreamReply) ProtoMessage() {}

func (x *BatchStreamReply) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchStreamReply.ProtoReflect.Descriptor instead.
func (*BatchStreamReply) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3}
}

func (x *BatchStreamReply) GetMessage() isBatchStreamReply_Message {
	if x != nil {
		return x.Message
	}
	return nil
}

func (x *BatchStreamReply) GetResults() *BatchStreamReply_Results {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_Results_); ok {
			return x.Results
		}
	}
	return nil
}

func (x *BatchStreamReply) GetShuttingDown() *BatchStreamReply_ShuttingDown {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_ShuttingDown_); ok {
			return x.ShuttingDown
		}
	}
	return nil
}

func (x *BatchStreamReply) GetShutdown() *BatchStreamReply_Shutdown {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_Shutdown_); ok {
			return x.Shutdown
		}
	}
	return nil
}

func (x *BatchStreamReply) GetStarted() *BatchStreamReply_Started {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_Started_); ok {
			return x.Started
		}
	}
	return nil
}

func (x *BatchStreamReply) GetBackoff() *BatchStreamReply_Backoff {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_Backoff_); ok {
			return x.Backoff
		}
	}
	return nil
}

func (x *BatchStreamReply) GetAcks() *BatchStreamReply_Acks {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_Acks_); ok {
			return x.Acks
		}
	}
	return nil
}

func (x *BatchStreamReply) GetOutOfMemory() *BatchStreamReply_OutOfMemory {
	if x != nil {
		if x, ok := x.Message.(*BatchStreamReply_OutOfMemory_); ok {
			return x.OutOfMemory
		}
	}
	return nil
}

type isBatchStreamReply_Message interface {
	isBatchStreamReply_Message()
}

type BatchStreamReply_Results_ struct {
	Results *BatchStreamReply_Results `protobuf:"bytes,1,opt,name=results,proto3,oneof"`
}

type BatchStreamReply_ShuttingDown_ struct {
	ShuttingDown *BatchStreamReply_ShuttingDown `protobuf:"bytes,2,opt,name=shutting_down,json=shuttingDown,proto3,oneof"`
}

type BatchStreamReply_Shutdown_ struct {
	Shutdown *BatchStreamReply_Shutdown `protobuf:"bytes,3,opt,name=shutdown,proto3,oneof"`
}

type BatchStreamReply_Started_ struct {
	Started *BatchStreamReply_Started `protobuf:"bytes,4,opt,name=started,proto3,oneof"`
}

type BatchStreamReply_Backoff_ struct {
	Backoff *BatchStreamReply_Backoff `protobuf:"bytes,5,opt,name=backoff,proto3,oneof"`
}

type BatchStreamReply_Acks_ struct {
	Acks *BatchStreamReply_Acks `protobuf:"bytes,6,opt,name=acks,proto3,oneof"`
}

type BatchStreamReply_OutOfMemory_ struct {
	OutOfMemory *BatchStreamReply_OutOfMemory `protobuf:"bytes,7,opt,name=out_of_memory,json=outOfMemory,proto3,oneof"`
}

func (*BatchStreamReply_Results_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_ShuttingDown_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_Shutdown_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_Started_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_Backoff_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_Acks_) isBatchStreamReply_Message() {}

func (*BatchStreamReply_OutOfMemory_) isBatchStreamReply_Message() {}

type BatchObject struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	Uuid  string                 `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// protolint:disable:next REPEATED_FIELD_NAMES_PLURALIZED
	//
	// Deprecated: Marked as deprecated in v1/batch.proto.
	Vector      []float32               `protobuf:"fixed32,2,rep,packed,name=vector,proto3" json:"vector,omitempty"` // deprecated, will be removed
	Properties  *BatchObject_Properties `protobuf:"bytes,3,opt,name=properties,proto3" json:"properties,omitempty"`
	Collection  string                  `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"`
	Tenant      string                  `protobuf:"bytes,5,opt,name=tenant,proto3" json:"tenant,omitempty"`
	VectorBytes []byte                  `protobuf:"bytes,6,opt,name=vector_bytes,json=vectorBytes,proto3" json:"vector_bytes,omitempty"`
	// protolint:disable:next REPEATED_FIELD_NAMES_PLURALIZED
	Vectors       []*Vectors `protobuf:"bytes,23,rep,name=vectors,proto3" json:"vectors,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchObject) ProtoMessage() {}

func (x *BatchObject) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchObject.ProtoReflect.Descriptor instead.
func (*BatchObject) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{4}
}

func (x *BatchObject) GetUuid() string {
	if x != nil {
		return x.Uuid
	}
	return ""
}

// Deprecated: Marked as deprecated in v1/batch.proto.
func (x *BatchObject) GetVector() []float32 {
	if x != nil {
		return x.Vector
	}
	return nil
}

func (x *BatchObject) GetProperties() *BatchObject_Properties {
	if x != nil {
		return x.Properties
	}
	return nil
}

func (x *BatchObject) GetCollection() string {
	if x != nil {
		return x.Collection
	}
	return ""
}

func (x *BatchObject) GetTenant() string {
	if x != nil {
		return x.Tenant
	}
	return ""
}

func (x *BatchObject) GetVectorBytes() []byte {
	if x != nil {
		return x.VectorBytes
	}
	return nil
}

func (x *BatchObject) GetVectors() []*Vectors {
	if x != nil {
		return x.Vectors
	}
	return nil
}

type BatchReference struct {
	state          protoimpl.MessageState `protogen:"open.v1"`
	Name           string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	FromCollection string                 `protobuf:"bytes,2,opt,name=from_collection,json=fromCollection,proto3" json:"from_collection,omitempty"`
	FromUuid       string                 `protobuf:"bytes,3,opt,name=from_uuid,json=fromUuid,proto3" json:"from_uuid,omitempty"`
	ToCollection   *string                `protobuf:"bytes,4,opt,name=to_collection,json=toCollection,proto3,oneof" json:"to_collection,omitempty"`
	ToUuid         string                 `protobuf:"bytes,5,opt,name=to_uuid,json=toUuid,proto3" json:"to_uuid,omitempty"`
	Tenant         string                 `protobuf:"bytes,6,opt,name=tenant,proto3" json:"tenant,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

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

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

func (*BatchReference) ProtoMessage() {}

func (x *BatchReference) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchReference.ProtoReflect.Descriptor instead.
func (*BatchReference) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{5}
}

func (x *BatchReference) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *BatchReference) GetFromCollection() string {
	if x != nil {
		return x.FromCollection
	}
	return ""
}

func (x *BatchReference) GetFromUuid() string {
	if x != nil {
		return x.FromUuid
	}
	return ""
}

func (x *BatchReference) GetToCollection() string {
	if x != nil && x.ToCollection != nil {
		return *x.ToCollection
	}
	return ""
}

func (x *BatchReference) GetToUuid() string {
	if x != nil {
		return x.ToUuid
	}
	return ""
}

func (x *BatchReference) GetTenant() string {
	if x != nil {
		return x.Tenant
	}
	return ""
}

type BatchObjectsReply struct {
	state         protoimpl.MessageState          `protogen:"open.v1"`
	Took          float32                         `protobuf:"fixed32,1,opt,name=took,proto3" json:"took,omitempty"`
	Errors        []*BatchObjectsReply_BatchError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchObjectsReply) ProtoMessage() {}

func (x *BatchObjectsReply) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchObjectsReply.ProtoReflect.Descriptor instead.
func (*BatchObjectsReply) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{6}
}

func (x *BatchObjectsReply) GetTook() float32 {
	if x != nil {
		return x.Took
	}
	return 0
}

func (x *BatchObjectsReply) GetErrors() []*BatchObjectsReply_BatchError {
	if x != nil {
		return x.Errors
	}
	return nil
}

type BatchReferencesReply struct {
	state         protoimpl.MessageState             `protogen:"open.v1"`
	Took          float32                            `protobuf:"fixed32,1,opt,name=took,proto3" json:"took,omitempty"`
	Errors        []*BatchReferencesReply_BatchError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchReferencesReply) ProtoMessage() {}

func (x *BatchReferencesReply) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchReferencesReply.ProtoReflect.Descriptor instead.
func (*BatchReferencesReply) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{7}
}

func (x *BatchReferencesReply) GetTook() float32 {
	if x != nil {
		return x.Took
	}
	return 0
}

func (x *BatchReferencesReply) GetErrors() []*BatchReferencesReply_BatchError {
	if x != nil {
		return x.Errors
	}
	return nil
}

type BatchStreamRequest_Start struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	ConsistencyLevel *ConsistencyLevel      `protobuf:"varint,1,opt,name=consistency_level,json=consistencyLevel,proto3,enum=weaviate.v1.ConsistencyLevel,oneof" json:"consistency_level,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*BatchStreamRequest_Start) ProtoMessage() {}

func (x *BatchStreamRequest_Start) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchStreamRequest_Start.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest_Start) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2, 0}
}

func (x *BatchStreamRequest_Start) GetConsistencyLevel() ConsistencyLevel {
	if x != nil && x.ConsistencyLevel != nil {
		return *x.ConsistencyLevel
	}
	return ConsistencyLevel_CONSISTENCY_LEVEL_UNSPECIFIED
}

type BatchStreamRequest_Stop struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*BatchStreamRequest_Stop) ProtoMessage() {}

func (x *BatchStreamRequest_Stop) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_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 BatchStreamRequest_Stop.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest_Stop) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2, 1}
}

type BatchStreamRequest_Data struct {
	state         protoimpl.MessageState              `protogen:"open.v1"`
	Objects       *BatchStreamRequest_Data_Objects    `protobuf:"bytes,1,opt,name=objects,proto3" json:"objects,omitempty"`
	References    *BatchStreamRequest_Data_References `protobuf:"bytes,2,opt,name=references,proto3" json:"references,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamRequest_Data) Reset() {
	*x = BatchStreamRequest_Data{}
	mi := &file_v1_batch_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamRequest_Data) ProtoMessage() {}

func (x *BatchStreamRequest_Data) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[10]
	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 BatchStreamRequest_Data.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest_Data) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2, 2}
}

func (x *BatchStreamRequest_Data) GetObjects() *BatchStreamRequest_Data_Objects {
	if x != nil {
		return x.Objects
	}
	return nil
}

func (x *BatchStreamRequest_Data) GetReferences() *BatchStreamRequest_Data_References {
	if x != nil {
		return x.References
	}
	return nil
}

type BatchStreamRequest_Data_Objects struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Values        []*BatchObject         `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamRequest_Data_Objects) Reset() {
	*x = BatchStreamRequest_Data_Objects{}
	mi := &file_v1_batch_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamRequest_Data_Objects) ProtoMessage() {}

func (x *BatchStreamRequest_Data_Objects) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[11]
	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 BatchStreamRequest_Data_Objects.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest_Data_Objects) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2, 2, 0}
}

func (x *BatchStreamRequest_Data_Objects) GetValues() []*BatchObject {
	if x != nil {
		return x.Values
	}
	return nil
}

type BatchStreamRequest_Data_References struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Values        []*BatchReference      `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamRequest_Data_References) Reset() {
	*x = BatchStreamRequest_Data_References{}
	mi := &file_v1_batch_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamRequest_Data_References) ProtoMessage() {}

func (x *BatchStreamRequest_Data_References) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[12]
	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 BatchStreamRequest_Data_References.ProtoReflect.Descriptor instead.
func (*BatchStreamRequest_Data_References) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{2, 2, 1}
}

func (x *BatchStreamRequest_Data_References) GetValues() []*BatchReference {
	if x != nil {
		return x.Values
	}
	return nil
}

type BatchStreamReply_Started struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Started) Reset() {
	*x = BatchStreamReply_Started{}
	mi := &file_v1_batch_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Started) ProtoMessage() {}

func (x *BatchStreamReply_Started) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[13]
	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 BatchStreamReply_Started.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Started) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 0}
}

type BatchStreamReply_ShuttingDown struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_ShuttingDown) Reset() {
	*x = BatchStreamReply_ShuttingDown{}
	mi := &file_v1_batch_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_ShuttingDown) ProtoMessage() {}

func (x *BatchStreamReply_ShuttingDown) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[14]
	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 BatchStreamReply_ShuttingDown.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_ShuttingDown) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 1}
}

type BatchStreamReply_Shutdown struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Shutdown) Reset() {
	*x = BatchStreamReply_Shutdown{}
	mi := &file_v1_batch_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Shutdown) ProtoMessage() {}

func (x *BatchStreamReply_Shutdown) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[15]
	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 BatchStreamReply_Shutdown.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Shutdown) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 2}
}

type BatchStreamReply_OutOfMemory struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Uuids         []string               `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	Beacons       []string               `protobuf:"bytes,2,rep,name=beacons,proto3" json:"beacons,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_OutOfMemory) Reset() {
	*x = BatchStreamReply_OutOfMemory{}
	mi := &file_v1_batch_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_OutOfMemory) ProtoMessage() {}

func (x *BatchStreamReply_OutOfMemory) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[16]
	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 BatchStreamReply_OutOfMemory.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_OutOfMemory) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 3}
}

func (x *BatchStreamReply_OutOfMemory) GetUuids() []string {
	if x != nil {
		return x.Uuids
	}
	return nil
}

func (x *BatchStreamReply_OutOfMemory) GetBeacons() []string {
	if x != nil {
		return x.Beacons
	}
	return nil
}

type BatchStreamReply_Backoff struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	BatchSize     int32                  `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Backoff) Reset() {
	*x = BatchStreamReply_Backoff{}
	mi := &file_v1_batch_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Backoff) ProtoMessage() {}

func (x *BatchStreamReply_Backoff) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[17]
	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 BatchStreamReply_Backoff.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Backoff) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 4}
}

func (x *BatchStreamReply_Backoff) GetBatchSize() int32 {
	if x != nil {
		return x.BatchSize
	}
	return 0
}

type BatchStreamReply_Acks struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Uuids         []string               `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	Beacons       []string               `protobuf:"bytes,2,rep,name=beacons,proto3" json:"beacons,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Acks) Reset() {
	*x = BatchStreamReply_Acks{}
	mi := &file_v1_batch_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Acks) ProtoMessage() {}

func (x *BatchStreamReply_Acks) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[18]
	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 BatchStreamReply_Acks.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Acks) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 5}
}

func (x *BatchStreamReply_Acks) GetUuids() []string {
	if x != nil {
		return x.Uuids
	}
	return nil
}

func (x *BatchStreamReply_Acks) GetBeacons() []string {
	if x != nil {
		return x.Beacons
	}
	return nil
}

type BatchStreamReply_Results struct {
	state         protoimpl.MessageState              `protogen:"open.v1"`
	Errors        []*BatchStreamReply_Results_Error   `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	Successes     []*BatchStreamReply_Results_Success `protobuf:"bytes,2,rep,name=successes,proto3" json:"successes,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Results) Reset() {
	*x = BatchStreamReply_Results{}
	mi := &file_v1_batch_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Results) ProtoMessage() {}

func (x *BatchStreamReply_Results) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[19]
	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 BatchStreamReply_Results.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Results) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 6}
}

func (x *BatchStreamReply_Results) GetErrors() []*BatchStreamReply_Results_Error {
	if x != nil {
		return x.Errors
	}
	return nil
}

func (x *BatchStreamReply_Results) GetSuccesses() []*BatchStreamReply_Results_Success {
	if x != nil {
		return x.Successes
	}
	return nil
}

type BatchStreamReply_Results_Error struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	Error string                 `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Types that are valid to be assigned to Detail:
	//
	//	*BatchStreamReply_Results_Error_Uuid
	//	*BatchStreamReply_Results_Error_Beacon
	Detail        isBatchStreamReply_Results_Error_Detail `protobuf_oneof:"detail"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Results_Error) Reset() {
	*x = BatchStreamReply_Results_Error{}
	mi := &file_v1_batch_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Results_Error) ProtoMessage() {}

func (x *BatchStreamReply_Results_Error) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[20]
	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 BatchStreamReply_Results_Error.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Results_Error) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 6, 0}
}

func (x *BatchStreamReply_Results_Error) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *BatchStreamReply_Results_Error) GetDetail() isBatchStreamReply_Results_Error_Detail {
	if x != nil {
		return x.Detail
	}
	return nil
}

func (x *BatchStreamReply_Results_Error) GetUuid() string {
	if x != nil {
		if x, ok := x.Detail.(*BatchStreamReply_Results_Error_Uuid); ok {
			return x.Uuid
		}
	}
	return ""
}

func (x *BatchStreamReply_Results_Error) GetBeacon() string {
	if x != nil {
		if x, ok := x.Detail.(*BatchStreamReply_Results_Error_Beacon); ok {
			return x.Beacon
		}
	}
	return ""
}

type isBatchStreamReply_Results_Error_Detail interface {
	isBatchStreamReply_Results_Error_Detail()
}

type BatchStreamReply_Results_Error_Uuid struct {
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3,oneof"`
}

type BatchStreamReply_Results_Error_Beacon struct {
	Beacon string `protobuf:"bytes,3,opt,name=beacon,proto3,oneof"`
}

func (*BatchStreamReply_Results_Error_Uuid) isBatchStreamReply_Results_Error_Detail() {}

func (*BatchStreamReply_Results_Error_Beacon) isBatchStreamReply_Results_Error_Detail() {}

type BatchStreamReply_Results_Success struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Detail:
	//
	//	*BatchStreamReply_Results_Success_Uuid
	//	*BatchStreamReply_Results_Success_Beacon
	Detail        isBatchStreamReply_Results_Success_Detail `protobuf_oneof:"detail"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchStreamReply_Results_Success) Reset() {
	*x = BatchStreamReply_Results_Success{}
	mi := &file_v1_batch_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchStreamReply_Results_Success) ProtoMessage() {}

func (x *BatchStreamReply_Results_Success) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[21]
	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 BatchStreamReply_Results_Success.ProtoReflect.Descriptor instead.
func (*BatchStreamReply_Results_Success) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{3, 6, 1}
}

func (x *BatchStreamReply_Results_Success) GetDetail() isBatchStreamReply_Results_Success_Detail {
	if x != nil {
		return x.Detail
	}
	return nil
}

func (x *BatchStreamReply_Results_Success) GetUuid() string {
	if x != nil {
		if x, ok := x.Detail.(*BatchStreamReply_Results_Success_Uuid); ok {
			return x.Uuid
		}
	}
	return ""
}

func (x *BatchStreamReply_Results_Success) GetBeacon() string {
	if x != nil {
		if x, ok := x.Detail.(*BatchStreamReply_Results_Success_Beacon); ok {
			return x.Beacon
		}
	}
	return ""
}

type isBatchStreamReply_Results_Success_Detail interface {
	isBatchStreamReply_Results_Success_Detail()
}

type BatchStreamReply_Results_Success_Uuid struct {
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3,oneof"`
}

type BatchStreamReply_Results_Success_Beacon struct {
	Beacon string `protobuf:"bytes,3,opt,name=beacon,proto3,oneof"`
}

func (*BatchStreamReply_Results_Success_Uuid) isBatchStreamReply_Results_Success_Detail() {}

func (*BatchStreamReply_Results_Success_Beacon) isBatchStreamReply_Results_Success_Detail() {}

type BatchObject_Properties struct {
	state                  protoimpl.MessageState              `protogen:"open.v1"`
	NonRefProperties       *structpb.Struct                    `protobuf:"bytes,1,opt,name=non_ref_properties,json=nonRefProperties,proto3" json:"non_ref_properties,omitempty"`
	SingleTargetRefProps   []*BatchObject_SingleTargetRefProps `protobuf:"bytes,2,rep,name=single_target_ref_props,json=singleTargetRefProps,proto3" json:"single_target_ref_props,omitempty"`
	MultiTargetRefProps    []*BatchObject_MultiTargetRefProps  `protobuf:"bytes,3,rep,name=multi_target_ref_props,json=multiTargetRefProps,proto3" json:"multi_target_ref_props,omitempty"`
	NumberArrayProperties  []*NumberArrayProperties            `protobuf:"bytes,4,rep,name=number_array_properties,json=numberArrayProperties,proto3" json:"number_array_properties,omitempty"`
	IntArrayProperties     []*IntArrayProperties               `protobuf:"bytes,5,rep,name=int_array_properties,json=intArrayProperties,proto3" json:"int_array_properties,omitempty"`
	TextArrayProperties    []*TextArrayProperties              `protobuf:"bytes,6,rep,name=text_array_properties,json=textArrayProperties,proto3" json:"text_array_properties,omitempty"`
	BooleanArrayProperties []*BooleanArrayProperties           `protobuf:"bytes,7,rep,name=boolean_array_properties,json=booleanArrayProperties,proto3" json:"boolean_array_properties,omitempty"`
	ObjectProperties       []*ObjectProperties                 `protobuf:"bytes,8,rep,name=object_properties,json=objectProperties,proto3" json:"object_properties,omitempty"`
	ObjectArrayProperties  []*ObjectArrayProperties            `protobuf:"bytes,9,rep,name=object_array_properties,json=objectArrayProperties,proto3" json:"object_array_properties,omitempty"`
	// empty lists do not have a type in many languages and clients do not know which datatype the property has.
	// Weaviate can get the datatype from its schema
	EmptyListProps []string `protobuf:"bytes,10,rep,name=empty_list_props,json=emptyListProps,proto3" json:"empty_list_props,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *BatchObject_Properties) Reset() {
	*x = BatchObject_Properties{}
	mi := &file_v1_batch_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchObject_Properties) ProtoMessage() {}

func (x *BatchObject_Properties) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[22]
	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 BatchObject_Properties.ProtoReflect.Descriptor instead.
func (*BatchObject_Properties) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{4, 0}
}

func (x *BatchObject_Properties) GetNonRefProperties() *structpb.Struct {
	if x != nil {
		return x.NonRefProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetSingleTargetRefProps() []*BatchObject_SingleTargetRefProps {
	if x != nil {
		return x.SingleTargetRefProps
	}
	return nil
}

func (x *BatchObject_Properties) GetMultiTargetRefProps() []*BatchObject_MultiTargetRefProps {
	if x != nil {
		return x.MultiTargetRefProps
	}
	return nil
}

func (x *BatchObject_Properties) GetNumberArrayProperties() []*NumberArrayProperties {
	if x != nil {
		return x.NumberArrayProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetIntArrayProperties() []*IntArrayProperties {
	if x != nil {
		return x.IntArrayProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetTextArrayProperties() []*TextArrayProperties {
	if x != nil {
		return x.TextArrayProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetBooleanArrayProperties() []*BooleanArrayProperties {
	if x != nil {
		return x.BooleanArrayProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetObjectProperties() []*ObjectProperties {
	if x != nil {
		return x.ObjectProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetObjectArrayProperties() []*ObjectArrayProperties {
	if x != nil {
		return x.ObjectArrayProperties
	}
	return nil
}

func (x *BatchObject_Properties) GetEmptyListProps() []string {
	if x != nil {
		return x.EmptyListProps
	}
	return nil
}

type BatchObject_SingleTargetRefProps struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Uuids         []string               `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	PropName      string                 `protobuf:"bytes,2,opt,name=prop_name,json=propName,proto3" json:"prop_name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchObject_SingleTargetRefProps) Reset() {
	*x = BatchObject_SingleTargetRefProps{}
	mi := &file_v1_batch_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchObject_SingleTargetRefProps) ProtoMessage() {}

func (x *BatchObject_SingleTargetRefProps) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[23]
	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 BatchObject_SingleTargetRefProps.ProtoReflect.Descriptor instead.
func (*BatchObject_SingleTargetRefProps) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{4, 1}
}

func (x *BatchObject_SingleTargetRefProps) GetUuids() []string {
	if x != nil {
		return x.Uuids
	}
	return nil
}

func (x *BatchObject_SingleTargetRefProps) GetPropName() string {
	if x != nil {
		return x.PropName
	}
	return ""
}

type BatchObject_MultiTargetRefProps struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	Uuids            []string               `protobuf:"bytes,1,rep,name=uuids,proto3" json:"uuids,omitempty"`
	PropName         string                 `protobuf:"bytes,2,opt,name=prop_name,json=propName,proto3" json:"prop_name,omitempty"`
	TargetCollection string                 `protobuf:"bytes,3,opt,name=target_collection,json=targetCollection,proto3" json:"target_collection,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *BatchObject_MultiTargetRefProps) Reset() {
	*x = BatchObject_MultiTargetRefProps{}
	mi := &file_v1_batch_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchObject_MultiTargetRefProps) ProtoMessage() {}

func (x *BatchObject_MultiTargetRefProps) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[24]
	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 BatchObject_MultiTargetRefProps.ProtoReflect.Descriptor instead.
func (*BatchObject_MultiTargetRefProps) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{4, 2}
}

func (x *BatchObject_MultiTargetRefProps) GetUuids() []string {
	if x != nil {
		return x.Uuids
	}
	return nil
}

func (x *BatchObject_MultiTargetRefProps) GetPropName() string {
	if x != nil {
		return x.PropName
	}
	return ""
}

func (x *BatchObject_MultiTargetRefProps) GetTargetCollection() string {
	if x != nil {
		return x.TargetCollection
	}
	return ""
}

type BatchObjectsReply_BatchError struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Index         int32                  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchObjectsReply_BatchError) Reset() {
	*x = BatchObjectsReply_BatchError{}
	mi := &file_v1_batch_proto_msgTypes[25]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchObjectsReply_BatchError) ProtoMessage() {}

func (x *BatchObjectsReply_BatchError) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[25]
	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 BatchObjectsReply_BatchError.ProtoReflect.Descriptor instead.
func (*BatchObjectsReply_BatchError) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{6, 0}
}

func (x *BatchObjectsReply_BatchError) GetIndex() int32 {
	if x != nil {
		return x.Index
	}
	return 0
}

func (x *BatchObjectsReply_BatchError) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

type BatchReferencesReply_BatchError struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Index         int32                  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchReferencesReply_BatchError) Reset() {
	*x = BatchReferencesReply_BatchError{}
	mi := &file_v1_batch_proto_msgTypes[26]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*BatchReferencesReply_BatchError) ProtoMessage() {}

func (x *BatchReferencesReply_BatchError) ProtoReflect() protoreflect.Message {
	mi := &file_v1_batch_proto_msgTypes[26]
	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 BatchReferencesReply_BatchError.ProtoReflect.Descriptor instead.
func (*BatchReferencesReply_BatchError) Descriptor() ([]byte, []int) {
	return file_v1_batch_proto_rawDescGZIP(), []int{7, 0}
}

func (x *BatchReferencesReply_BatchError) GetIndex() int32 {
	if x != nil {
		return x.Index
	}
	return 0
}

func (x *BatchReferencesReply_BatchError) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

var File_v1_batch_proto protoreflect.FileDescriptor

const file_v1_batch_proto_rawDesc = "" +
	"\n" +
	"\x0ev1/batch.proto\x12\vweaviate.v1\x1a\x1cgoogle/protobuf/struct.proto\x1a\rv1/base.proto\"\xb0\x01\n" +
	"\x13BatchObjectsRequest\x122\n" +
	"\aobjects\x18\x01 \x03(\v2\x18.weaviate.v1.BatchObjectR\aobjects\x12O\n" +
	"\x11consistency_level\x18\x02 \x01(\x0e2\x1d.weaviate.v1.ConsistencyLevelH\x00R\x10consistencyLevel\x88\x01\x01B\x14\n" +
	"\x12_consistency_level\"\xbc\x01\n" +
	"\x16BatchReferencesRequest\x12;\n" +
	"\n" +
	"references\x18\x01 \x03(\v2\x1b.weaviate.v1.BatchReferenceR\n" +
	"references\x12O\n" +
	"\x11consistency_level\x18\x02 \x01(\x0e2\x1d.weaviate.v1.ConsistencyLevelH\x00R\x10consistencyLevel\x88\x01\x01B\x14\n" +
	"\x12_consistency_level\"\xf0\x04\n" +
	"\x12BatchStreamRequest\x12=\n" +
	"\x05start\x18\x01 \x01(\v2%.weaviate.v1.BatchStreamRequest.StartH\x00R\x05start\x12:\n" +
	"\x04data\x18\x02 \x01(\v2$.weaviate.v1.BatchStreamRequest.DataH\x00R\x04data\x12:\n" +
	"\x04stop\x18\x03 \x01(\v2$.weaviate.v1.BatchStreamRequest.StopH\x00R\x04stop\x1an\n" +
	"\x05Start\x12O\n" +
	"\x11consistency_level\x18\x01 \x01(\x0e2\x1d.weaviate.v1.ConsistencyLevelH\x00R\x10consistencyLevel\x88\x01\x01B\x14\n" +
	"\x12_consistency_level\x1a\x06\n" +
	"\x04Stop\x1a\x9f\x02\n" +
	"\x04Data\x12F\n" +
	"\aobjects\x18\x01 \x01(\v2,.weaviate.v1.BatchStreamRequest.Data.ObjectsR\aobjects\x12O\n" +
	"\n" +
	"references\x18\x02 \x01(\v2/.weaviate.v1.BatchStreamRequest.Data.ReferencesR\n" +
	"references\x1a;\n" +
	"\aObjects\x120\n" +
	"\x06values\x18\x01 \x03(\v2\x18.weaviate.v1.BatchObjectR\x06values\x1aA\n" +
	"\n" +
	"References\x123\n" +
	"\x06values\x18\x01 \x03(\v2\x1b.weaviate.v1.BatchReferenceR\x06valuesB\t\n" +
	"\amessage\"\x8e\b\n" +
	"\x10BatchStreamReply\x12A\n" +
	"\aresults\x18\x01 \x01(\v2%.weaviate.v1.BatchStreamReply.ResultsH\x00R\aresults\x12Q\n" +
	"\rshutting_down\x18\x02 \x01(\v2*.weaviate.v1.BatchStreamReply.ShuttingDownH\x00R\fshuttingDown\x12D\n" +
	"\bshutdown\x18\x03 \x01(\v2&.weaviate.v1.BatchStreamReply.ShutdownH\x00R\bshutdown\x12A\n" +
	"\astarted\x18\x04 \x01(\v2%.weaviate.v1.BatchStreamReply.StartedH\x00R\astarted\x12A\n" +
	"\abackoff\x18\x05 \x01(\v2%.weaviate.v1.BatchStreamReply.BackoffH\x00R\abackoff\x128\n" +
	"\x04acks\x18\x06 \x01(\v2\".weaviate.v1.BatchStreamReply.AcksH\x00R\x04acks\x12O\n" +
	"\rout_of_memory\x18\a \x01(\v2).weaviate.v1.BatchStreamReply.OutOfMemoryH\x00R\voutOfMemory\x1a\t\n" +
	"\aStarted\x1a\x0e\n" +
	"\fShuttingDown\x1a\n" +
	"\n" +
	"\bShutdown\x1a=\n" +
	"\vOutOfMemory\x12\x14\n" +
	"\x05uuids\x18\x01 \x03(\tR\x05uuids\x12\x18\n" +
	"\abeacons\x18\x02 \x03(\tR\abeacons\x1a(\n" +
	"\aBackoff\x12\x1d\n" +
	"\n" +
	"batch_size\x18\x01 \x01(\x05R\tbatchSize\x1a6\n" +
	"\x04Acks\x12\x14\n" +
	"\x05uuids\x18\x01 \x03(\tR\x05uuids\x12\x18\n" +
	"\abeacons\x18\x02 \x03(\tR\abeacons\x1a\xb9\x02\n" +
	"\aResults\x12C\n" +
	"\x06errors\x18\x01 \x03(\v2+.weaviate.v1.BatchStreamReply.Results.ErrorR\x06errors\x12K\n" +
	"\tsuccesses\x18\x02 \x03(\v2-.weaviate.v1.BatchStreamReply.Results.SuccessR\tsuccesses\x1aW\n" +
	"\x05Error\x12\x14\n" +
	"\x05error\x18\x01 \x01(\tR\x05error\x12\x14\n" +
	"\x04uuid\x18\x02 \x01(\tH\x00R\x04uuid\x12\x18\n" +
	"\x06beacon\x18\x03 \x01(\tH\x00R\x06beaconB\b\n" +
	"\x06detail\x1aC\n" +
	"\aSuccess\x12\x14\n" +
	"\x04uuid\x18\x02 \x01(\tH\x00R\x04uuid\x12\x18\n" +
	"\x06beacon\x18\x03 \x01(\tH\x00R\x06beaconB\b\n" +
	"\x06detailB\t\n" +
	"\amessage\"\xa4\n" +
	"\n" +
	"\vBatchObject\x12\x12\n" +
	"\x04uuid\x18\x01 \x01(\tR\x04uuid\x12\x1a\n" +
	"\x06vector\x18\x02 \x03(\x02B\x02\x18\x01R\x06vector\x12C\n" +
	"\n" +
	"properties\x18\x03 \x01(\v2#.weaviate.v1.BatchObject.PropertiesR\n" +
	"properties\x12\x1e\n" +
	"\n" +
	"collection\x18\x04 \x01(\tR\n" +
	"collection\x12\x16\n" +
	"\x06tenant\x18\x05 \x01(\tR\x06tenant\x12!\n" +
	"\fvector_bytes\x18\x06 \x01(\fR\vvectorBytes\x12.\n" +
	"\avectors\x18\x17 \x03(\v2\x14.weaviate.v1.VectorsR\avectors\x1a\xd2\x06\n" +
	"\n" +
	"Properties\x12E\n" +
	"\x12non_ref_properties\x18\x01 \x01(\v2\x17.google.protobuf.StructR\x10nonRefProperties\x12d\n" +
	"\x17single_target_ref_props\x18\x02 \x03(\v2-.weaviate.v1.BatchObject.SingleTargetRefPropsR\x14singleTargetRefProps\x12a\n" +
	"\x16multi_target_ref_props\x18\x03 \x03(\v2,.weaviate.v1.BatchObject.MultiTargetRefPropsR\x13multiTargetRefProps\x12Z\n" +
	"\x17number_array_properties\x18\x04 \x03(\v2\".weaviate.v1.NumberArrayPropertiesR\x15numberArrayProperties\x12Q\n" +
	"\x14int_array_properties\x18\x05 \x03(\v2\x1f.weaviate.v1.IntArrayPropertiesR\x12intArrayProperties\x12T\n" +
	"\x15text_array_properties\x18\x06 \x03(\v2 .weaviate.v1.TextArrayPropertiesR\x13textArrayProperties\x12]\n" +
	"\x18boolean_array_properties\x18\a \x03(\v2#.weaviate.v1.BooleanArrayPropertiesR\x16booleanArrayProperties\x12J\n" +
	"\x11object_properties\x18\b \x03(\v2\x1d.weaviate.v1.ObjectPropertiesR\x10objectProperties\x12Z\n" +
	"\x17object_array_properties\x18\t \x03(\v2\".weaviate.v1.ObjectArrayPropertiesR\x15objectArrayProperties\x12(\n" +
	"\x10empty_list_props\x18\n" +
	" \x03(\tR\x0eemptyListProps\x1aI\n" +
	"\x14SingleTargetRefProps\x12\x14\n" +
	"\x05uuids\x18\x01 \x03(\tR\x05uuids\x12\x1b\n" +
	"\tprop_name\x18\x02 \x01(\tR\bpropName\x1au\n" +
	"\x13MultiTargetRefProps\x12\x14\n" +
	"\x05uuids\x18\x01 \x03(\tR\x05uuids\x12\x1b\n" +
	"\tprop_name\x18\x02 \x01(\tR\bpropName\x12+\n" +
	"\x11target_collection\x18\x03 \x01(\tR\x10targetCollection\"\xd7\x01\n" +
	"\x0eBatchReference\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12'\n" +
	"\x0ffrom_collection\x18\x02 \x01(\tR\x0efromCollection\x12\x1b\n" +
	"\tfrom_uuid\x18\x03 \x01(\tR\bfromUuid\x12(\n" +
	"\rto_collection\x18\x04 \x01(\tH\x00R\ftoCollection\x88\x01\x01\x12\x17\n" +
	"\ato_uuid\x18\x05 \x01(\tR\x06toUuid\x12\x16\n" +
	"\x06tenant\x18\x06 \x01(\tR\x06tenantB\x10\n" +
	"\x0e_to_collection\"\xa4\x01\n" +
	"\x11BatchObjectsReply\x12\x12\n" +
	"\x04took\x18\x01 \x01(\x02R\x04took\x12A\n" +
	"\x06errors\x18\x02 \x03(\v2).weaviate.v1.BatchObjectsReply.BatchErrorR\x06errors\x1a8\n" +
	"\n" +
	"BatchError\x12\x14\n" +
	"\x05index\x18\x01 \x01(\x05R\x05index\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05error\"\xaa\x01\n" +
	"\x14BatchReferencesReply\x12\x12\n" +
	"\x04took\x18\x01 \x01(\x02R\x04took\x12D\n" +
	"\x06errors\x18\x02 \x03(\v2,.weaviate.v1.BatchReferencesReply.BatchErrorR\x06errors\x1a8\n" +
	"\n" +
	"BatchError\x12\x14\n" +
	"\x05index\x18\x01 \x01(\x05R\x05index\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05errorBo\n" +
	"#io.weaviate.client.grpc.protocol.v1B\x12WeaviateProtoBatchZ4github.com/weaviate/weaviate/grpc/generated;protocolb\x06proto3"

var (
	file_v1_batch_proto_rawDescOnce sync.Once
	file_v1_batch_proto_rawDescData []byte
)

func file_v1_batch_proto_rawDescGZIP() []byte {
	file_v1_batch_proto_rawDescOnce.Do(func() {
		file_v1_batch_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_v1_batch_proto_rawDesc), len(file_v1_batch_proto_rawDesc)))
	})
	return file_v1_batch_proto_rawDescData
}

var file_v1_batch_proto_msgTypes = make([]protoimpl.MessageInfo, 27)
var file_v1_batch_proto_goTypes = []any{
	(*BatchObjectsRequest)(nil),                // 0: weaviate.v1.BatchObjectsRequest
	(*BatchReferencesRequest)(nil),             // 1: weaviate.v1.BatchReferencesRequest
	(*BatchStreamRequest)(nil),                 // 2: weaviate.v1.BatchStreamRequest
	(*BatchStreamReply)(nil),                   // 3: weaviate.v1.BatchStreamReply
	(*BatchObject)(nil),                        // 4: weaviate.v1.BatchObject
	(*BatchReference)(nil),                     // 5: weaviate.v1.BatchReference
	(*BatchObjectsReply)(nil),                  // 6: weaviate.v1.BatchObjectsReply
	(*BatchReferencesReply)(nil),               // 7: weaviate.v1.BatchReferencesReply
	(*BatchStreamRequest_Start)(nil),           // 8: weaviate.v1.BatchStreamRequest.Start
	(*BatchStreamRequest_Stop)(nil),            // 9: weaviate.v1.BatchStreamRequest.Stop
	(*BatchStreamRequest_Data)(nil),            // 10: weaviate.v1.BatchStreamRequest.Data
	(*BatchStreamRequest_Data_Objects)(nil),    // 11: weaviate.v1.BatchStreamRequest.Data.Objects
	(*BatchStreamRequest_Data_References)(nil), // 12: weaviate.v1.BatchStreamRequest.Data.References
	(*BatchStreamReply_Started)(nil),           // 13: weaviate.v1.BatchStreamReply.Started
	(*BatchStreamReply_ShuttingDown)(nil),      // 14: weaviate.v1.BatchStreamReply.ShuttingDown
	(*BatchStreamReply_Shutdown)(nil),          // 15: weaviate.v1.BatchStreamReply.Shutdown
	(*BatchStreamReply_OutOfMemory)(nil),       // 16: weaviate.v1.BatchStreamReply.OutOfMemory
	(*BatchStreamReply_Backoff)(nil),           // 17: weaviate.v1.BatchStreamReply.Backoff
	(*BatchStreamReply_Acks)(nil),              // 18: weaviate.v1.BatchStreamReply.Acks
	(*BatchStreamReply_Results)(nil),           // 19: weaviate.v1.BatchStreamReply.Results
	(*BatchStreamReply_Results_Error)(nil),     // 20: weaviate.v1.BatchStreamReply.Results.Error
	(*BatchStreamReply_Results_Success)(nil),   // 21: weaviate.v1.BatchStreamReply.Results.Success
	(*BatchObject_Properties)(nil),             // 22: weaviate.v1.BatchObject.Properties
	(*BatchObject_SingleTargetRefProps)(nil),   // 23: weaviate.v1.BatchObject.SingleTargetRefProps
	(*BatchObject_MultiTargetRefProps)(nil),    // 24: weaviate.v1.BatchObject.MultiTargetRefProps
	(*BatchObjectsReply_BatchError)(nil),       // 25: weaviate.v1.BatchObjectsReply.BatchError
	(*BatchReferencesReply_BatchError)(nil),    // 26: weaviate.v1.BatchReferencesReply.BatchError
	(ConsistencyLevel)(0),                      // 27: weaviate.v1.ConsistencyLevel
	(*Vectors)(nil),                            // 28: weaviate.v1.Vectors
	(*structpb.Struct)(nil),                    // 29: google.protobuf.Struct
	(*NumberArrayProperties)(nil),              // 30: weaviate.v1.NumberArrayProperties
	(*IntArrayProperties)(nil),                 // 31: weaviate.v1.IntArrayProperties
	(*TextArrayProperties)(nil),                // 32: weaviate.v1.TextArrayProperties
	(*BooleanArrayProperties)(nil),             // 33: weaviate.v1.BooleanArrayProperties
	(*ObjectProperties)(nil),                   // 34: weaviate.v1.ObjectProperties
	(*ObjectArrayProperties)(nil),              // 35: weaviate.v1.ObjectArrayProperties
}
var file_v1_batch_proto_depIdxs = []int32{
	4,  // 0: weaviate.v1.BatchObjectsRequest.objects:type_name -> weaviate.v1.BatchObject
	27, // 1: weaviate.v1.BatchObjectsRequest.consistency_level:type_name -> weaviate.v1.ConsistencyLevel
	5,  // 2: weaviate.v1.BatchReferencesRequest.references:type_name -> weaviate.v1.BatchReference
	27, // 3: weaviate.v1.BatchReferencesRequest.consistency_level:type_name -> weaviate.v1.ConsistencyLevel
	8,  // 4: weaviate.v1.BatchStreamRequest.start:type_name -> weaviate.v1.BatchStreamRequest.Start
	10, // 5: weaviate.v1.BatchStreamRequest.data:type_name -> weaviate.v1.BatchStreamRequest.Data
	9,  // 6: weaviate.v1.BatchStreamRequest.stop:type_name -> weaviate.v1.BatchStreamRequest.Stop
	19, // 7: weaviate.v1.BatchStreamReply.results:type_name -> weaviate.v1.BatchStreamReply.Results
	14, // 8: weaviate.v1.BatchStreamReply.shutting_down:type_name -> weaviate.v1.BatchStreamReply.ShuttingDown
	15, // 9: weaviate.v1.BatchStreamReply.shutdown:type_name -> weaviate.v1.BatchStreamReply.Shutdown
	13, // 10: weaviate.v1.BatchStreamReply.started:type_name -> weaviate.v1.BatchStreamReply.Started
	17, // 11: weaviate.v1.BatchStreamReply.backoff:type_name -> weaviate.v1.BatchStreamReply.Backoff
	18, // 12: weaviate.v1.BatchStreamReply.acks:type_name -> weaviate.v1.BatchStreamReply.Acks
	16, // 13: weaviate.v1.BatchStreamReply.out_of_memory:type_name -> weaviate.v1.BatchStreamReply.OutOfMemory
	22, // 14: weaviate.v1.BatchObject.properties:type_name -> weaviate.v1.BatchObject.Properties
	28, // 15: weaviate.v1.BatchObject.vectors:type_name -> weaviate.v1.Vectors
	25, // 16: weaviate.v1.BatchObjectsReply.errors:type_name -> weaviate.v1.BatchObjectsReply.BatchError
	26, // 17: weaviate.v1.BatchReferencesReply.errors:type_name -> weaviate.v1.BatchReferencesReply.BatchError
	27, // 18: weaviate.v1.BatchStreamRequest.Start.consistency_level:type_name -> weaviate.v1.ConsistencyLevel
	11, // 19: weaviate.v1.BatchStreamRequest.Data.objects:type_name -> weaviate.v1.BatchStreamRequest.Data.Objects
	12, // 20: weaviate.v1.BatchStreamRequest.Data.references:type_name -> weaviate.v1.BatchStreamRequest.Data.References
	4,  // 21: weaviate.v1.BatchStreamRequest.Data.Objects.values:type_name -> weaviate.v1.BatchObject
	5,  // 22: weaviate.v1.BatchStreamRequest.Data.References.values:type_name -> weaviate.v1.BatchReference
	20, // 23: weaviate.v1.BatchStreamReply.Results.errors:type_name -> weaviate.v1.BatchStreamReply.Results.Error
	21, // 24: weaviate.v1.BatchStreamReply.Results.successes:type_name -> weaviate.v1.BatchStreamReply.Results.Success
	29, // 25: weaviate.v1.BatchObject.Properties.non_ref_properties:type_name -> google.protobuf.Struct
	23, // 26: weaviate.v1.BatchObject.Properties.single_target_ref_props:type_name -> weaviate.v1.BatchObject.SingleTargetRefProps
	24, // 27: weaviate.v1.BatchObject.Properties.multi_target_ref_props:type_name -> weaviate.v1.BatchObject.MultiTargetRefProps
	30, // 28: weaviate.v1.BatchObject.Properties.number_array_properties:type_name -> weaviate.v1.NumberArrayProperties
	31, // 29: weaviate.v1.BatchObject.Properties.int_array_properties:type_name -> weaviate.v1.IntArrayProperties
	32, // 30: weaviate.v1.BatchObject.Properties.text_array_properties:type_name -> weaviate.v1.TextArrayProperties
	33, // 31: weaviate.v1.BatchObject.Properties.boolean_array_properties:type_name -> weaviate.v1.BooleanArrayProperties
	34, // 32: weaviate.v1.BatchObject.Properties.object_properties:type_name -> weaviate.v1.ObjectProperties
	35, // 33: weaviate.v1.BatchObject.Properties.object_array_properties:type_name -> weaviate.v1.ObjectArrayProperties
	34, // [34:34] is the sub-list for method output_type
	34, // [34:34] is the sub-list for method input_type
	34, // [34:34] is the sub-list for extension type_name
	34, // [34:34] is the sub-list for extension extendee
	0,  // [0:34] is the sub-list for field type_name
}

func init() { file_v1_batch_proto_init() }
func file_v1_batch_proto_init() {
	if File_v1_batch_proto != nil {
		return
	}
	file_v1_base_proto_init()
	file_v1_batch_proto_msgTypes[0].OneofWrappers = []any{}
	file_v1_batch_proto_msgTypes[1].OneofWrappers = []any{}
	file_v1_batch_proto_msgTypes[2].OneofWrappers = []any{
		(*BatchStreamRequest_Start_)(nil),
		(*BatchStreamRequest_Data_)(nil),
		(*BatchStreamRequest_Stop_)(nil),
	}
	file_v1_batch_proto_msgTypes[3].OneofWrappers = []any{
		(*BatchStreamReply_Results_)(nil),
		(*BatchStreamReply_ShuttingDown_)(nil),
		(*BatchStreamReply_Shutdown_)(nil),
		(*BatchStreamReply_Started_)(nil),
		(*BatchStreamReply_Backoff_)(nil),
		(*BatchStreamReply_Acks_)(nil),
		(*BatchStreamReply_OutOfMemory_)(nil),
	}
	file_v1_batch_proto_msgTypes[5].OneofWrappers = []any{}
	file_v1_batch_proto_msgTypes[8].OneofWrappers = []any{}
	file_v1_batch_proto_msgTypes[20].OneofWrappers = []any{
		(*BatchStreamReply_Results_Error_Uuid)(nil),
		(*BatchStreamReply_Results_Error_Beacon)(nil),
	}
	file_v1_batch_proto_msgTypes[21].OneofWrappers = []any{
		(*BatchStreamReply_Results_Success_Uuid)(nil),
		(*BatchStreamReply_Results_Success_Beacon)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_v1_batch_proto_rawDesc), len(file_v1_batch_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   27,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_v1_batch_proto_goTypes,
		DependencyIndexes: file_v1_batch_proto_depIdxs,
		MessageInfos:      file_v1_batch_proto_msgTypes,
	}.Build()
	File_v1_batch_proto = out.File
	file_v1_batch_proto_goTypes = nil
	file_v1_batch_proto_depIdxs = nil
}
