dataflow

func DataflowFlexTemplateJobSpec_FromProto ¶

func DataflowFlexTemplateJobSpec_FromProto(mapCtx *direct.MapContext, in *pb.FlexTemplateRuntimeEnvironment) *krm.DataflowFlexTemplateJobSpec

func DataflowFlexTemplateJobSpec_ToProto ¶

func DataflowFlexTemplateJobSpec_ToProto(mapCtx *direct.MapContext, in *krm.DataflowFlexTemplateJobSpec) *pb.FlexTemplateRuntimeEnvironment

func RefineComputeSubnetworkRef ¶ added in v1.127.0

func RefineComputeSubnetworkRef(ctx context.Context, reader client.Reader, src client.Object, ref *refs.ComputeSubnetworkRef) (*refs.ComputeSubnetworkRef, error)

RefineComputeSubnetworkRef refine the subnetwork format because DataflowFlexTemplateJob has a specific format requirement: "You can specify a subnetwork using either a complete URL or an abbreviated path.

Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network,
you must use the complete URL.