func (*IndexRuleBindingRegistryServiceUpdateResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{13}
}
Deprecated: Use IndexRuleBindingRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.
package v1
import (
	reflect "reflect"
	sync "sync"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	v1 "github.com/apache/skywalking-banyandb/api/proto/banyandb/common/v1"
)
const (
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type StreamRegistryServiceCreateRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
}
func (x *StreamRegistryServiceCreateRequest) Reset() {
	*x = StreamRegistryServiceCreateRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[0]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceCreateRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceCreateRequest) ProtoMessage() {}
func (x *StreamRegistryServiceCreateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[0]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceCreateRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{0}
}
func (x *StreamRegistryServiceCreateRequest) GetStream() *Stream {
	if x != nil {
		return x.Stream
	}
	return nil
}
type StreamRegistryServiceCreateResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *StreamRegistryServiceCreateResponse) Reset() {
	*x = StreamRegistryServiceCreateResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[1]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceCreateResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceCreateResponse) ProtoMessage() {}
func (x *StreamRegistryServiceCreateResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[1]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceCreateResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{1}
}
type StreamRegistryServiceUpdateRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
}
func (x *StreamRegistryServiceUpdateRequest) Reset() {
	*x = StreamRegistryServiceUpdateRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[2]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceUpdateRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceUpdateRequest) ProtoMessage() {}
func (x *StreamRegistryServiceUpdateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[2]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceUpdateRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{2}
}
func (x *StreamRegistryServiceUpdateRequest) GetStream() *Stream {
	if x != nil {
		return x.Stream
	}
	return nil
}
type StreamRegistryServiceUpdateResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *StreamRegistryServiceUpdateResponse) Reset() {
	*x = StreamRegistryServiceUpdateResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[3]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceUpdateResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceUpdateResponse) ProtoMessage() {}
func (x *StreamRegistryServiceUpdateResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[3]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceUpdateResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{3}
}
type StreamRegistryServiceDeleteRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
}
func (x *StreamRegistryServiceDeleteRequest) Reset() {
	*x = StreamRegistryServiceDeleteRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[4]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceDeleteRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceDeleteRequest) ProtoMessage() {}
func (x *StreamRegistryServiceDeleteRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[4]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceDeleteRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{4}
}
func (x *StreamRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata {
	if x != nil {
		return x.Metadata
	}
	return nil
}
type StreamRegistryServiceDeleteResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
}
func (x *StreamRegistryServiceDeleteResponse) Reset() {
	*x = StreamRegistryServiceDeleteResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[5]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceDeleteResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceDeleteResponse) ProtoMessage() {}
func (x *StreamRegistryServiceDeleteResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[5]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceDeleteResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{5}
}
func (x *StreamRegistryServiceDeleteResponse) GetDeleted() bool {
	if x != nil {
		return x.Deleted
	}
	return false
}
type StreamRegistryServiceGetRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
}
func (x *StreamRegistryServiceGetRequest) Reset() {
	*x = StreamRegistryServiceGetRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[6]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceGetRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceGetRequest) ProtoMessage() {}
func (x *StreamRegistryServiceGetRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[6]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceGetRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{6}
}
func (x *StreamRegistryServiceGetRequest) GetMetadata() *v1.Metadata {
	if x != nil {
		return x.Metadata
	}
	return nil
}
type StreamRegistryServiceGetResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
}
func (x *StreamRegistryServiceGetResponse) Reset() {
	*x = StreamRegistryServiceGetResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[7]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceGetResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceGetResponse) ProtoMessage() {}
func (x *StreamRegistryServiceGetResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[7]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceGetResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{7}
}
func (x *StreamRegistryServiceGetResponse) GetStream() *Stream {
	if x != nil {
		return x.Stream
	}
	return nil
}
type StreamRegistryServiceListRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}
func (x *StreamRegistryServiceListRequest) Reset() {
	*x = StreamRegistryServiceListRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[8]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceListRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceListRequest) ProtoMessage() {}
func (x *StreamRegistryServiceListRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[8]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceListRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{8}
}
func (x *StreamRegistryServiceListRequest) GetGroup() string {
	if x != nil {
		return x.Group
	}
	return ""
}
type StreamRegistryServiceListResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Stream []*Stream `protobuf:"bytes,1,rep,name=stream,proto3" json:"stream,omitempty"`
}
func (x *StreamRegistryServiceListResponse) Reset() {
	*x = StreamRegistryServiceListResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[9]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StreamRegistryServiceListResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StreamRegistryServiceListResponse) ProtoMessage() {}
func (x *StreamRegistryServiceListResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[9]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StreamRegistryServiceListResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{9}
}
func (x *StreamRegistryServiceListResponse) GetStream() []*Stream {
	if x != nil {
		return x.Stream
	}
	return nil
}
type IndexRuleBindingRegistryServiceCreateRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	IndexRuleBinding *IndexRuleBinding `protobuf:"bytes,1,opt,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
}
func (x *IndexRuleBindingRegistryServiceCreateRequest) Reset() {
	*x = IndexRuleBindingRegistryServiceCreateRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[10]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *IndexRuleBindingRegistryServiceCreateRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*IndexRuleBindingRegistryServiceCreateRequest) ProtoMessage() {}
func (x *IndexRuleBindingRegistryServiceCreateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[10]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*IndexRuleBindingRegistryServiceCreateRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{10}
}
func (x *IndexRuleBindingRegistryServiceCreateRequest) GetIndexRuleBinding() *IndexRuleBinding {
	if x != nil {
		return x.IndexRuleBinding
	}
	return nil
}
type IndexRuleBindingRegistryServiceCreateResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *IndexRuleBindingRegistryServiceCreateResponse) Reset() {
	*x = IndexRuleBindingRegistryServiceCreateResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[11]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *IndexRuleBindingRegistryServiceCreateResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*IndexRuleBindingRegistryServiceCreateResponse) ProtoMessage() {}
func (x *IndexRuleBindingRegistryServiceCreateResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[11]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*IndexRuleBindingRegistryServiceCreateResponse) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{11}
}
type IndexRuleBindingRegistryServiceUpdateRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	IndexRuleBinding *IndexRuleBinding `protobuf:"bytes,1,opt,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
}
func (x *IndexRuleBindingRegistryServiceUpdateRequest) Reset() {
	*x = IndexRuleBindingRegistryServiceUpdateRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[12]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *IndexRuleBindingRegistryServiceUpdateRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*IndexRuleBindingRegistryServiceUpdateRequest) ProtoMessage() {}
func (x *IndexRuleBindingRegistryServiceUpdateRequest) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[12]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*IndexRuleBindingRegistryServiceUpdateRequest) Descriptor() ([]byte, []int) {
	return file_banyandb_database_v1_rpc_proto_rawDescGZIP(), []int{12}
}
func (x *IndexRuleBindingRegistryServiceUpdateRequest) GetIndexRuleBinding() *IndexRuleBinding {
	if x != nil {
		return x.IndexRuleBinding
	}
	return nil
}
type IndexRuleBindingRegistryServiceUpdateResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *IndexRuleBindingRegistryServiceUpdateResponse) Reset() {
	*x = IndexRuleBindingRegistryServiceUpdateResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_banyandb_database_v1_rpc_proto_msgTypes[13]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *IndexRuleBindingRegistryServiceUpdateResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*IndexRuleBindingRegistryServiceUpdateResponse) ProtoMessage() {}
func (x *IndexRuleBindingRegistryServiceUpdateResponse) ProtoReflect() protoreflect.Message {
	mi := &file_banyandb_database_v1_rpc_proto_msgTypes[13]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}