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 DataflowJobSpec_FromProto ¶ added in v1.153.0

func DataflowJobSpec_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.DataflowJobSpec

func DataflowJobSpec_ToProto ¶ added in v1.153.0

func DataflowJobSpec_ToProto(mapCtx *direct.MapContext, in *krm.DataflowJobSpec) *pb.Job

func DataflowJobStatus_FromProto ¶ added in v1.153.0

func DataflowJobStatus_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.DataflowJobStatus

func DataflowJobStatus_ToProto ¶ added in v1.153.0

func DataflowJobStatus_ToProto(mapCtx *direct.MapContext, in *krm.DataflowJobStatus) *pb.Job

func RefineComputeSubnetworkRef ¶ added in v1.127.0

func RefineComputeSubnetworkRef(ctx context.Context, reader client.Reader, src client.Object, ref *computev1beta1.ComputeSubnetworkRef) (*computev1beta1.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.