connectionpb

Jul 24, 2023

Changes in this version

type CloudSpannerProperties

+ MaxParallelism int32

+ UseDataBoost bool

+ func (x *CloudSpannerProperties) GetMaxParallelism() int32

+ func (x *CloudSpannerProperties) GetUseDataBoost() bool

type Connection

+ func (x *Connection) GetSalesforceDataCloud() *SalesforceDataCloudProperties

+ type Connection_SalesforceDataCloud struct

+ SalesforceDataCloud *SalesforceDataCloudProperties

+ type SalesforceDataCloudProperties struct

+ Identity string

+ InstanceUri string

+ TenantId string

+ func (*SalesforceDataCloudProperties) Descriptor() ([]byte, []int)

+ func (*SalesforceDataCloudProperties) ProtoMessage()

+ func (x *SalesforceDataCloudProperties) GetIdentity() string

+ func (x *SalesforceDataCloudProperties) GetInstanceUri() string

+ func (x *SalesforceDataCloudProperties) GetTenantId() string

+ func (x *SalesforceDataCloudProperties) ProtoReflect() protoreflect.Message

+ func (x *SalesforceDataCloudProperties) Reset()

+ func (x *SalesforceDataCloudProperties) String() string

Apr 3, 2023

Changes in this version

type Connection

+ func (x *Connection) GetSpark() *SparkProperties

+ type Connection_Spark struct

+ Spark *SparkProperties

+ type MetastoreServiceConfig struct

+ MetastoreService string

+ func (*MetastoreServiceConfig) Descriptor() ([]byte, []int)

+ func (*MetastoreServiceConfig) ProtoMessage()

+ func (x *MetastoreServiceConfig) GetMetastoreService() string

+ func (x *MetastoreServiceConfig) ProtoReflect() protoreflect.Message

+ func (x *MetastoreServiceConfig) Reset()

+ func (x *MetastoreServiceConfig) String() string

+ type SparkHistoryServerConfig struct

+ DataprocCluster string

+ func (*SparkHistoryServerConfig) Descriptor() ([]byte, []int)

+ func (*SparkHistoryServerConfig) ProtoMessage()

+ func (x *SparkHistoryServerConfig) GetDataprocCluster() string

+ func (x *SparkHistoryServerConfig) ProtoReflect() protoreflect.Message

+ func (x *SparkHistoryServerConfig) Reset()

+ func (x *SparkHistoryServerConfig) String() string

+ type SparkProperties struct

+ MetastoreServiceConfig *MetastoreServiceConfig

+ ServiceAccountId string

+ SparkHistoryServerConfig *SparkHistoryServerConfig

+ func (*SparkProperties) Descriptor() ([]byte, []int)

+ func (*SparkProperties) ProtoMessage()

+ func (x *SparkProperties) GetMetastoreServiceConfig() *MetastoreServiceConfig

+ func (x *SparkProperties) GetServiceAccountId() string

+ func (x *SparkProperties) GetSparkHistoryServerConfig() *SparkHistoryServerConfig

+ func (x *SparkProperties) ProtoReflect() protoreflect.Message

+ func (x *SparkProperties) Reset()

+ func (x *SparkProperties) String() string

Mar 1, 2023

Changes in this version

type CloudSpannerProperties

+ DatabaseRole string

+ UseServerlessAnalytics bool

+ func (x *CloudSpannerProperties) GetDatabaseRole() string

+ func (x *CloudSpannerProperties) GetUseServerlessAnalytics() bool

Nov 30, 2022

Changes in this version

+ var CloudSqlProperties_DatabaseType_name = map[int32]string

+ var CloudSqlProperties_DatabaseType_value = map[string]int32

+ var File_google_cloud_bigquery_connection_v1_connection_proto protoreflect.FileDescriptor

+ func RegisterConnectionServiceServer(s *grpc.Server, srv ConnectionServiceServer)

+ type AwsAccessRole struct

+ IamRoleId string

+ Identity string

+ func (*AwsAccessRole) Descriptor() ([]byte, []int)

+ func (*AwsAccessRole) ProtoMessage()

