datastream

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: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BigQueryProfile_FromProto 

func BigQueryProfile_FromProto(mapCtx *direct.MapContext, in *pb.BigQueryProfile) *krmv1alpha1.BigQueryProfile

func BigQueryProfile_ToProto 

func BigQueryProfile_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryProfile) *pb.BigQueryProfile

func DatastreamConnectionProfileObservedState_FromProto 

func DatastreamConnectionProfileObservedState_FromProto(mapCtx *direct.MapContext, in *pb.ConnectionProfile) *krm.DatastreamConnectionProfileObservedState

func DatastreamConnectionProfileObservedState_ToProto 

func DatastreamConnectionProfileObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DatastreamConnectionProfileObservedState) *pb.ConnectionProfile

func DatastreamConnectionProfileSpec_FromProto 

func DatastreamConnectionProfileSpec_FromProto(mapCtx *direct.MapContext, in *pb.ConnectionProfile) *krm.DatastreamConnectionProfileSpec

func DatastreamConnectionProfileSpec_ToProto 

func DatastreamConnectionProfileSpec_ToProto(mapCtx *direct.MapContext, in *krm.DatastreamConnectionProfileSpec) *pb.ConnectionProfile

func DatastreamPrivateConnectionObservedState_FromProto 

func DatastreamPrivateConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PrivateConnection) *krmv1alpha1.DatastreamPrivateConnectionObservedState

func DatastreamPrivateConnectionObservedState_ToProto 

func DatastreamPrivateConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DatastreamPrivateConnectionObservedState) *pb.PrivateConnection

func DatastreamPrivateConnectionSpec_FromProto 

func DatastreamPrivateConnectionSpec_FromProto(mapCtx *direct.MapContext, in *pb.PrivateConnection) *krm.DatastreamPrivateConnectionSpec

func DatastreamPrivateConnectionSpec_ToProto 

func DatastreamPrivateConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.DatastreamPrivateConnectionSpec) *pb.PrivateConnection

func DatastreamRouteObservedState_FromProto added in v1.131.0 

func DatastreamRouteObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Route) *krmv1alpha1.DatastreamRouteObservedState

func DatastreamRouteObservedState_ToProto added in v1.131.0 

func DatastreamRouteObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DatastreamRouteObservedState) *pb.Route

func DatastreamRouteSpec_FromProto added in v1.131.0 

func DatastreamRouteSpec_FromProto(mapCtx *direct.MapContext, in *pb.Route) *krmv1alpha1.DatastreamRouteSpec

func DatastreamRouteSpec_ToProto added in v1.131.0 

func DatastreamRouteSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DatastreamRouteSpec) *pb.Route

func Error_FromProto 

func Error_FromProto(mapCtx *direct.MapContext, in *pb.Error) *krm.Error

func Error_ToProto 

func Error_ToProto(mapCtx *direct.MapContext, in *krm.Error) *pb.Error

func ForwardSSHTunnelConnectivity_FromProto 

func ForwardSSHTunnelConnectivity_FromProto(mapCtx *direct.MapContext, in *pb.ForwardSshTunnelConnectivity) *krm.ForwardSSHTunnelConnectivity

func ForwardSSHTunnelConnectivity_Password_ToProto 

func ForwardSSHTunnelConnectivity_Password_ToProto(mapCtx *direct.MapContext, in *refsv1beta1secret.BasicAuthSecretRef) *pb.ForwardSshTunnelConnectivity_Password

func ForwardSSHTunnelConnectivity_PrivateKey_ToProto 

func ForwardSSHTunnelConnectivity_PrivateKey_ToProto(mapCtx *direct.MapContext, in *string) *pb.ForwardSshTunnelConnectivity_PrivateKey

func ForwardSSHTunnelConnectivity_ToProto 

func ForwardSSHTunnelConnectivity_ToProto(mapCtx *direct.MapContext, in *krm.ForwardSSHTunnelConnectivity) *pb.ForwardSshTunnelConnectivity

func GCSProfile_FromProto 

func GCSProfile_FromProto(mapCtx *direct.MapContext, in *pb.GcsProfile) *krmv1alpha1.GCSProfile

func GCSProfile_ToProto 

func GCSProfile_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.GCSProfile) *pb.GcsProfile

func MysqlProfileObservedState_FromProto 

func MysqlProfileObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MysqlProfile) *krmv1alpha1.MysqlProfileObservedState

func MysqlProfileObservedState_ToProto 

func MysqlProfileObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.MysqlProfileObservedState) *pb.MysqlProfile

func MysqlProfile_FromProto 

func MysqlProfile_FromProto(mapCtx *direct.MapContext, in *pb.MysqlProfile) *krm.MysqlProfile

func MysqlProfile_ToProto 

func MysqlProfile_ToProto(mapCtx *direct.MapContext, in *krm.MysqlProfile) *pb.MysqlProfile

func MysqlSSLConfigObservedState_FromProto 

func MysqlSSLConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MysqlSslConfig) *krmv1alpha1.MysqlSSLConfigObservedState

func MysqlSSLConfigObservedState_ToProto 

func MysqlSSLConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.MysqlSSLConfigObservedState) *pb.MysqlSslConfig

