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

package dataflow

import (
	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	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)
)

// CRRFStatus represents the lifecycle state of CRRF for a cluster.
type CRRFStatus int32

const (
	CRRFStatus_CRRF_STATUS_UNSPECIFIED CRRFStatus = 0
	CRRFStatus_CRRF_STATUS_DISABLED    CRRFStatus = 1
	CRRFStatus_CRRF_STATUS_ENABLING    CRRFStatus = 2
	CRRFStatus_CRRF_STATUS_ENABLED     CRRFStatus = 3
	CRRFStatus_CRRF_STATUS_DISABLING   CRRFStatus = 4
	CRRFStatus_CRRF_STATUS_FAILED      CRRFStatus = 5
)

// Enum value maps for CRRFStatus.
var (
	CRRFStatus_name = map[int32]string{
		0: "CRRF_STATUS_UNSPECIFIED",
		1: "CRRF_STATUS_DISABLED",
		2: "CRRF_STATUS_ENABLING",
		3: "CRRF_STATUS_ENABLED",
		4: "CRRF_STATUS_DISABLING",
		5: "CRRF_STATUS_FAILED",
	}
	CRRFStatus_value = map[string]int32{
		"CRRF_STATUS_UNSPECIFIED": 0,
		"CRRF_STATUS_DISABLED":    1,
		"CRRF_STATUS_ENABLING":    2,
		"CRRF_STATUS_ENABLED":     3,
		"CRRF_STATUS_DISABLING":   4,
		"CRRF_STATUS_FAILED":      5,
	}
)

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

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

func (CRRFStatus) Descriptor() protoreflect.EnumDescriptor {
	return file_dataflow_crrf_proto_enumTypes[0].Descriptor()
}

func (CRRFStatus) Type() protoreflect.EnumType {
	return &file_dataflow_crrf_proto_enumTypes[0]
}

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

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

type EnableCRRFRequest struct {
	state     protoimpl.MessageState `protogen:"open.v1"`
	OrgId     uint64                 `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ProjectId uint64                 `protobuf:"varint,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId uint64                 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The AWS region where the secondary backup bucket will be created.
	SecondaryRegion string `protobuf:"bytes,4,opt,name=secondary_region,json=secondaryRegion,proto3" json:"secondary_region,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

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

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

func (*EnableCRRFRequest) ProtoMessage() {}

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

func (x *EnableCRRFRequest) GetOrgId() uint64 {
	if x != nil {
		return x.OrgId
	}
	return 0
}

func (x *EnableCRRFRequest) GetProjectId() uint64 {
	if x != nil {
		return x.ProjectId
	}
	return 0
}

func (x *EnableCRRFRequest) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

func (x *EnableCRRFRequest) GetSecondaryRegion() string {
	if x != nil {
		return x.SecondaryRegion
	}
	return ""
}

type EnableCRRFResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Status        CRRFStatus             `protobuf:"varint,1,opt,name=status,proto3,enum=dataflow.CRRFStatus" json:"status,omitempty"`
	Message       string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*EnableCRRFResponse) ProtoMessage() {}

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

func (x *EnableCRRFResponse) GetStatus() CRRFStatus {
	if x != nil {
		return x.Status
	}
	return CRRFStatus_CRRF_STATUS_UNSPECIFIED
}

func (x *EnableCRRFResponse) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

type QueryCRRFRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	OrgId         uint64                 `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ProjectId     uint64                 `protobuf:"varint,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId     uint64                 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*QueryCRRFRequest) ProtoMessage() {}

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

func (x *QueryCRRFRequest) GetOrgId() uint64 {
	if x != nil {
		return x.OrgId
	}
	return 0
}

func (x *QueryCRRFRequest) GetProjectId() uint64 {
	if x != nil {
		return x.ProjectId
	}
	return 0
}

func (x *QueryCRRFRequest) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

type QueryCRRFResponse struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	ClusterId         uint64                 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Status            CRRFStatus             `protobuf:"varint,2,opt,name=status,proto3,enum=dataflow.CRRFStatus" json:"status,omitempty"`
	SecondaryRegion   string                 `protobuf:"bytes,3,opt,name=secondary_region,json=secondaryRegion,proto3" json:"secondary_region,omitempty"`
	MasterBucketId    uint64                 `protobuf:"varint,4,opt,name=master_bucket_id,json=masterBucketId,proto3" json:"master_bucket_id,omitempty"`
	SecondaryBucketId uint64                 `protobuf:"varint,5,opt,name=secondary_bucket_id,json=secondaryBucketId,proto3" json:"secondary_bucket_id,omitempty"`
	ErrorMessage      string                 `protobuf:"bytes,9,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*QueryCRRFResponse) ProtoMessage() {}

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

func (x *QueryCRRFResponse) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

func (x *QueryCRRFResponse) GetStatus() CRRFStatus {
	if x != nil {
		return x.Status
	}
	return CRRFStatus_CRRF_STATUS_UNSPECIFIED
}

func (x *QueryCRRFResponse) GetSecondaryRegion() string {
	if x != nil {
		return x.SecondaryRegion
	}
	return ""
}

func (x *QueryCRRFResponse) GetMasterBucketId() uint64 {
	if x != nil {
		return x.MasterBucketId
	}
	return 0
}

func (x *QueryCRRFResponse) GetSecondaryBucketId() uint64 {
	if x != nil {
		return x.SecondaryBucketId
	}
	return 0
}

func (x *QueryCRRFResponse) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

type DisableCRRFRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	OrgId         uint64                 `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ProjectId     uint64                 `protobuf:"varint,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId     uint64                 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*DisableCRRFRequest) ProtoMessage() {}

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

func (x *DisableCRRFRequest) GetOrgId() uint64 {
	if x != nil {
		return x.OrgId
	}
	return 0
}

func (x *DisableCRRFRequest) GetProjectId() uint64 {
	if x != nil {
		return x.ProjectId
	}
	return 0
}

func (x *DisableCRRFRequest) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

type DisableCRRFResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Status        CRRFStatus             `protobuf:"varint,1,opt,name=status,proto3,enum=dataflow.CRRFStatus" json:"status,omitempty"`
	Message       string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*DisableCRRFResponse) ProtoMessage() {}

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

