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

package dataflow

import (
	_ "github.com/envoyproxy/protoc-gen-validate/validate"
	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options"
	_ "github.com/tidbcloud/dataflow-service/idl/pbgen/proto/agent"
	_ "github.com/tidbcloud/dataflow-service/idl/pbgen/proto/common"
	_ "go.buf.build/protocolbuffers/go/linuxgit/tidbcloud/base"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	_ "google.golang.org/genproto/googleapis/api/httpbody"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	_ "google.golang.org/protobuf/types/known/anypb"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	_ "google.golang.org/protobuf/types/known/timestamppb"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

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

type GetPrivateLinkEndpointResp_Phase int32

const (
	GetPrivateLinkEndpointResp_Pending           GetPrivateLinkEndpointResp_Phase = 0 // means it's still creating.
	GetPrivateLinkEndpointResp_PendingAcceptance GetPrivateLinkEndpointResp_Phase = 1 // means user should accept the private link request in their account.
	GetPrivateLinkEndpointResp_Available         GetPrivateLinkEndpointResp_Phase = 2 // means private link is ready.
	GetPrivateLinkEndpointResp_Failed            GetPrivateLinkEndpointResp_Phase = 3 // failed to create the private link endpoint, then message will contain detailed message
)

// Enum value maps for GetPrivateLinkEndpointResp_Phase.
var (
	GetPrivateLinkEndpointResp_Phase_name = map[int32]string{
		0: "Pending",
		1: "PendingAcceptance",
		2: "Available",
		3: "Failed",
	}
	GetPrivateLinkEndpointResp_Phase_value = map[string]int32{
		"Pending":           0,
		"PendingAcceptance": 1,
		"Available":         2,
		"Failed":            3,
	}
)

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

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

func (GetPrivateLinkEndpointResp_Phase) Descriptor() protoreflect.EnumDescriptor {
	return file_dataflow_dataflow_proto_enumTypes[0].Descriptor()
}

func (GetPrivateLinkEndpointResp_Phase) Type() protoreflect.EnumType {
	return &file_dataflow_dataflow_proto_enumTypes[0]
}

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

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

type CreateConnProfileReq struct {
	state     protoimpl.MessageState `protogen:"open.v1"`
	ProjectId uint64                 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId uint64                 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Name      string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// todo: make it a enum? we can make it a enum, but the validation err msg is not clear, see Operation in dm.proto.
	Type                string  `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Region              string  `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	ConnMethod          string  `protobuf:"bytes,7,opt,name=conn_method,json=connMethod,proto3" json:"conn_method,omitempty"`
	EndpointServiceName *string `protobuf:"bytes,8,opt,name=endpoint_service_name,json=endpointServiceName,proto3,oneof" json:"endpoint_service_name,omitempty"`
	Host                *string `protobuf:"bytes,9,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Port                uint32  `protobuf:"varint,10,opt,name=port,proto3" json:"port,omitempty"`
	User                string  `protobuf:"bytes,11,opt,name=user,proto3" json:"user,omitempty"`
	Password            string  `protobuf:"bytes,12,opt,name=password,proto3" json:"password,omitempty"`
	SslCa               string  `protobuf:"bytes,13,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert             string  `protobuf:"bytes,14,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey              string  `protobuf:"bytes,15,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	OrgId               uint64  `protobuf:"varint,150,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

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

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

func (*CreateConnProfileReq) ProtoMessage() {}

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

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

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

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

func (x *CreateConnProfileReq) GetType() string {
	if x != nil {
		return x.Type
	}
	return ""
}

func (x *CreateConnProfileReq) GetRegion() string {
	if x != nil {
		return x.Region
	}
	return ""
}

func (x *CreateConnProfileReq) GetConnMethod() string {
	if x != nil {
		return x.ConnMethod
	}
	return ""
}

func (x *CreateConnProfileReq) GetEndpointServiceName() string {
	if x != nil && x.EndpointServiceName != nil {
		return *x.EndpointServiceName
	}
	return ""
}

func (x *CreateConnProfileReq) GetHost() string {
	if x != nil && x.Host != nil {
		return *x.Host
	}
	return ""
}

func (x *CreateConnProfileReq) GetPort() uint32 {
	if x != nil {
		return x.Port
	}
	return 0
}

func (x *CreateConnProfileReq) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *CreateConnProfileReq) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

func (x *CreateConnProfileReq) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *CreateConnProfileReq) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *CreateConnProfileReq) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

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

type CreateConnProfileResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CreateConnProfileResp) ProtoMessage() {}

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

func (x *CreateConnProfileResp) GetId() uint64 {
	if x != nil {
		return x.Id
	}
	return 0
}

type GetIPWhiteListReq struct {
	state     protoimpl.MessageState `protogen:"open.v1"`
	ProjectId uint64                 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId uint64                 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	OrgId     uint64                 `protobuf:"varint,150,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// only direct and vpc-peering need white list, private-link don't
	ConnMethod    string `protobuf:"bytes,3,opt,name=conn_method,json=connMethod,proto3" json:"conn_method,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetIPWhiteListReq) ProtoMessage() {}

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

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

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

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

func (x *GetIPWhiteListReq) GetConnMethod() string {
	if x != nil {
		return x.ConnMethod
	}
	return ""
}

type GetIPWhiteListResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ips           []string               `protobuf:"bytes,1,rep,name=ips,proto3" json:"ips,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetIPWhiteListResp) ProtoMessage() {}

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

func (x *GetIPWhiteListResp) GetIps() []string {
	if x != nil {
		return x.Ips
	}
	return nil
}

type CreatePrivateLinkEndpointReq struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	ProjectId           uint64                 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId           uint64                 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	EndpointServiceName string                 `protobuf:"bytes,4,opt,name=endpoint_service_name,json=endpointServiceName,proto3" json:"endpoint_service_name,omitempty"`
	OrgId               uint64                 `protobuf:"varint,150,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

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

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

func (*CreatePrivateLinkEndpointReq) ProtoMessage() {}

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

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

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

func (x *CreatePrivateLinkEndpointReq) GetEndpointServiceName() string {
	if x != nil {
		return x.EndpointServiceName
	}
	return ""
}

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

type CreatePrivateLinkEndpointResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CreatePrivateLinkEndpointResp) ProtoMessage() {}

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

func (x *CreatePrivateLinkEndpointResp) GetId() uint64 {
	if x != nil {
		return x.Id
	}
	return 0
}

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

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

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

func (*GetPrivateLinkEndpointReq) ProtoMessage() {}

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

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

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

func (x *GetPrivateLinkEndpointReq) GetId() uint64 {
	if x != nil {
		return x.Id
	}
	return 0
}

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

