bigqueryconnection

package
v1.154.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AwsAccessRoleSpec_FromProto added in v1.124.0

func AwsAccessRoleSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleSpec

func AwsAccessRoleSpec_ToProto added in v1.124.0

func AwsAccessRoleSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleSpec) *pb.AwsAccessRole

func AwsAccessRoleStatus_FromProto added in v1.124.0

func AwsAccessRoleStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleStatus

func AwsAccessRoleStatus_ToProto added in v1.124.0

func AwsAccessRoleStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleStatus) *pb.AwsAccessRole

func AwsPropertiesSpec_FromProto added in v1.124.0

func AwsPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesSpec

func AwsPropertiesSpec_ToProto added in v1.124.0

func AwsPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesSpec) *pb.AwsProperties

func AwsPropertiesStatus_FromProto added in v1.124.0

func AwsPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesStatus

func AwsPropertiesStatus_ToProto added in v1.124.0

func AwsPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesStatus) *pb.AwsProperties

func AzurePropertiesSpec_FromProto added in v1.124.0

func AzurePropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesSpec

func AzurePropertiesSpec_ToProto added in v1.124.0

func AzurePropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesSpec) *pb.AzureProperties

func AzurePropertiesStatus_FromProto added in v1.124.0

func AzurePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesStatus

func AzurePropertiesStatus_ToProto added in v1.124.0

func AzurePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesStatus) *pb.AzureProperties

func BigQueryConnectionConnectionObservedState_FromProto

func BigQueryConnectionConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState

found existing non-generated mapping function "AzurePropertiesStatus_ToProto", skipping

func AzurePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesStatus) *pb.AzureProperties {
	if in == nil {
		return nil
	}
	out := &pb.AzureProperties{}
	out.Application = direct.ValueOf(in.Application)
	out.ClientId = direct.ValueOf(in.ClientID)
	out.ObjectId = direct.ValueOf(in.ObjectID)
	// MISSING: CustomerTenantID
	// MISSING: RedirectURI
	// (near miss): "RedirectURI" vs "RedirectUri"
	// MISSING: FederatedApplicationClientID
	out.Identity = direct.ValueOf(in.Identity)
	return out
}

func BigQueryConnectionConnectionObservedState_ToProto

func BigQueryConnectionConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionObservedState) *pb.Connection

func BigQueryConnectionConnectionSpec_FromProto

func BigQueryConnectionConnectionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionSpec

func BigQueryConnectionConnectionSpec_ToProto

func BigQueryConnectionConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionSpec) *pb.Connection

func BigQueryConnectionConnectionStatusObservedState_FromProto

func BigQueryConnectionConnectionStatusObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState

func CloudResourcePropertiesStatus_FromProto

func CloudResourcePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourcePropertiesStatus

found existing non-generated mapping function "BigQueryConnectionConnectionSpec_ToProto", skipping

func BigQueryConnectionConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionSpec) *pb.Connection {
	if in == nil {
		return nil
	}
	out := &pb.Connection{}
	// MISSING: Name
	out.FriendlyName = direct.ValueOf(in.FriendlyName)
	out.Description = direct.ValueOf(in.Description)
	// MISSING: CloudSpanner
	// MISSING: SalesforceDataCloud
	// MISSING: CreationTime
	// MISSING: LastModifiedTime
	return out
}

func CloudSpannerPropertiesSpec_FromProto added in v1.124.0

func CloudSpannerPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerPropertiesSpec

func CloudSpannerPropertiesSpec_ToProto added in v1.124.0

func CloudSpannerPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerPropertiesSpec) *pb.CloudSpannerProperties

func CloudSqlCredential_FromProto

func CloudSqlCredential_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlCredential) *krm.CloudSqlCredential

func CloudSqlCredential_ToProto

func CloudSqlCredential_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlCredential) *pb.CloudSqlCredential

func CloudSqlPropertiesSpec_FromProto added in v1.124.0

func CloudSqlPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesSpec

func CloudSqlPropertiesSpec_ToProto added in v1.124.0

func CloudSqlPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesSpec) *pb.CloudSqlProperties

func CloudSqlPropertiesStatus_FromProto added in v1.124.0

func CloudSqlPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesStatus

found existing non-generated mapping function "CloudSqlCredential_ToProto", skipping

func CloudSqlCredential_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlCredential) *pb.CloudSqlCredential {
	if in == nil {
		return nil
	}
	out := &pb.CloudSqlCredential{}
	// MISSING: Username
	// MISSING: Password
	return out
}

func CloudSqlPropertiesStatus_ToProto added in v1.124.0

func CloudSqlPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesStatus) *pb.CloudSqlProperties

func MetastoreServiceConfigSpec_FromProto added in v1.124.0

func MetastoreServiceConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfigSpec

func MetastoreServiceConfigSpec_ToProto added in v1.124.0

func MetastoreServiceConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfigSpec) *pb.MetastoreServiceConfig

func NewModel

func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func SparkHistoryServerConfigSpec_FromProto added in v1.124.0

func SparkHistoryServerConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfigSpec

func SparkHistoryServerConfigSpec_ToProto added in v1.124.0

func SparkHistoryServerConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfigSpec) *pb.SparkHistoryServerConfig

func SparkPropertiesSpec_FromProto added in v1.124.0

func SparkPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesSpec

func SparkPropertiesSpec_ToProto added in v1.124.0

func SparkPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesSpec) *pb.SparkProperties

func SparkPropertiesStatus_FromProto added in v1.124.0

func SparkPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesStatus

func SparkPropertiesStatus_ToProto added in v1.124.0

func SparkPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesStatus) *pb.SparkProperties

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func (*Adapter) Create

func (a *Adapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

func (*Adapter) Delete

func (a *Adapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete implements the Adapter interface.

func (*Adapter) Export

func (*Adapter) Find

func (a *Adapter) Find(ctx context.Context) (bool, error)

func (*Adapter) Update

func (a *Adapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL