metastore

package
v1.131.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuxiliaryVersionConfig_FromProto 

func AuxiliaryVersionConfig_FromProto(mapCtx *direct.MapContext, in *pb.AuxiliaryVersionConfig) *krm.AuxiliaryVersionConfig

func AuxiliaryVersionConfig_ToProto 

func AuxiliaryVersionConfig_ToProto(mapCtx *direct.MapContext, in *krm.AuxiliaryVersionConfig) *pb.AuxiliaryVersionConfig

func BackendMetastore_FromProto 

func BackendMetastore_FromProto(mapCtx *direct.MapContext, in *pb.BackendMetastore) *krm.BackendMetastore

func BackendMetastore_ToProto 

func BackendMetastore_ToProto(mapCtx *direct.MapContext, in *krm.BackendMetastore) *pb.BackendMetastore

func EncryptionConfig_FromProto 

func EncryptionConfig_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfig) *krm.EncryptionConfig

func EncryptionConfig_ToProto 

func EncryptionConfig_ToProto(mapCtx *direct.MapContext, in *krm.EncryptionConfig) *pb.EncryptionConfig

func HiveMetastoreConfig_FromProto 

func HiveMetastoreConfig_FromProto(mapCtx *direct.MapContext, in *pb.HiveMetastoreConfig) *krm.HiveMetastoreConfig

func HiveMetastoreConfig_ToProto 

func HiveMetastoreConfig_ToProto(mapCtx *direct.MapContext, in *krm.HiveMetastoreConfig) *pb.HiveMetastoreConfig

func KerberosConfig_FromProto 

func KerberosConfig_FromProto(mapCtx *direct.MapContext, in *pb.KerberosConfig) *krm.KerberosConfig

func KerberosConfig_ToProto 

func KerberosConfig_ToProto(mapCtx *direct.MapContext, in *krm.KerberosConfig) *pb.KerberosConfig

func MaintenanceWindow_FromProto 

func MaintenanceWindow_FromProto(mapCtx *direct.MapContext, in *pb.MaintenanceWindow) *krm.MaintenanceWindow

func MaintenanceWindow_ToProto 

func MaintenanceWindow_ToProto(mapCtx *direct.MapContext, in *krm.MaintenanceWindow) *pb.MaintenanceWindow

func MetadataExportObservedState_FromProto 

func MetadataExportObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MetadataExport) *krm.MetadataExportObservedState

func MetadataExportObservedState_ToProto 

func MetadataExportObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MetadataExportObservedState) *pb.MetadataExport

func MetadataExport_FromProto 

func MetadataExport_FromProto(mapCtx *direct.MapContext, in *pb.MetadataExport) *krm.MetadataExport

func MetadataExport_ToProto 

func MetadataExport_ToProto(mapCtx *direct.MapContext, in *krm.MetadataExport) *pb.MetadataExport

func MetadataManagementActivityObservedState_FromProto 

func MetadataManagementActivityObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MetadataManagementActivity) *krm.MetadataManagementActivityObservedState

func MetadataManagementActivityObservedState_ToProto 

func MetadataManagementActivityObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MetadataManagementActivityObservedState) *pb.MetadataManagementActivity

func MetadataManagementActivity_FromProto 

func MetadataManagementActivity_FromProto(mapCtx *direct.MapContext, in *pb.MetadataManagementActivity) *krm.MetadataManagementActivity

func MetadataManagementActivity_ToProto 

func MetadataManagementActivity_ToProto(mapCtx *direct.MapContext, in *krm.MetadataManagementActivity) *pb.MetadataManagementActivity

func MetastoreBackupObservedState_FromProto added in v1.130.2 

func MetastoreBackupObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Backup) *krmv1alpha1.MetastoreBackupObservedState

func MetastoreBackupObservedState_ToProto added in v1.130.2 

func MetastoreBackupObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.MetastoreBackupObservedState) *pb.Backup

func MetastoreBackupSpec_FromProto added in v1.130.2 

func MetastoreBackupSpec_FromProto(mapCtx *direct.MapContext, in *pb.Backup) *krmv1alpha1.MetastoreBackupSpec

func MetastoreBackupSpec_ToProto added in v1.130.2 

func MetastoreBackupSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.MetastoreBackupSpec) *pb.Backup

func MetastoreFederationObservedState_FromProto 

func MetastoreFederationObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Federation) *krm.MetastoreFederationObservedState

func MetastoreFederationObservedState_ToProto 

func MetastoreFederationObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreFederationObservedState) *pb.Federation

func MetastoreFederationSpec_FromProto 

func MetastoreFederationSpec_FromProto(mapCtx *direct.MapContext, in *pb.Federation) *krm.MetastoreFederationSpec

func MetastoreFederationSpec_ToProto 

func MetastoreFederationSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreFederationSpec) *pb.Federation

func MetastoreServiceObservedState_FromProto 

func MetastoreServiceObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Service) *krm.MetastoreServiceObservedState

func MetastoreServiceObservedState_ToProto 

func MetastoreServiceObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceObservedState) *pb.Service

func MetastoreServiceSpec_FromProto 

func MetastoreServiceSpec_FromProto(mapCtx *direct.MapContext, in *pb.Service) *krm.MetastoreServiceSpec

func MetastoreServiceSpec_ToProto 

func MetastoreServiceSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceSpec) *pb.Service

func NetworkConfigObservedState_FromProto 

func NetworkConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krm.NetworkConfigObservedState

func NetworkConfigObservedState_ToProto 

func NetworkConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfigObservedState) *pb.NetworkConfig

func NetworkConfig_ConsumerObservedState_FromProto 