func (x *DisableCRRFResponse) GetStatus() CRRFStatus {
	if x != nil {
		return x.Status
	}
	return CRRFStatus_CRRF_STATUS_UNSPECIFIED
}

func (x *DisableCRRFResponse) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

var File_dataflow_crrf_proto protoreflect.FileDescriptor

const file_dataflow_crrf_proto_rawDesc = "" +
	"\n" +
	"\x13dataflow/crrf.proto\x12\bdataflow\x1a\x1cgoogle/api/annotations.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\"\x93\x01\n" +
	"\x11EnableCRRFRequest\x12\x15\n" +
	"\x06org_id\x18\x01 \x01(\x04R\x05orgId\x12\x1d\n" +
	"\n" +
	"project_id\x18\x02 \x01(\x04R\tprojectId\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x03 \x01(\x04R\tclusterId\x12)\n" +
	"\x10secondary_region\x18\x04 \x01(\tR\x0fsecondaryRegion\"\\\n" +
	"\x12EnableCRRFResponse\x12,\n" +
	"\x06status\x18\x01 \x01(\x0e2\x14.dataflow.CRRFStatusR\x06status\x12\x18\n" +
	"\amessage\x18\x02 \x01(\tR\amessage\"g\n" +
	"\x10QueryCRRFRequest\x12\x15\n" +
	"\x06org_id\x18\x01 \x01(\x04R\x05orgId\x12\x1d\n" +
	"\n" +
	"project_id\x18\x02 \x01(\x04R\tprojectId\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x03 \x01(\x04R\tclusterId\"\x8a\x02\n" +
	"\x11QueryCRRFResponse\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x01 \x01(\x04R\tclusterId\x12,\n" +
	"\x06status\x18\x02 \x01(\x0e2\x14.dataflow.CRRFStatusR\x06status\x12)\n" +
	"\x10secondary_region\x18\x03 \x01(\tR\x0fsecondaryRegion\x12(\n" +
	"\x10master_bucket_id\x18\x04 \x01(\x04R\x0emasterBucketId\x12.\n" +
	"\x13secondary_bucket_id\x18\x05 \x01(\x04R\x11secondaryBucketId\x12#\n" +
	"\rerror_message\x18\t \x01(\tR\ferrorMessage\"i\n" +
	"\x12DisableCRRFRequest\x12\x15\n" +
	"\x06org_id\x18\x01 \x01(\x04R\x05orgId\x12\x1d\n" +
	"\n" +
	"project_id\x18\x02 \x01(\x04R\tprojectId\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x03 \x01(\x04R\tclusterId\"]\n" +
	"\x13DisableCRRFResponse\x12,\n" +
	"\x06status\x18\x01 \x01(\x0e2\x14.dataflow.CRRFStatusR\x06status\x12\x18\n" +
	"\amessage\x18\x02 \x01(\tR\amessage*\xa9\x01\n" +
	"\n" +
	"CRRFStatus\x12\x1b\n" +
	"\x17CRRF_STATUS_UNSPECIFIED\x10\x00\x12\x18\n" +
	"\x14CRRF_STATUS_DISABLED\x10\x01\x12\x18\n" +
	"\x14CRRF_STATUS_ENABLING\x10\x02\x12\x17\n" +
	"\x13CRRF_STATUS_ENABLED\x10\x03\x12\x19\n" +
	"\x15CRRF_STATUS_DISABLING\x10\x04\x12\x16\n" +
	"\x12CRRF_STATUS_FAILED\x10\x052\x92\x04\n" +
	"\x12CRRFConsoleService\x12\xa9\x01\n" +
	"\n" +
	"EnableCRRF\x12\x1b.dataflow.EnableCRRFRequest\x1a\x1c.dataflow.EnableCRRFResponse\"`\x92A\f*\n" +
	"EnableCRRF\x82\xd3\xe4\x93\x02K:\x01*\"F/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/crrf\x12\xa2\x01\n" +
	"\tQueryCRRF\x12\x1a.dataflow.QueryCRRFRequest\x1a\x1b.dataflow.QueryCRRFResponse\"\\\x92A\v*\tQueryCRRF\x82\xd3\xe4\x93\x02H\x12F/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/crrf\x12\xaa\x01\n" +
	"\vDisableCRRF\x12\x1c.dataflow.DisableCRRFRequest\x1a\x1d.dataflow.DisableCRRFResponse\"^\x92A\r*\vDisableCRRF\x82\xd3\xe4\x93\x02H*F/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/crrfBIZGgithub.com/tidbcloud/dataflow-service/idl/pbgen/proto/dataflow;dataflowb\x06proto3"