+ func (x *AwsAccessRole) GetIamRoleId() string

+ func (x *AwsAccessRole) GetIdentity() string

+ func (x *AwsAccessRole) ProtoReflect() protoreflect.Message

+ func (x *AwsAccessRole) Reset()

+ func (x *AwsAccessRole) String() string

+ type AwsCrossAccountRole struct

+ ExternalId string

+ IamRoleId string

+ IamUserId string

+ func (*AwsCrossAccountRole) Descriptor() ([]byte, []int)

+ func (*AwsCrossAccountRole) ProtoMessage()

+ func (x *AwsCrossAccountRole) GetExternalId() string

+ func (x *AwsCrossAccountRole) GetIamRoleId() string

+ func (x *AwsCrossAccountRole) GetIamUserId() string

+ func (x *AwsCrossAccountRole) ProtoReflect() protoreflect.Message

+ func (x *AwsCrossAccountRole) Reset()

+ func (x *AwsCrossAccountRole) String() string

+ type AwsProperties struct

+ AuthenticationMethod isAwsProperties_AuthenticationMethod

+ func (*AwsProperties) Descriptor() ([]byte, []int)

+ func (*AwsProperties) ProtoMessage()

+ func (m *AwsProperties) GetAuthenticationMethod() isAwsProperties_AuthenticationMethod

+ func (x *AwsProperties) GetAccessRole() *AwsAccessRole

+ func (x *AwsProperties) GetCrossAccountRole() *AwsCrossAccountRole

+ func (x *AwsProperties) ProtoReflect() protoreflect.Message

+ func (x *AwsProperties) Reset()

+ func (x *AwsProperties) String() string

+ type AwsProperties_AccessRole struct

+ AccessRole *AwsAccessRole

+ type AwsProperties_CrossAccountRole struct

+ CrossAccountRole *AwsCrossAccountRole

+ type AzureProperties struct

+ Application string

+ ClientId string

+ CustomerTenantId string

+ FederatedApplicationClientId string

+ Identity string

+ ObjectId string

+ RedirectUri string

+ func (*AzureProperties) Descriptor() ([]byte, []int)

+ func (*AzureProperties) ProtoMessage()

+ func (x *AzureProperties) GetApplication() string

+ func (x *AzureProperties) GetClientId() string

+ func (x *AzureProperties) GetCustomerTenantId() string

+ func (x *AzureProperties) GetFederatedApplicationClientId() string

+ func (x *AzureProperties) GetIdentity() string

+ func (x *AzureProperties) GetObjectId() string

+ func (x *AzureProperties) GetRedirectUri() string

+ func (x *AzureProperties) ProtoReflect() protoreflect.Message

+ func (x *AzureProperties) Reset()

+ func (x *AzureProperties) String() string

+ type CloudResourceProperties struct

+ ServiceAccountId string

+ func (*CloudResourceProperties) Descriptor() ([]byte, []int)

+ func (*CloudResourceProperties) ProtoMessage()

+ func (x *CloudResourceProperties) GetServiceAccountId() string

+ func (x *CloudResourceProperties) ProtoReflect() protoreflect.Message

+ func (x *CloudResourceProperties) Reset()

+ func (x *CloudResourceProperties) String() string

+ type CloudSpannerProperties struct

+ Database string

+ UseParallelism bool

+ func (*CloudSpannerProperties) Descriptor() ([]byte, []int)

+ func (*CloudSpannerProperties) ProtoMessage()

+ func (x *CloudSpannerProperties) GetDatabase() string

+ func (x *CloudSpannerProperties) GetUseParallelism() bool

+ func (x *CloudSpannerProperties) ProtoReflect() protoreflect.Message

+ func (x *CloudSpannerProperties) Reset()

+ func (x *CloudSpannerProperties) String() string

+ type CloudSqlCredential struct

+ Password string

+ Username string

+ func (*CloudSqlCredential) Descriptor() ([]byte, []int)

+ func (*CloudSqlCredential) ProtoMessage()

+ func (x *CloudSqlCredential) GetPassword() string

+ func (x *CloudSqlCredential) GetUsername() string

+ func (x *CloudSqlCredential) ProtoReflect() protoreflect.Message

+ func (x *CloudSqlCredential) Reset()

+ func (x *CloudSqlCredential) String() string

+ type CloudSqlProperties struct

+ Credential *CloudSqlCredential

+ Database string

+ InstanceId string

+ ServiceAccountId string

+ Type CloudSqlProperties_DatabaseType

+ func (*CloudSqlProperties) Descriptor() ([]byte, []int)

+ func (*CloudSqlProperties) ProtoMessage()

+ func (x *CloudSqlProperties) GetCredential() *CloudSqlCredential

+ func (x *CloudSqlProperties) GetDatabase() string

+ func (x *CloudSqlProperties) GetInstanceId() string

+ func (x *CloudSqlProperties) GetServiceAccountId() string

+ func (x *CloudSqlProperties) GetType() CloudSqlProperties_DatabaseType

+ func (x *CloudSqlProperties) ProtoReflect() protoreflect.Message

+ func (x *CloudSqlProperties) Reset()

+ func (x *CloudSqlProperties) String() string

+ type CloudSqlProperties_DatabaseType int32

+ const CloudSqlProperties_DATABASE_TYPE_UNSPECIFIED

+ const CloudSqlProperties_MYSQL

+ const CloudSqlProperties_POSTGRES

+ func (CloudSqlProperties_DatabaseType) Descriptor() protoreflect.EnumDescriptor

+ func (CloudSqlProperties_DatabaseType) EnumDescriptor() ([]byte, []int)

+ func (CloudSqlProperties_DatabaseType) Type() protoreflect.EnumType

+ func (x CloudSqlProperties_DatabaseType) Enum() *CloudSqlProperties_DatabaseType

+ func (x CloudSqlProperties_DatabaseType) Number() protoreflect.EnumNumber

+ func (x CloudSqlProperties_DatabaseType) String() string

+ type Connection struct

+ CreationTime int64

+ Description string

+ FriendlyName string

+ HasCredential bool

+ LastModifiedTime int64

+ Name string

+ Properties isConnection_Properties

+ func (*Connection) Descriptor() ([]byte, []int)

+ func (*Connection) ProtoMessage()

+ func (m *Connection) GetProperties() isConnection_Properties

+ func (x *Connection) GetAws() *AwsProperties

+ func (x *Connection) GetAzure() *AzureProperties

+ func (x *Connection) GetCloudResource() *CloudResourceProperties

+ func (x *Connection) GetCloudSpanner() *CloudSpannerProperties

+ func (x *Connection) GetCloudSql() *CloudSqlProperties

+ func (x *Connection) GetCreationTime() int64

+ func (x *Connection) GetDescription() string

+ func (x *Connection) GetFriendlyName() string

+ func (x *Connection) GetHasCredential() bool

+ func (x *Connection) GetLastModifiedTime() int64

+ func (x *Connection) GetName() string

+ func (x *Connection) ProtoReflect() protoreflect.Message

+ func (x *Connection) Reset()

+ func (x *Connection) String() string

+ type ConnectionServiceClient interface

+ CreateConnection func(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*Connection, error)