func NetworkConfig_ConsumerObservedState_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig_Consumer) *krm.NetworkConfig_ConsumerObservedState

func NetworkConfig_ConsumerObservedState_ToProto 

func NetworkConfig_ConsumerObservedState_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfig_ConsumerObservedState) *pb.NetworkConfig_Consumer

func NetworkConfig_Consumer_FromProto 

func NetworkConfig_Consumer_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig_Consumer) *krm.NetworkConfig_Consumer

func NetworkConfig_Consumer_ToProto 

func NetworkConfig_Consumer_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfig_Consumer) *pb.NetworkConfig_Consumer

func NetworkConfig_FromProto 

func NetworkConfig_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krm.NetworkConfig

func NetworkConfig_ToProto 

func NetworkConfig_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfig) *pb.NetworkConfig

func NewMetastoreBackupModel added in v1.131.0 

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

func NewMetastoreFederationModel added in v1.131.0 

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

func NewMetastoreServiceModel added in v1.131.0 

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

func RestoreObservedState_FromProto 

func RestoreObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Restore) *krm.RestoreObservedState

func RestoreObservedState_ToProto 

func RestoreObservedState_ToProto(mapCtx *direct.MapContext, in *krm.RestoreObservedState) *pb.Restore

func Restore_FromProto 

func Restore_FromProto(mapCtx *direct.MapContext, in *pb.Restore) *krm.Restore

func Restore_ToProto 

func Restore_ToProto(mapCtx *direct.MapContext, in *krm.Restore) *pb.Restore

func ScalingConfig_FromProto 

func ScalingConfig_FromProto(mapCtx *direct.MapContext, in *pb.ScalingConfig) *krm.ScalingConfig

func ScalingConfig_ToProto 

func ScalingConfig_ToProto(mapCtx *direct.MapContext, in *krm.ScalingConfig) *pb.ScalingConfig

func Secret_FromProto 

func Secret_FromProto(mapCtx *direct.MapContext, in *pb.Secret) *krm.Secret

func Secret_ToProto 

func Secret_ToProto(mapCtx *direct.MapContext, in *krm.Secret) *pb.Secret

func TelemetryConfig_FromProto 

func TelemetryConfig_FromProto(mapCtx *direct.MapContext, in *pb.TelemetryConfig) *krm.TelemetryConfig

func TelemetryConfig_ToProto 

func TelemetryConfig_ToProto(mapCtx *direct.MapContext, in *krm.TelemetryConfig) *pb.TelemetryConfig

Types

type MetastoreBackupAdapter added in v1.131.0 

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

func (*MetastoreBackupAdapter) Create added in v1.131.0 

func (a *MetastoreBackupAdapter) 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 (*MetastoreBackupAdapter) Delete added in v1.131.0 

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

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

func (*MetastoreBackupAdapter) Export added in v1.131.0 

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

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

func (*MetastoreBackupAdapter) Find added in v1.131.0 

func (a *MetastoreBackupAdapter) 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 (*MetastoreBackupAdapter) Update added in v1.131.0 

func (a *MetastoreBackupAdapter) 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. MetastoreBackup resource has no mutable fields as per the proto definition, so this function only updates the status.

type MetastoreBackupModel added in v1.131.0 

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

func (*MetastoreBackupModel) AdapterForObject added in v1.131.0 

func (m *MetastoreBackupModel) AdapterForObject(ctx context.Context, reader client.Reader, u *unstructured.Unstructured) (directbase.Adapter, error)

func (*MetastoreBackupModel) AdapterForURL added in v1.131.0 

func (m *MetastoreBackupModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

type MetastoreFederationAdapter added in v1.131.0 

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

func (*MetastoreFederationAdapter) Create added in v1.131.0 

func (a *MetastoreFederationAdapter) 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 (*MetastoreFederationAdapter) Delete added in v1.131.0 

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

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

func (*MetastoreFederationAdapter) Export added in v1.131.0 

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

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

func (*MetastoreFederationAdapter) Find added in v1.131.0 

func (a *MetastoreFederationAdapter) 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 (*MetastoreFederationAdapter) Update added in v1.131.0 

func (a *MetastoreFederationAdapter) 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 MetastoreFederationModel added in v1.131.0 

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

func (*MetastoreFederationModel) AdapterForObject added in v1.131.0 

func (m *MetastoreFederationModel) AdapterForObject(ctx context.Context, reader client.Reader, u *unstructured.Unstructured) (directbase.Adapter, error)

func (*MetastoreFederationModel) AdapterForURL added in v1.131.0 

func (m *MetastoreFederationModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

type MetastoreServiceAdapter added in v1.131.0 

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

func (*MetastoreServiceAdapter) Create added in v1.131.0 

func (a *MetastoreServiceAdapter) 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 (*MetastoreServiceAdapter) Delete added in v1.131.0 

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

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

func (*MetastoreServiceAdapter) Export added in v1.131.0 

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

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

func (*MetastoreServiceAdapter) Find added in v1.131.0 

func (a *MetastoreServiceAdapter) 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 (*MetastoreServiceAdapter) Update added in v1.131.0 

func (a *MetastoreServiceAdapter) 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 MetastoreServiceModel added in v1.131.0 

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

func (*MetastoreServiceModel) AdapterForObject added in v1.131.0 

func (m *MetastoreServiceModel) AdapterForObject(ctx context.Context, reader client.Reader, u *unstructured.Unstructured) (directbase.Adapter, error)

func (*MetastoreServiceModel) AdapterForURL added in v1.131.0 

func (m *MetastoreServiceModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

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.
OSZAR »