var (
	file_dataflow_crrf_proto_rawDescOnce sync.Once
	file_dataflow_crrf_proto_rawDescData []byte
)

func file_dataflow_crrf_proto_rawDescGZIP() []byte {
	file_dataflow_crrf_proto_rawDescOnce.Do(func() {
		file_dataflow_crrf_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_dataflow_crrf_proto_rawDesc), len(file_dataflow_crrf_proto_rawDesc)))
	})
	return file_dataflow_crrf_proto_rawDescData
}

var file_dataflow_crrf_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_dataflow_crrf_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
var file_dataflow_crrf_proto_goTypes = []any{
	(CRRFStatus)(0),             // 0: dataflow.CRRFStatus
	(*EnableCRRFRequest)(nil),   // 1: dataflow.EnableCRRFRequest
	(*EnableCRRFResponse)(nil),  // 2: dataflow.EnableCRRFResponse
	(*QueryCRRFRequest)(nil),    // 3: dataflow.QueryCRRFRequest
	(*QueryCRRFResponse)(nil),   // 4: dataflow.QueryCRRFResponse
	(*DisableCRRFRequest)(nil),  // 5: dataflow.DisableCRRFRequest
	(*DisableCRRFResponse)(nil), // 6: dataflow.DisableCRRFResponse
}
var file_dataflow_crrf_proto_depIdxs = []int32{
	0, // 0: dataflow.EnableCRRFResponse.status:type_name -> dataflow.CRRFStatus
	0, // 1: dataflow.QueryCRRFResponse.status:type_name -> dataflow.CRRFStatus
	0, // 2: dataflow.DisableCRRFResponse.status:type_name -> dataflow.CRRFStatus
	1, // 3: dataflow.CRRFConsoleService.EnableCRRF:input_type -> dataflow.EnableCRRFRequest
	3, // 4: dataflow.CRRFConsoleService.QueryCRRF:input_type -> dataflow.QueryCRRFRequest
	5, // 5: dataflow.CRRFConsoleService.DisableCRRF:input_type -> dataflow.DisableCRRFRequest
	2, // 6: dataflow.CRRFConsoleService.EnableCRRF:output_type -> dataflow.EnableCRRFResponse
	4, // 7: dataflow.CRRFConsoleService.QueryCRRF:output_type -> dataflow.QueryCRRFResponse
	6, // 8: dataflow.CRRFConsoleService.DisableCRRF:output_type -> dataflow.DisableCRRFResponse
	6, // [6:9] is the sub-list for method output_type
	3, // [3:6] is the sub-list for method input_type
	3, // [3:3] is the sub-list for extension type_name
	3, // [3:3] is the sub-list for extension extendee
	0, // [0:3] is the sub-list for field type_name
}

func init() { file_dataflow_crrf_proto_init() }
func file_dataflow_crrf_proto_init() {
	if File_dataflow_crrf_proto != nil {
		return
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_dataflow_crrf_proto_rawDesc), len(file_dataflow_crrf_proto_rawDesc)),
			NumEnums:      1,
			NumMessages:   6,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_dataflow_crrf_proto_goTypes,
		DependencyIndexes: file_dataflow_crrf_proto_depIdxs,
		EnumInfos:         file_dataflow_crrf_proto_enumTypes,
		MessageInfos:      file_dataflow_crrf_proto_msgTypes,
	}.Build()
	File_dataflow_crrf_proto = out.File
	file_dataflow_crrf_proto_goTypes = nil
	file_dataflow_crrf_proto_depIdxs = nil
}