bigqueryreservation

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AutoscaleObservedState_v1beta1_FromProto added in v1.153.0 

func AutoscaleObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Reservation_Autoscale) *krm.AutoscaleObservedState

func AutoscaleObservedState_v1beta1_ToProto added in v1.153.0 

func AutoscaleObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.AutoscaleObservedState) *pb.Reservation_Autoscale

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

func AutoscaleObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Reservation_Autoscale) *krm.AutoscaleObservedState {
	if in == nil {
		return nil
	}
	out := &krm.AutoscaleObservedState{}
	out.CurrentSlots = direct.LazyPtr(in.GetCurrentSlots())
	// MISSING: MaxSlots
	return out
}

func AutoscaleSpec_v1beta1_FromProto added in v1.153.0 

func AutoscaleSpec_v1beta1_FromProto(mapctx *direct.MapContext, in *pb.Reservation_Autoscale) *krm.AutoscaleSpec

func AutoscaleSpec_v1beta1_ToProto added in v1.153.0 

func AutoscaleSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.AutoscaleSpec) *pb.Reservation_Autoscale

func BigQueryReservationAssignmentFuzzer added in v1.136.0 

func BigQueryReservationAssignmentFuzzer() fuzztesting.KRMFuzzer

func BigQueryReservationAssignmentObservedState_FromProto added in v1.136.0 

func BigQueryReservationAssignmentObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Assignment) *krm.BigQueryReservationAssignmentObservedState

func BigQueryReservationAssignmentObservedState_ToProto added in v1.136.0 

func BigQueryReservationAssignmentObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentObservedState) *pb.Assignment

func BigQueryReservationAssignmentObservedState_v1beta1_FromProto added in v1.153.0 

func BigQueryReservationAssignmentObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Assignment) *krm.BigQueryReservationAssignmentObservedState

func BigQueryReservationAssignmentObservedState_v1beta1_ToProto added in v1.153.0 

func BigQueryReservationAssignmentObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentObservedState) *pb.Assignment

func BigQueryReservationAssignmentSpec_Assignee_ToProto added in v1.136.0 

func BigQueryReservationAssignmentSpec_Assignee_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentSpec) string

func BigQueryReservationAssignmentSpec_FromProto added in v1.136.0 

func BigQueryReservationAssignmentSpec_FromProto(mapCtx *direct.MapContext, in *pb.Assignment) *krm.BigQueryReservationAssignmentSpec

func BigQueryReservationAssignmentSpec_ToProto added in v1.136.0 

func BigQueryReservationAssignmentSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentSpec) *pb.Assignment

func BigQueryReservationAssignmentSpec_v1beta1_FromProto added in v1.153.0 

func BigQueryReservationAssignmentSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Assignment) *krm.BigQueryReservationAssignmentSpec

func BigQueryReservationAssignmentSpec_v1beta1_ToProto added in v1.153.0 

func BigQueryReservationAssignmentSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentSpec) *pb.Assignment

func BigQueryReservationCapacityCommitmentFuzzer added in v1.153.0 

func BigQueryReservationCapacityCommitmentFuzzer() fuzztesting.KRMFuzzer

func BigQueryReservationCapacityCommitmentSpec_v1alpha1_FromProto added in v1.153.0 

func BigQueryReservationCapacityCommitmentSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.CapacityCommitment) *krmbigqueryreservationv1alpha1.BigQueryReservationCapacityCommitmentSpec

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

func BigQueryReservationAssignmentSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationAssignmentSpec) *pb.Assignment {
	if in == nil {
		return nil
	}
	out := &pb.Assignment{}
	// MISSING: Name
	out.Assignee = BigQueryReservationAssignmentSpec_Assignee_ToProto(mapCtx, in.Assignee)
	out.JobType = direct.Enum_ToProto[pb.Assignment_JobType](mapCtx, in.JobType)
	// MISSING: EnableGeminiInBigquery
	return out
}

func BigQueryReservationCapacityCommitmentSpec_v1alpha1_ToProto added in v1.153.0 

func BigQueryReservationCapacityCommitmentSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigqueryreservationv1alpha1.BigQueryReservationCapacityCommitmentSpec) *pb.CapacityCommitment

func BigQueryReservationCapacityCommitmentStatus_v1alpha1_FromProto added in v1.153.0 

func BigQueryReservationCapacityCommitmentStatus_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.CapacityCommitment) *krmbigqueryreservationv1alpha1.BigQueryReservationCapacityCommitmentStatus

func BigQueryReservationCapacityCommitmentStatus_v1alpha1_ToProto added in v1.153.0 

func BigQueryReservationCapacityCommitmentStatus_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigqueryreservationv1alpha1.BigQueryReservationCapacityCommitmentStatus) *pb.CapacityCommitment

func BigQueryReservationReservationFuzzer added in v1.136.0 

func BigQueryReservationReservationFuzzer() fuzztesting.KRMFuzzer

func BigQueryReservationReservationObservedState_FromProto added in v1.136.0 

func BigQueryReservationReservationObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.BigQueryReservationReservationObservedState

func BigQueryReservationReservationObservedState_ToProto added in v1.136.0 

func BigQueryReservationReservationObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationReservationObservedState) *pb.Reservation

func BigQueryReservationReservationObservedState_v1beta1_FromProto added in v1.153.0 

func BigQueryReservationReservationObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.BigQueryReservationReservationObservedState

func BigQueryReservationReservationObservedState_v1beta1_ToProto added in v1.153.0 

func BigQueryReservationReservationObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationReservationObservedState) *pb.Reservation

func BigQueryReservationReservationSpec_FromProto added in v1.136.0 

func BigQueryReservationReservationSpec_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.BigQueryReservationReservationSpec

func BigQueryReservationReservationSpec_ToProto added in v1.136.0 

func BigQueryReservationReservationSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationReservationSpec) *pb.Reservation

func BigQueryReservationReservationSpec_v1beta1_FromProto added in v1.153.0 

func BigQueryReservationReservationSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.BigQueryReservationReservationSpec

func BigQueryReservationReservationSpec_v1beta1_ToProto added in v1.153.0 

func BigQueryReservationReservationSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryReservationReservationSpec) *pb.Reservation

func BigqueryReservationAssignmentSpec_Assignee_FromProto 

func BigqueryReservationAssignmentSpec_Assignee_FromProto(mapCtx *direct.MapContext, in *pb.Assignment) *krm.Assignee

func FailoverObservedState_FromProto 

func FailoverObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.FailoverObservedState

func FailoverObservedState_ToProto 

func FailoverObservedState_ToProto(mapCtx *direct.MapContext, in *krm.FailoverObservedState) (string, string, string)

func FailoverSpec_FromProto 

func FailoverSpec_FromProto(mapCtx *direct.MapContext, in *pb.Reservation) *krm.FailoverSpec

func FailoverSpec_ToProto 

func FailoverSpec_ToProto(mapCtx *direct.MapContext, in *krm.FailoverSpec) string

func NewAssignmentModel 

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

func NewCapacityCommitmentModel added in v1.154.0 

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

func NewReservationModel 

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

Types

type AssignmentAdapter 

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

func (*AssignmentAdapter) Create 

func (a *AssignmentAdapter) 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 (*AssignmentAdapter) Delete 

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

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

func (*AssignmentAdapter) Export 

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

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

func (*AssignmentAdapter) Find 

func (a *AssignmentAdapter) 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 (*AssignmentAdapter) Update 

func (a *AssignmentAdapter) 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 CapacityCommitmentAdapter added in v1.154.0 

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

func (*CapacityCommitmentAdapter) Create added in v1.154.0 

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

func (*CapacityCommitmentAdapter) Delete added in v1.154.0 

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

func (*CapacityCommitmentAdapter) Export added in v1.154.0 

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

func (*CapacityCommitmentAdapter) Find added in v1.154.0 

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

func (*CapacityCommitmentAdapter) Update added in v1.154.0 

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

type ReservationAdapter 

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

func (*ReservationAdapter) Create 

func (a *ReservationAdapter) 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 (*ReservationAdapter) Delete 

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

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

func (*ReservationAdapter) Export 

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

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

func (*ReservationAdapter) Find 

func (a *ReservationAdapter) 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 (*ReservationAdapter) Update 

func (a *ReservationAdapter) 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.