type GetPrivateLinkEndpointResp struct {
	state         protoimpl.MessageState           `protogen:"open.v1"`
	Phase         GetPrivateLinkEndpointResp_Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=dataflow.GetPrivateLinkEndpointResp_Phase" json:"phase,omitempty"`
	Message       string                           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	EndpointId    string                           `protobuf:"bytes,3,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetPrivateLinkEndpointResp) ProtoMessage() {}

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

func (x *GetPrivateLinkEndpointResp) GetPhase() GetPrivateLinkEndpointResp_Phase {
	if x != nil {
		return x.Phase
	}
	return GetPrivateLinkEndpointResp_Pending
}

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

func (x *GetPrivateLinkEndpointResp) GetEndpointId() string {
	if x != nil {
		return x.EndpointId
	}
	return ""
}

type ValidateRemoteDBConnectivityReq struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	ProjectId           uint64                 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId           uint64                 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ConnMethod          string                 `protobuf:"bytes,3,opt,name=conn_method,json=connMethod,proto3" json:"conn_method,omitempty"`
	EndpointServiceName *string                `protobuf:"bytes,4,opt,name=endpoint_service_name,json=endpointServiceName,proto3,oneof" json:"endpoint_service_name,omitempty"`
	Host                *string                `protobuf:"bytes,5,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Port                uint32                 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	User                string                 `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"`
	Password            string                 `protobuf:"bytes,8,opt,name=password,proto3" json:"password,omitempty"`
	SslCa               string                 `protobuf:"bytes,9,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert             string                 `protobuf:"bytes,10,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey              string                 `protobuf:"bytes,11,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	// right now we don't use this parameter, will use it when we support pg.
	// we put here to check in backend that user has set this parameter.
	Type          string `protobuf:"bytes,12,opt,name=type,proto3" json:"type,omitempty"`
	OrgId         uint64 `protobuf:"varint,150,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*ValidateRemoteDBConnectivityReq) ProtoMessage() {}

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

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

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

func (x *ValidateRemoteDBConnectivityReq) GetConnMethod() string {
	if x != nil {
		return x.ConnMethod
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetEndpointServiceName() string {
	if x != nil && x.EndpointServiceName != nil {
		return *x.EndpointServiceName
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetHost() string {
	if x != nil && x.Host != nil {
		return *x.Host
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetPort() uint32 {
	if x != nil {
		return x.Port
	}
	return 0
}

func (x *ValidateRemoteDBConnectivityReq) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

func (x *ValidateRemoteDBConnectivityReq) GetType() string {
	if x != nil {
		return x.Type
	}
	return ""
}

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

type ValidateClusterConnectivityReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ProjectId     uint64                 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ClusterId     uint64                 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	User          string                 `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty"`
	Password      string                 `protobuf:"bytes,9,opt,name=password,proto3" json:"password,omitempty"`
	OrgId         uint64                 `protobuf:"varint,150,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*ValidateClusterConnectivityReq) ProtoMessage() {}

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

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

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

func (x *ValidateClusterConnectivityReq) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *ValidateClusterConnectivityReq) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

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

type ValidateRemoteDBConnectivityResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	DbVersion     string                 `protobuf:"bytes,1,opt,name=db_version,json=dbVersion,proto3" json:"db_version,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*ValidateRemoteDBConnectivityResp) ProtoMessage() {}

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

func (x *ValidateRemoteDBConnectivityResp) GetDbVersion() string {
	if x != nil {
		return x.DbVersion
	}
	return ""
}

type ConnProfile struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	Id                  uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Version             string                 `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Region              string                 `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
	Host                *string                `protobuf:"bytes,6,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Port                uint32                 `protobuf:"varint,7,opt,name=port,proto3" json:"port,omitempty"`
	User                string                 `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty"`
	ConnMethod          string                 `protobuf:"bytes,9,opt,name=conn_method,json=connMethod,proto3" json:"conn_method,omitempty"`
	EndpointServiceName *string                `protobuf:"bytes,10,opt,name=endpoint_service_name,json=endpointServiceName,proto3,oneof" json:"endpoint_service_name,omitempty"`
	Password            string                 `protobuf:"bytes,11,opt,name=password,proto3" json:"password,omitempty"`
	SslCa               string                 `protobuf:"bytes,12,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert             string                 `protobuf:"bytes,13,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey              string                 `protobuf:"bytes,14,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

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

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

func (*ConnProfile) ProtoMessage() {}

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

func (x *ConnProfile) GetId() uint64 {
	if x != nil {
		return x.Id
	}
	return 0
}

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

func (x *ConnProfile) GetType() string {
	if x != nil {
		return x.Type
	}
	return ""
}

func (x *ConnProfile) GetVersion() string {
	if x != nil {
		return x.Version
	}
	return ""
}

func (x *ConnProfile) GetRegion() string {
	if x != nil {
		return x.Region
	}
	return ""
}

func (x *ConnProfile) GetHost() string {
	if x != nil && x.Host != nil {
		return *x.Host
	}
	return ""
}

func (x *ConnProfile) GetPort() uint32 {
	if x != nil {
		return x.Port
	}
	return 0
}

func (x *ConnProfile) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *ConnProfile) GetConnMethod() string {
	if x != nil {
		return x.ConnMethod
	}
	return ""
}

func (x *ConnProfile) GetEndpointServiceName() string {
	if x != nil && x.EndpointServiceName != nil {
		return *x.EndpointServiceName
	}
	return ""
}

func (x *ConnProfile) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

func (x *ConnProfile) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *ConnProfile) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *ConnProfile) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

var File_dataflow_dataflow_proto protoreflect.FileDescriptor

const file_dataflow_dataflow_proto_rawDesc = "" +
	"\n" +
	"\x17dataflow/dataflow.proto\x12\bdataflow\x1a\x11agent/agent.proto\x1a\x0fbase/base.proto\x1a\x13common/common.proto\x1a\x1cgoogle/api/annotations.proto\x1a\x19google/api/httpbody.proto\x1a\x19google/protobuf/any.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a\x17validate/validate.proto\"\xcc\x06\n" +
	"\x14CreateConnProfileReq\x12&\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04B\a\xfaB\x042\x02 \x00R\tprojectId\x12&\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04B\a\xfaB\x042\x02 \x00R\tclusterId\x120\n" +
	"\x04name\x18\x03 \x01(\tB\x1c\xfaB\x19r\x172\x15^[A-Za-z][\\w-]{0,59}$R\x04name\x12k\n" +
	"\x04type\x18\x04 \x01(\tBW\xfaBTrRR\x05mysqlR\x10aws-aurora-mysqlR\raws-rds-mysqlR\x12google-cloud-mysqlR\x14azure-flexible-mysqlR\x04type\x12\x1f\n" +
	"\x06region\x18\x06 \x01(\tB\a\xfaB\x04r\x02\x18@R\x06region\x12I\n" +
	"\vconn_method\x18\a \x01(\tB(\xfaB%r#R\x06directR\vvpc-peeringR\fprivate-linkR\n" +
	"connMethod\x12k\n" +
	"\x15endpoint_service_name\x18\b \x01(\tB2\xfaB/r-\x18\x80\x042(^(com.amazonaws.vpce|/subscriptions/).*$H\x00R\x13endpointServiceName\x88\x01\x01\x12$\n" +
	"\x04host\x18\t \x01(\tB\v\xfaB\br\x06\x18\x80\x02\xa8\x01\x01H\x01R\x04host\x88\x01\x01\x12\x1b\n" +
	"\x04port\x18\n" +
	" \x01(\rB\a\xfaB\x04*\x02 \x00R\x04port\x12\x1d\n" +
	"\x04user\x18\v \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\x04user\x12%\n" +
	"\bpassword\x18\f \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\bpassword\x12\x15\n" +
	"\x06ssl_ca\x18\r \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\x0e \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\x0f \x01(\tR\x06sslKey\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId:]\x92AZ\n" +
	"X\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\xd2\x01\x04name\xd2\x01\x04type\xd2\x01\vconn_method\xd2\x01\x04port\xd2\x01\x04user\xd2\x01\bpasswordB\x18\n" +
	"\x16_endpoint_service_nameB\a\n" +
	"\x05_host\"'\n" +
	"\x15CreateConnProfileResp\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\x04R\x02id\"\xde\x01\n" +
	"\x11GetIPWhiteListReq\x12\x1d\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04R\tprojectId\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04R\tclusterId\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId\x12;\n" +
	"\vconn_method\x18\x03 \x01(\tB\x1a\xfaB\x17r\x15R\x06directR\vvpc-peeringR\n" +
	"connMethod:6\x92A3\n" +
	"1\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\xd2\x01\vconn_method\"&\n" +
	"\x12GetIPWhiteListResp\x12\x10\n" +
	"\x03ips\x18\x01 \x03(\tR\x03ips\"\x98\x02\n" +
	"\x1cCreatePrivateLinkEndpointReq\x12&\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04B\a\xfaB\x042\x02 \x00R\tprojectId\x12&\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04B\a\xfaB\x042\x02 \x00R\tclusterId\x12f\n" +
	"\x15endpoint_service_name\x18\x04 \x01(\tB2\xfaB/r-\x18\x80\x042(^(com.amazonaws.vpce|/subscriptions/).*$R\x13endpointServiceName\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId:(\x92A%\n" +
	"#\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\"/\n" +
	"\x1dCreatePrivateLinkEndpointResp\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\x04R\x02id\"\xcb\x01\n" +
	"\x19GetPrivateLinkEndpointReq\x12&\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04B\a\xfaB\x042\x02 \x00R\tprojectId\x12&\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04B\a\xfaB\x042\x02 \x00R\tclusterId\x12\x17\n" +
	"\x02id\x18\x03 \x01(\x04B\a\xfaB\x042\x02 \x00R\x02id\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId:-\x92A*\n" +
	"(\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\xd2\x01\x02id\"\xe1\x01\n" +
	"\x1aGetPrivateLinkEndpointResp\x12@\n" +
	"\x05phase\x18\x01 \x01(\x0e2*.dataflow.GetPrivateLinkEndpointResp.PhaseR\x05phase\x12\x18\n" +
	"\amessage\x18\x02 \x01(\tR\amessage\x12\x1f\n" +
	"\vendpoint_id\x18\x03 \x01(\tR\n" +
	"endpointId\"F\n" +
	"\x05Phase\x12\v\n" +
	"\aPending\x10\x00\x12\x15\n" +
	"\x11PendingAcceptance\x10\x01\x12\r\n" +
	"\tAvailable\x10\x02\x12\n" +
	"\n" +
	"\x06Failed\x10\x03\"\xfd\x05\n" +
	"\x1fValidateRemoteDBConnectivityReq\x12&\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04B\a\xfaB\x042\x02 \x00R\tprojectId\x12&\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04B\a\xfaB\x042\x02 \x00R\tclusterId\x12I\n" +
	"\vconn_method\x18\x03 \x01(\tB(\xfaB%r#R\x06directR\vvpc-peeringR\fprivate-linkR\n" +
	"connMethod\x12k\n" +
	"\x15endpoint_service_name\x18\x04 \x01(\tB2\xfaB/r-\x18\x80\x042(^(com.amazonaws.vpce|/subscriptions/).*$H\x00R\x13endpointServiceName\x88\x01\x01\x12$\n" +
	"\x04host\x18\x05 \x01(\tB\v\xfaB\br\x06\x18\x80\x02\xa8\x01\x01H\x01R\x04host\x88\x01\x01\x12\x1b\n" +
	"\x04port\x18\x06 \x01(\rB\a\xfaB\x04*\x02 \x00R\x04port\x12\x1d\n" +
	"\x04user\x18\a \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\x04user\x12%\n" +
	"\bpassword\x18\b \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\bpassword\x12\x15\n" +
	"\x06ssl_ca\x18\t \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\n" +
	" \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\v \x01(\tR\x06sslKey\x12k\n" +
	"\x04type\x18\f \x01(\tBW\xfaBTrRR\x05mysqlR\x10aws-aurora-mysqlR\raws-rds-mysqlR\x12google-cloud-mysqlR\x14azure-flexible-mysqlR\x04type\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId:V\x92AS\n" +
	"Q\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\xd2\x01\vconn_method\xd2\x01\x04port\xd2\x01\x04user\xd2\x01\bpassword\xd2\x01\x04typeB\x18\n" +
	"\x16_endpoint_service_nameB\a\n" +
	"\x05_host\"\x8a\x02\n" +
	"\x1eValidateClusterConnectivityReq\x12&\n" +
	"\n" +
	"project_id\x18\x01 \x01(\x04B\a\xfaB\x042\x02 \x00R\tprojectId\x12&\n" +
	"\n" +
	"cluster_id\x18\x02 \x01(\x04B\a\xfaB\x042\x02 \x00R\tclusterId\x12\x1d\n" +
	"\x04user\x18\b \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\x04user\x12%\n" +
	"\bpassword\x18\t \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\bpassword\x12\x16\n" +
	"\x06org_id\x18\x96\x01 \x01(\x04R\x05orgId::\x92A7\n" +
	"5\xd2\x01\x06org_id\xd2\x01\n" +
	"project_id\xd2\x01\n" +
	"cluster_id\xd2\x01\x04user\xd2\x01\bpassword\"A\n" +
	" ValidateRemoteDBConnectivityResp\x12\x1d\n" +
	"\n" +
	"db_version\x18\x01 \x01(\tR\tdbVersion\"\xa6\x04\n" +
	"\vConnProfile\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\x04R\x02id\x12\x12\n" +
	"\x04name\x18\x02 \x01(\tR\x04name\x12\x12\n" +
	"\x04type\x18\x03 \x01(\tR\x04type\x12\x18\n" +
	"\aversion\x18\x04 \x01(\tR\aversion\x12\x16\n" +
	"\x06region\x18\x05 \x01(\tR\x06region\x12$\n" +
	"\x04host\x18\x06 \x01(\tB\v\xfaB\br\x06\x18\x80\x02\xa8\x01\x01H\x00R\x04host\x88\x01\x01\x12\x1b\n" +
	"\x04port\x18\a \x01(\rB\a\xfaB\x04*\x02 \x00R\x04port\x12\x1d\n" +
	"\x04user\x18\b \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\x04user\x12I\n" +
	"\vconn_method\x18\t \x01(\tB(\xfaB%r#R\x06directR\vvpc-peeringR\fprivate-linkR\n" +
	"connMethod\x12k\n" +
	"\x15endpoint_service_name\x18\n" +
	" \x01(\tB2\xfaB/r-\x18\x80\x042(^(com.amazonaws.vpce|/subscriptions/).*$H\x01R\x13endpointServiceName\x88\x01\x01\x12%\n" +
	"\bpassword\x18\v \x01(\tB\t\xfaB\x06r\x04\x10\x01\x18@R\bpassword\x12\x15\n" +
	"\x06ssl_ca\x18\f \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\r \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\x0e \x01(\tR\x06sslKeyB\a\n" +
	"\x05_hostB\x18\n" +
	"\x16_endpoint_service_name2\x99\v\n" +
	"\x12ConnProfileService\x12\xcf\x01\n" +
	"\x11CreateConnProfile\x12\x1e.dataflow.CreateConnProfileReq\x1a\x1f.dataflow.CreateConnProfileResp\"y\x92A\x13*\x11CreateConnProfile\x82\xd3\xe4\x93\x02]:\x01*\"X/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/conn-profiles\x12\xce\x01\n" +
	"\x0eGetIPWhiteList\x12\x1b.dataflow.GetIPWhiteListReq\x1a\x1c.dataflow.GetIPWhiteListResp\"\x80\x01\x92A\x10*\x0eGetIPWhiteList\x82\xd3\xe4\x93\x02g\x12e/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/connectivity/ip-white-list\x12\xf0\x01\n" +
	"\x19CreatePrivateLinkEndpoint\x12&.dataflow.CreatePrivateLinkEndpointReq\x1a'.dataflow.CreatePrivateLinkEndpointResp\"\x81\x01\x92A\x1b*\x19CreatePrivateLinkEndpoint\x82\xd3\xe4\x93\x02]:\x01*\"X/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/private-links\x12\xe6\x01\n" +
	"\x16GetPrivateLinkEndpoint\x12#.dataflow.GetPrivateLinkEndpointReq\x1a$.dataflow.GetPrivateLinkEndpointResp\"\x80\x01\x92A\x18*\x16GetPrivateLinkEndpoint\x82\xd3\xe4\x93\x02_\x12]/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/private-links/{id}\x12\x8b\x02\n" +
	"\x1cValidateRemoteDBConnectivity\x12).dataflow.ValidateRemoteDBConnectivityReq\x1a*.dataflow.ValidateRemoteDBConnectivityResp\"\x93\x01\x92A\x1e*\x1cValidateRemoteDBConnectivity\x82\xd3\xe4\x93\x02l:\x01*\"g/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/connectivity/validate/remote\x12\xf5\x01\n" +
	"\x1bValidateClusterConnectivity\x12(.dataflow.ValidateClusterConnectivityReq\x1a\x16.google.protobuf.Empty\"\x93\x01\x92A\x1d*\x1bValidateClusterConnectivity\x82\xd3\xe4\x93\x02m:\x01*\"h/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/dataflow/connectivity/validate/clusterB\x89\x02\x92A\xbc\x01\x12\x052\x030.1*\x01\x02ZY\n" +
	"W\n" +
	"\x06bearer\x12M\b\x02\x128Authentication token, prefixed by Bearer: Bearer <token>\x1a\rAuthorization \x02b\f\n" +
	"\n" +
	"\n" +
	"\x06bearer\x12\x00rG\n" +
	"\x16DBaaS Dataflow Service\x12-https://github.com/tidbcloud/dataflow-serviceZGgithub.com/tidbcloud/dataflow-service/idl/pbgen/proto/dataflow;dataflowb\x06proto3"

var (
	file_dataflow_dataflow_proto_rawDescOnce sync.Once
	file_dataflow_dataflow_proto_rawDescData []byte
)

func file_dataflow_dataflow_proto_rawDescGZIP() []byte {
	file_dataflow_dataflow_proto_rawDescOnce.Do(func() {
		file_dataflow_dataflow_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_dataflow_dataflow_proto_rawDesc), len(file_dataflow_dataflow_proto_rawDesc)))
	})
	return file_dataflow_dataflow_proto_rawDescData
}

var file_dataflow_dataflow_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_dataflow_dataflow_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
var file_dataflow_dataflow_proto_goTypes = []any{
	(GetPrivateLinkEndpointResp_Phase)(0),    // 0: dataflow.GetPrivateLinkEndpointResp.Phase
	(*CreateConnProfileReq)(nil),             // 1: dataflow.CreateConnProfileReq
	(*CreateConnProfileResp)(nil),            // 2: dataflow.CreateConnProfileResp
	(*GetIPWhiteListReq)(nil),                // 3: dataflow.GetIPWhiteListReq
	(*GetIPWhiteListResp)(nil),               // 4: dataflow.GetIPWhiteListResp
	(*CreatePrivateLinkEndpointReq)(nil),     // 5: dataflow.CreatePrivateLinkEndpointReq
	(*CreatePrivateLinkEndpointResp)(nil),    // 6: dataflow.CreatePrivateLinkEndpointResp
	(*GetPrivateLinkEndpointReq)(nil),        // 7: dataflow.GetPrivateLinkEndpointReq
	(*GetPrivateLinkEndpointResp)(nil),       // 8: dataflow.GetPrivateLinkEndpointResp
	(*ValidateRemoteDBConnectivityReq)(nil),  // 9: dataflow.ValidateRemoteDBConnectivityReq
	(*ValidateClusterConnectivityReq)(nil),   // 10: dataflow.ValidateClusterConnectivityReq
	(*ValidateRemoteDBConnectivityResp)(nil), // 11: dataflow.ValidateRemoteDBConnectivityResp
	(*ConnProfile)(nil),                      // 12: dataflow.ConnProfile
	(*emptypb.Empty)(nil),                    // 13: google.protobuf.Empty
}
var file_dataflow_dataflow_proto_depIdxs = []int32{
	0,  // 0: dataflow.GetPrivateLinkEndpointResp.phase:type_name -> dataflow.GetPrivateLinkEndpointResp.Phase
	1,  // 1: dataflow.ConnProfileService.CreateConnProfile:input_type -> dataflow.CreateConnProfileReq
	3,  // 2: dataflow.ConnProfileService.GetIPWhiteList:input_type -> dataflow.GetIPWhiteListReq
	5,  // 3: dataflow.ConnProfileService.CreatePrivateLinkEndpoint:input_type -> dataflow.CreatePrivateLinkEndpointReq
	7,  // 4: dataflow.ConnProfileService.GetPrivateLinkEndpoint:input_type -> dataflow.GetPrivateLinkEndpointReq
	9,  // 5: dataflow.ConnProfileService.ValidateRemoteDBConnectivity:input_type -> dataflow.ValidateRemoteDBConnectivityReq
	10, // 6: dataflow.ConnProfileService.ValidateClusterConnectivity:input_type -> dataflow.ValidateClusterConnectivityReq
	2,  // 7: dataflow.ConnProfileService.CreateConnProfile:output_type -> dataflow.CreateConnProfileResp
	4,  // 8: dataflow.ConnProfileService.GetIPWhiteList:output_type -> dataflow.GetIPWhiteListResp
	6,  // 9: dataflow.ConnProfileService.CreatePrivateLinkEndpoint:output_type -> dataflow.CreatePrivateLinkEndpointResp
	8,  // 10: dataflow.ConnProfileService.GetPrivateLinkEndpoint:output_type -> dataflow.GetPrivateLinkEndpointResp
	11, // 11: dataflow.ConnProfileService.ValidateRemoteDBConnectivity:output_type -> dataflow.ValidateRemoteDBConnectivityResp
	13, // 12: dataflow.ConnProfileService.ValidateClusterConnectivity:output_type -> google.protobuf.Empty
	7,  // [7:13] is the sub-list for method output_type
	1,  // [1:7] is the sub-list for method input_type
	1,  // [1:1] is the sub-list for extension type_name
	1,  // [1:1] is the sub-list for extension extendee
	0,  // [0:1] is the sub-list for field type_name
}

func init() { file_dataflow_dataflow_proto_init() }
func file_dataflow_dataflow_proto_init() {
	if File_dataflow_dataflow_proto != nil {
		return
	}
	file_dataflow_dataflow_proto_msgTypes[0].OneofWrappers = []any{}
	file_dataflow_dataflow_proto_msgTypes[8].OneofWrappers = []any{}
	file_dataflow_dataflow_proto_msgTypes[11].OneofWrappers = []any{}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_dataflow_dataflow_proto_rawDesc), len(file_dataflow_dataflow_proto_rawDesc)),
			NumEnums:      1,
			NumMessages:   12,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_dataflow_dataflow_proto_goTypes,
		DependencyIndexes: file_dataflow_dataflow_proto_depIdxs,
		EnumInfos:         file_dataflow_dataflow_proto_enumTypes,
		MessageInfos:      file_dataflow_dataflow_proto_msgTypes,
	}.Build()
	File_dataflow_dataflow_proto = out.File
	file_dataflow_dataflow_proto_goTypes = nil
	file_dataflow_dataflow_proto_depIdxs = nil
}