func MysqlSSLConfig_FromProto 

func MysqlSSLConfig_FromProto(mapCtx *direct.MapContext, in *pb.MysqlSslConfig) *krmv1alpha1.MysqlSSLConfig

func MysqlSSLConfig_ToProto 

func MysqlSSLConfig_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.MysqlSSLConfig) *pb.MysqlSslConfig

func NewConnectionProfileModel 

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

func NewPrivateConnectionModel 

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

func NewRouteModel added in v1.131.0 

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

func OracleAsmConfig_FromProto 

func OracleAsmConfig_FromProto(mapCtx *direct.MapContext, in *pb.OracleAsmConfig) *krm.OracleAsmConfig

func OracleAsmConfig_ToProto 

func OracleAsmConfig_ToProto(mapCtx *direct.MapContext, in *krm.OracleAsmConfig) *pb.OracleAsmConfig

func OracleProfileObservedState_FromProto 

func OracleProfileObservedState_FromProto(mapCtx *direct.MapContext, in *pb.OracleProfile) *krmv1alpha1.OracleProfileObservedState

func OracleProfileObservedState_ToProto 

func OracleProfileObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.OracleProfileObservedState) *pb.OracleProfile

func OracleProfile_FromProto 

func OracleProfile_FromProto(mapCtx *direct.MapContext, in *pb.OracleProfile) *krm.OracleProfile

func OracleProfile_ToProto 

func OracleProfile_ToProto(mapCtx *direct.MapContext, in *krm.OracleProfile) *pb.OracleProfile

func OracleSSLConfigObservedState_FromProto 

func OracleSSLConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.OracleSslConfig) *krmv1alpha1.OracleSSLConfigObservedState

func OracleSSLConfigObservedState_ToProto 

func OracleSSLConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.OracleSSLConfigObservedState) *pb.OracleSslConfig

func OracleSSLConfig_FromProto 

func OracleSSLConfig_FromProto(mapCtx *direct.MapContext, in *pb.OracleSslConfig) *krmv1alpha1.OracleSSLConfig

func OracleSSLConfig_ToProto 

func OracleSSLConfig_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.OracleSSLConfig) *pb.OracleSslConfig

func PostgresqlProfile_FromProto 

func PostgresqlProfile_FromProto(mapCtx *direct.MapContext, in *pb.PostgresqlProfile) *krm.PostgresqlProfile

func PostgresqlProfile_ToProto 

func PostgresqlProfile_ToProto(mapCtx *direct.MapContext, in *krm.PostgresqlProfile) *pb.PostgresqlProfile

func PrivateConnectivity_FromProto 

func PrivateConnectivity_FromProto(mapCtx *direct.MapContext, in *pb.PrivateConnectivity) *krm.PrivateConnectivity

func PrivateConnectivity_ToProto 

func PrivateConnectivity_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.PrivateConnectivity) *pb.PrivateConnectivity

func SQLServerProfile_FromProto 

func SQLServerProfile_FromProto(mapCtx *direct.MapContext, in *pb.SqlServerProfile) *krm.SQLServerProfile

func SQLServerProfile_ToProto 

func SQLServerProfile_ToProto(mapCtx *direct.MapContext, in *krm.SQLServerProfile) *pb.SqlServerProfile

func StaticServiceIPConnectivity_FromProto 

func StaticServiceIPConnectivity_FromProto(mapCtx *direct.MapContext, in *pb.StaticServiceIpConnectivity) *krmv1alpha1.StaticServiceIPConnectivity

func StaticServiceIPConnectivity_ToProto 

func StaticServiceIPConnectivity_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.StaticServiceIPConnectivity) *pb.StaticServiceIpConnectivity

func VpcPeeringConfig_FromProto 

func VpcPeeringConfig_FromProto(mapCtx *direct.MapContext, in *pb.VpcPeeringConfig) *krm.VpcPeeringConfig

func VpcPeeringConfig_ToProto 

func VpcPeeringConfig_ToProto(mapCtx *direct.MapContext, in *krm.VpcPeeringConfig) *pb.VpcPeeringConfig

Types

type ConnectionProfileAdapter 

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

func (*ConnectionProfileAdapter) Create 

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

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*ConnectionProfileAdapter) Delete 

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

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*ConnectionProfileAdapter) Export 

func (a *ConnectionProfileAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*ConnectionProfileAdapter) Find 

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

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*ConnectionProfileAdapter) Update 

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

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

type PrivateConnectionAdapter 

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

func (*PrivateConnectionAdapter) Create 

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

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*PrivateConnectionAdapter) Delete 

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

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*PrivateConnectionAdapter) Export 

func (a *PrivateConnectionAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*PrivateConnectionAdapter) Find 

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

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*PrivateConnectionAdapter) Update 

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

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

type RouteAdapter added in v1.131.0 

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

func (*RouteAdapter) Create added in v1.131.0 

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

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*RouteAdapter) Delete added in v1.131.0 

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

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*RouteAdapter) Export added in v1.131.0 

func (a *RouteAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*RouteAdapter) Find added in v1.131.0 

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

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*RouteAdapter) Update added in v1.131.0 

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

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.