+ DeleteConnection func(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetConnection func(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*Connection, error)

+ GetIamPolicy func(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)

+ ListConnections func(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error)

+ SetIamPolicy func(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)

+ TestIamPermissions func(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error)

+ UpdateConnection func(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*Connection, error)

+ func NewConnectionServiceClient(cc grpc.ClientConnInterface) ConnectionServiceClient

+ type ConnectionServiceServer interface

+ CreateConnection func(context.Context, *CreateConnectionRequest) (*Connection, error)

+ DeleteConnection func(context.Context, *DeleteConnectionRequest) (*emptypb.Empty, error)

+ GetConnection func(context.Context, *GetConnectionRequest) (*Connection, error)

+ GetIamPolicy func(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)

+ ListConnections func(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)

+ SetIamPolicy func(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)

+ TestIamPermissions func(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)

+ UpdateConnection func(context.Context, *UpdateConnectionRequest) (*Connection, error)

+ type Connection_Aws struct

+ Aws *AwsProperties

+ type Connection_Azure struct

+ Azure *AzureProperties

+ type Connection_CloudResource struct

+ CloudResource *CloudResourceProperties

+ type Connection_CloudSpanner struct

+ CloudSpanner *CloudSpannerProperties

+ type Connection_CloudSql struct

+ CloudSql *CloudSqlProperties

+ type CreateConnectionRequest struct

+ Connection *Connection

+ ConnectionId string

+ Parent string

+ func (*CreateConnectionRequest) Descriptor() ([]byte, []int)

+ func (*CreateConnectionRequest) ProtoMessage()

+ func (x *CreateConnectionRequest) GetConnection() *Connection

+ func (x *CreateConnectionRequest) GetConnectionId() string

+ func (x *CreateConnectionRequest) GetParent() string

+ func (x *CreateConnectionRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateConnectionRequest) Reset()

+ func (x *CreateConnectionRequest) String() string

+ type DeleteConnectionRequest struct

+ Name string

+ func (*DeleteConnectionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteConnectionRequest) ProtoMessage()

+ func (x *DeleteConnectionRequest) GetName() string

+ func (x *DeleteConnectionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteConnectionRequest) Reset()

+ func (x *DeleteConnectionRequest) String() string

+ type GetConnectionRequest struct

+ Name string

+ func (*GetConnectionRequest) Descriptor() ([]byte, []int)

+ func (*GetConnectionRequest) ProtoMessage()

+ func (x *GetConnectionRequest) GetName() string

+ func (x *GetConnectionRequest) ProtoReflect() protoreflect.Message

+ func (x *GetConnectionRequest) Reset()

+ func (x *GetConnectionRequest) String() string

+ type ListConnectionsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListConnectionsRequest) Descriptor() ([]byte, []int)

+ func (*ListConnectionsRequest) ProtoMessage()

+ func (x *ListConnectionsRequest) GetPageSize() int32

+ func (x *ListConnectionsRequest) GetPageToken() string

+ func (x *ListConnectionsRequest) GetParent() string

+ func (x *ListConnectionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListConnectionsRequest) Reset()

+ func (x *ListConnectionsRequest) String() string

+ type ListConnectionsResponse struct

+ Connections []*Connection

+ NextPageToken string

+ func (*ListConnectionsResponse) Descriptor() ([]byte, []int)

+ func (*ListConnectionsResponse) ProtoMessage()

+ func (x *ListConnectionsResponse) GetConnections() []*Connection

+ func (x *ListConnectionsResponse) GetNextPageToken() string

+ func (x *ListConnectionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListConnectionsResponse) Reset()

+ func (x *ListConnectionsResponse) String() string

+ type UnimplementedConnectionServiceServer struct

+ func (*UnimplementedConnectionServiceServer) CreateConnection(context.Context, *CreateConnectionRequest) (*Connection, error)

+ func (*UnimplementedConnectionServiceServer) DeleteConnection(context.Context, *DeleteConnectionRequest) (*emptypb.Empty, error)

+ func (*UnimplementedConnectionServiceServer) GetConnection(context.Context, *GetConnectionRequest) (*Connection, error)

+ func (*UnimplementedConnectionServiceServer) GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)

+ func (*UnimplementedConnectionServiceServer) ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)

+ func (*UnimplementedConnectionServiceServer) SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)

+ func (*UnimplementedConnectionServiceServer) TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)

+ func (*UnimplementedConnectionServiceServer) UpdateConnection(context.Context, *UpdateConnectionRequest) (*Connection, error)

+ type UpdateConnectionRequest struct

+ Connection *Connection

+ Name string

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateConnectionRequest) Descriptor() ([]byte, []int)

+ func (*UpdateConnectionRequest) ProtoMessage()

+ func (x *UpdateConnectionRequest) GetConnection() *Connection

+ func (x *UpdateConnectionRequest) GetName() string

+ func (x *UpdateConnectionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateConnectionRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateConnectionRequest) Reset()

+ func (x *UpdateConnectionRequest) String() string