dataflow

package
v1.123.1 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AutoscalingEvent_FromProto 

func AutoscalingEvent_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingEvent) *krm.AutoscalingEvent

func AutoscalingEvent_Time_FromProto 

func AutoscalingEvent_Time_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func AutoscalingEvent_Time_ToProto 

func AutoscalingEvent_Time_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func AutoscalingEvent_ToProto 

func AutoscalingEvent_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingEvent) *pb.AutoscalingEvent

func AutoscalingSettings_FromProto 

func AutoscalingSettings_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingSettings) *krm.AutoscalingSettings

func AutoscalingSettings_ToProto 

func AutoscalingSettings_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingSettings) *pb.AutoscalingSettings

func BigQueryIODetails_FromProto 

func BigQueryIODetails_FromProto(mapCtx *direct.MapContext, in *pb.BigQueryIODetails) *krm.BigQueryIODetails

func BigQueryIODetails_ToProto 

func BigQueryIODetails_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryIODetails) *pb.BigQueryIODetails

func BigTableIODetails_FromProto 

func BigTableIODetails_FromProto(mapCtx *direct.MapContext, in *pb.BigTableIODetails) *krm.BigTableIODetails

func BigTableIODetails_ToProto 

func BigTableIODetails_ToProto(mapCtx *direct.MapContext, in *krm.BigTableIODetails) *pb.BigTableIODetails

func ComputationTopology_FromProto 

func ComputationTopology_FromProto(mapCtx *direct.MapContext, in *pb.ComputationTopology) *krm.ComputationTopology

func ComputationTopology_ToProto 

func ComputationTopology_ToProto(mapCtx *direct.MapContext, in *krm.ComputationTopology) *pb.ComputationTopology

func ContainerSpec_FromProto 

func ContainerSpec_FromProto(mapCtx *direct.MapContext, in *pb.ContainerSpec) *krm.ContainerSpec

Override because of unhandled Any / Value / Struct fields

func ContainerSpec_ToProto 

func ContainerSpec_ToProto(mapCtx *direct.MapContext, in *krm.ContainerSpec) *pb.ContainerSpec

Override because of unhandled Any / Value / Struct fields

func CustomSourceLocation_FromProto 

func CustomSourceLocation_FromProto(mapCtx *direct.MapContext, in *pb.CustomSourceLocation) *krm.CustomSourceLocation

func CustomSourceLocation_ToProto 

func CustomSourceLocation_ToProto(mapCtx *direct.MapContext, in *krm.CustomSourceLocation) *pb.CustomSourceLocation

func DataDiskAssignment_FromProto 

func DataDiskAssignment_FromProto(mapCtx *direct.MapContext, in *pb.DataDiskAssignment) *krm.DataDiskAssignment

func DataDiskAssignment_ToProto 

func DataDiskAssignment_ToProto(mapCtx *direct.MapContext, in *krm.DataDiskAssignment) *pb.DataDiskAssignment

func DataflowFlexTemplateJobSpec_FromProto 

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

Override because of refs

func DataflowFlexTemplateJobSpec_ToProto 

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

func DatastoreIODetails_FromProto 

func DatastoreIODetails_FromProto(mapCtx *direct.MapContext, in *pb.DatastoreIODetails) *krm.DatastoreIODetails

func DatastoreIODetails_ToProto 

func DatastoreIODetails_ToProto(mapCtx *direct.MapContext, in *krm.DatastoreIODetails) *pb.DatastoreIODetails

func DebugOptions_FromProto 

func DebugOptions_FromProto(mapCtx *direct.MapContext, in *pb.DebugOptions) *krm.DebugOptions

func DebugOptions_ToProto 

func DebugOptions_ToProto(mapCtx *direct.MapContext, in *krm.DebugOptions) *pb.DebugOptions

func Disk_FromProto 

func Disk_FromProto(mapCtx *direct.MapContext, in *pb.Disk) *krm.Disk

func Disk_ToProto 

func Disk_ToProto(mapCtx *direct.MapContext, in *krm.Disk) *pb.Disk

func DisplayData_FromProto 

func DisplayData_FromProto(mapCtx *direct.MapContext, in *pb.DisplayData) *krm.DisplayData

Override because of unhandled Any / Value / Struct fields

func DisplayData_ToProto 

func DisplayData_ToProto(mapCtx *direct.MapContext, in *krm.DisplayData) *pb.DisplayData

Override because of unhandled Any / Value / Struct fields

func DynamicTemplateLaunchParams_FromProto 

func DynamicTemplateLaunchParams_FromProto(mapCtx *direct.MapContext, in *pb.DynamicTemplateLaunchParams) *krm.DynamicTemplateLaunchParams

func DynamicTemplateLaunchParams_ToProto 

func DynamicTemplateLaunchParams_ToProto(mapCtx *direct.MapContext, in *krm.DynamicTemplateLaunchParams) *pb.DynamicTemplateLaunchParams

func Environment_FromProto 

func Environment_FromProto(mapCtx *direct.MapContext, in *pb.Environment) *krm.Environment

Override because of unhandled Any / Value / Struct fields

func Environment_ToProto 

func Environment_ToProto(mapCtx *direct.MapContext, in *krm.Environment) *pb.Environment

Override because of unhandled Any / Value / Struct fields

func ExecutionStageState_CurrentStateTime_FromProto 

func ExecutionStageState_CurrentStateTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func ExecutionStageState_CurrentStateTime_ToProto 

func ExecutionStageState_CurrentStateTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func ExecutionStageState_FromProto 

func ExecutionStageState_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionStageState) *krm.ExecutionStageState

func ExecutionStageState_ToProto 

func ExecutionStageState_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionStageState) *pb.ExecutionStageState

func ExecutionStageSummary_ComponentSource_FromProto 

func ExecutionStageSummary_ComponentSource_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionStageSummary_ComponentSource) *krm.ExecutionStageSummary_ComponentSource

func ExecutionStageSummary_ComponentSource_ToProto 

func ExecutionStageSummary_ComponentSource_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionStageSummary_ComponentSource) *pb.ExecutionStageSummary_ComponentSource

func ExecutionStageSummary_ComponentTransform_FromProto 

func ExecutionStageSummary_ComponentTransform_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionStageSummary_ComponentTransform) *krm.ExecutionStageSummary_ComponentTransform

func ExecutionStageSummary_ComponentTransform_ToProto 

func ExecutionStageSummary_ComponentTransform_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionStageSummary_ComponentTransform) *pb.ExecutionStageSummary_ComponentTransform

func ExecutionStageSummary_FromProto 

func ExecutionStageSummary_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionStageSummary) *krm.ExecutionStageSummary

func ExecutionStageSummary_StageSource_FromProto 

func ExecutionStageSummary_StageSource_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionStageSummary_StageSource) *krm.ExecutionStageSummary_StageSource

func ExecutionStageSummary_StageSource_ToProto 

func ExecutionStageSummary_StageSource_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionStageSummary_StageSource) *pb.ExecutionStageSummary_StageSource

func ExecutionStageSummary_ToProto 

func ExecutionStageSummary_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionStageSummary) *pb.ExecutionStageSummary

func FailedLocation_FromProto 

func FailedLocation_FromProto(mapCtx *direct.MapContext, in *pb.FailedLocation) *krm.FailedLocation

func FailedLocation_ToProto 

func FailedLocation_ToProto(mapCtx *direct.MapContext, in *krm.FailedLocation) *pb.FailedLocation

func FileIODetails_FromProto 

func FileIODetails_FromProto(mapCtx *direct.MapContext, in *pb.FileIODetails) *krm.FileIODetails

func FileIODetails_ToProto 

func FileIODetails_ToProto(mapCtx *direct.MapContext, in *krm.FileIODetails) *pb.FileIODetails

func InvalidTemplateParameters_FromProto 

func InvalidTemplateParameters_FromProto(mapCtx *direct.MapContext, in *pb.InvalidTemplateParameters) *krm.InvalidTemplateParameters

func InvalidTemplateParameters_ParameterViolation_FromProto 

func InvalidTemplateParameters_ParameterViolation_FromProto(mapCtx *direct.MapContext, in *pb.InvalidTemplateParameters_ParameterViolation) *krm.InvalidTemplateParameters_ParameterViolation

func InvalidTemplateParameters_ParameterViolation_ToProto 

func InvalidTemplateParameters_ParameterViolation_ToProto(mapCtx *direct.MapContext, in *krm.InvalidTemplateParameters_ParameterViolation) *pb.InvalidTemplateParameters_ParameterViolation

func InvalidTemplateParameters_ToProto 

func InvalidTemplateParameters_ToProto(mapCtx *direct.MapContext, in *krm.InvalidTemplateParameters) *pb.InvalidTemplateParameters

func JobExecutionDetails_FromProto 

func JobExecutionDetails_FromProto(mapCtx *direct.MapContext, in *pb.JobExecutionDetails) *krm.JobExecutionDetails

func JobExecutionDetails_ToProto 

func JobExecutionDetails_ToProto(mapCtx *direct.MapContext, in *krm.JobExecutionDetails) *pb.JobExecutionDetails

func JobExecutionInfo_FromProto 

func JobExecutionInfo_FromProto(mapCtx *direct.MapContext, in *pb.JobExecutionInfo) *krm.JobExecutionInfo

func JobExecutionInfo_ToProto 

func JobExecutionInfo_ToProto(mapCtx *direct.MapContext, in *krm.JobExecutionInfo) *pb.JobExecutionInfo

func JobExecutionStageInfo_FromProto 

func JobExecutionStageInfo_FromProto(mapCtx *direct.MapContext, in *pb.JobExecutionStageInfo) *krm.JobExecutionStageInfo

func JobExecutionStageInfo_ToProto 

func JobExecutionStageInfo_ToProto(mapCtx *direct.MapContext, in *krm.JobExecutionStageInfo) *pb.JobExecutionStageInfo

func JobMessage_FromProto 

func JobMessage_FromProto(mapCtx *direct.MapContext, in *pb.JobMessage) *krm.JobMessage

func JobMessage_Time_FromProto 

func JobMessage_Time_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func JobMessage_Time_ToProto 

func JobMessage_Time_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func JobMessage_ToProto 

func JobMessage_ToProto(mapCtx *direct.MapContext, in *krm.JobMessage) *pb.JobMessage

func JobMetrics_FromProto 

func JobMetrics_FromProto(mapCtx *direct.MapContext, in *pb.JobMetrics) *krm.JobMetrics

Override because of unhandled Any / Value / Struct fields

func JobMetrics_MetricTime_FromProto 

func JobMetrics_MetricTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func JobMetrics_MetricsTime_ToProto 

func JobMetrics_MetricsTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func JobMetrics_ToProto 

func JobMetrics_ToProto(mapCtx *direct.MapContext, in *krm.JobMetrics) *pb.JobMetrics

Override because of unhandled Any / Value / Struct fields

func Job_CreateTime_FromProto 

func Job_CreateTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func Job_CreateTime_ToProto 

func Job_CreateTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func Job_FromProto 

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

Override because of unhandled Any / Value / Struct fields

func Job_StartTime_FromProto 

func Job_StartTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func Job_StartTime_ToProto 

func Job_StartTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func Job_ToProto 

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

Override because of unhandled Any / Value / Struct fields

func KeyRangeDataDiskAssignment_FromProto 

func KeyRangeDataDiskAssignment_FromProto(mapCtx *direct.MapContext, in *pb.KeyRangeDataDiskAssignment) *krm.KeyRangeDataDiskAssignment

func KeyRangeDataDiskAssignment_ToProto 

func KeyRangeDataDiskAssignment_ToProto(mapCtx *direct.MapContext, in *krm.KeyRangeDataDiskAssignment) *pb.KeyRangeDataDiskAssignment

func KeyRangeLocation_FromProto 

func KeyRangeLocation_FromProto(mapCtx *direct.MapContext, in *pb.KeyRangeLocation) *krm.KeyRangeLocation

func KeyRangeLocation_ToProto 

func KeyRangeLocation_ToProto(mapCtx *direct.MapContext, in *krm.KeyRangeLocation) *pb.KeyRangeLocation

func LaunchFlexTemplateParameter_FromProto 

func LaunchFlexTemplateParameter_FromProto(mapCtx *direct.MapContext, in *pb.LaunchFlexTemplateParameter) *krm.LaunchFlexTemplateParameter

Override because of unhandled Any / Value / Struct fields

func LaunchFlexTemplateParameter_ToProto 

func LaunchFlexTemplateParameter_ToProto(mapCtx *direct.MapContext, in *krm.LaunchFlexTemplateParameter) *pb.LaunchFlexTemplateParameter

Override because of unhandled Any / Value / Struct fields

func LaunchTemplateParameters_FromProto 

func LaunchTemplateParameters_FromProto(mapCtx *direct.MapContext, in *pb.LaunchTemplateParameters) *krm.LaunchTemplateParameters

func LaunchTemplateParameters_ToProto 

func LaunchTemplateParameters_ToProto(mapCtx *direct.MapContext, in *krm.LaunchTemplateParameters) *pb.LaunchTemplateParameters

func MetricStructuredName_FromProto 

func MetricStructuredName_FromProto(mapCtx *direct.MapContext, in *pb.MetricStructuredName) *krm.MetricStructuredName

func MetricStructuredName_ToProto 

func MetricStructuredName_ToProto(mapCtx *direct.MapContext, in *krm.MetricStructuredName) *pb.MetricStructuredName

func MetricUpdate_FromProto 

func MetricUpdate_FromProto(mapCtx *direct.MapContext, in *pb.MetricUpdate) *krm.MetricUpdate

Override because of unhandled Any / Value / Struct fields

func MetricUpdate_ToProto 

func MetricUpdate_ToProto(mapCtx *direct.MapContext, in *krm.MetricUpdate) *pb.MetricUpdate

Override because of unhandled Any / Value / Struct fields

func MountedDataDisk_FromProto 

func MountedDataDisk_FromProto(mapCtx *direct.MapContext, in *pb.MountedDataDisk) *krm.MountedDataDisk

func MountedDataDisk_ToProto 

func MountedDataDisk_ToProto(mapCtx *direct.MapContext, in *krm.MountedDataDisk) *pb.MountedDataDisk

func Package_FromProto 

func Package_FromProto(mapCtx *direct.MapContext, in *pb.Package) *krm.Package

func Package_ToProto 

func Package_ToProto(mapCtx *direct.MapContext, in *krm.Package) *pb.Package

func PipelineDescription_FromProto 

func PipelineDescription_FromProto(mapCtx *direct.MapContext, in *pb.PipelineDescription) *krm.PipelineDescription

func PipelineDescription_ToProto 

func PipelineDescription_ToProto(mapCtx *direct.MapContext, in *krm.PipelineDescription) *pb.PipelineDescription

func Point_Time_FromProto 

func Point_Time_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func Point_Time_ToProto 

func Point_Time_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func ProgressTimeseries_FromProto 

func ProgressTimeseries_FromProto(mapCtx *direct.MapContext, in *pb.ProgressTimeseries) *krm.ProgressTimeseries

func ProgressTimeseries_Point_FromProto 

func ProgressTimeseries_Point_FromProto(mapCtx *direct.MapContext, in *pb.ProgressTimeseries_Point) *krm.ProgressTimeseries_Point

func ProgressTimeseries_Point_ToProto 

func ProgressTimeseries_Point_ToProto(mapCtx *direct.MapContext, in *krm.ProgressTimeseries_Point) *pb.ProgressTimeseries_Point

func ProgressTimeseries_ToProto 

func ProgressTimeseries_ToProto(mapCtx *direct.MapContext, in *krm.ProgressTimeseries) *pb.ProgressTimeseries

func PubSubIODetails_FromProto 

func PubSubIODetails_FromProto(mapCtx *direct.MapContext, in *pb.PubSubIODetails) *krm.PubSubIODetails

func PubSubIODetails_ToProto 

func PubSubIODetails_ToProto(mapCtx *direct.MapContext, in *krm.PubSubIODetails) *pb.PubSubIODetails

func PubsubLocation_FromProto 

func PubsubLocation_FromProto(mapCtx *direct.MapContext, in *pb.PubsubLocation) *krm.PubsubLocation

func PubsubLocation_ToProto 

func PubsubLocation_ToProto(mapCtx *direct.MapContext, in *krm.PubsubLocation) *pb.PubsubLocation

func PubsubSnapshotMetadata_FromProto 

func PubsubSnapshotMetadata_FromProto(mapCtx *direct.MapContext, in *pb.PubsubSnapshotMetadata) *krm.PubsubSnapshotMetadata

func PubsubSnapshotMetadata_ToProto 

func PubsubSnapshotMetadata_ToProto(mapCtx *direct.MapContext, in *krm.PubsubSnapshotMetadata) *pb.PubsubSnapshotMetadata

func RuntimeEnvironment_FromProto 

func RuntimeEnvironment_FromProto(mapCtx *direct.MapContext, in *pb.RuntimeEnvironment) *krm.RuntimeEnvironment

func RuntimeEnvironment_ToProto 

func RuntimeEnvironment_ToProto(mapCtx *direct.MapContext, in *krm.RuntimeEnvironment) *pb.RuntimeEnvironment

func SDKInfo_FromProto 

func SDKInfo_FromProto(mapCtx *direct.MapContext, in *pb.SDKInfo) *krm.SDKInfo

func SDKInfo_ToProto 

func SDKInfo_ToProto(mapCtx *direct.MapContext, in *krm.SDKInfo) *pb.SDKInfo

func SdkHarnessContainerImage_FromProto 

func SdkHarnessContainerImage_FromProto(mapCtx *direct.MapContext, in *pb.SdkHarnessContainerImage) *krm.SdkHarnessContainerImage

func SdkHarnessContainerImage_ToProto 

func SdkHarnessContainerImage_ToProto(mapCtx *direct.MapContext, in *krm.SdkHarnessContainerImage) *pb.SdkHarnessContainerImage

func SdkVersion_FromProto 

func SdkVersion_FromProto(mapCtx *direct.MapContext, in *pb.SdkVersion) *krm.SdkVersion

func SdkVersion_ToProto 

func SdkVersion_ToProto(mapCtx *direct.MapContext, in *krm.SdkVersion) *pb.SdkVersion

func Snapshot_CreationTime_FromProto 

func Snapshot_CreationTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func Snapshot_CreationTime_ToProto 

func Snapshot_CreationTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func Snapshot_FromProto 

func Snapshot_FromProto(mapCtx *direct.MapContext, in *pb.Snapshot) *krm.Snapshot

func Snapshot_ToProto 

func Snapshot_ToProto(mapCtx *direct.MapContext, in *krm.Snapshot) *pb.Snapshot

func Snapshot_Ttl_FromProto 

func Snapshot_Ttl_FromProto(mapCtx *direct.MapContext, in *durationpb.Duration) *string

func Snapshot_Ttl_ToProto 

func Snapshot_Ttl_ToProto(mapCtx *direct.MapContext, in *string) *durationpb.Duration

func SpannerIODetails_FromProto 

func SpannerIODetails_FromProto(mapCtx *direct.MapContext, in *pb.SpannerIODetails) *krm.SpannerIODetails

func SpannerIODetails_ToProto 

func SpannerIODetails_ToProto(mapCtx *direct.MapContext, in *krm.SpannerIODetails) *pb.SpannerIODetails

func StageExecutionDetails_FromProto 

func StageExecutionDetails_FromProto(mapCtx *direct.MapContext, in *pb.StageExecutionDetails) *krm.StageExecutionDetails

func StageExecutionDetails_ToProto 

func StageExecutionDetails_ToProto(mapCtx *direct.MapContext, in *krm.StageExecutionDetails) *pb.StageExecutionDetails

func StageSummary_EndTime_FromProto 

func StageSummary_EndTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func StageSummary_EndTime_ToProto 

func StageSummary_EndTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func StageSummary_FromProto 

func StageSummary_FromProto(mapCtx *direct.MapContext, in *pb.StageSummary) *krm.StageSummary

func StageSummary_StartTime_FromProto 

func StageSummary_StartTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func StageSummary_StartTime_ToProto 

func StageSummary_StartTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func StageSummary_ToProto 

func StageSummary_ToProto(mapCtx *direct.MapContext, in *krm.StageSummary) *pb.StageSummary

func StateFamilyConfig_FromProto 

func StateFamilyConfig_FromProto(mapCtx *direct.MapContext, in *pb.StateFamilyConfig) *krm.StateFamilyConfig

func StateFamilyConfig_ToProto 

func StateFamilyConfig_ToProto(mapCtx *direct.MapContext, in *krm.StateFamilyConfig) *pb.StateFamilyConfig

func Step_FromProto 

func Step_FromProto(mapCtx *direct.MapContext, in *pb.Step) *krm.Step

Override because of unhandled Any / Value / Struct fields

func Step_ToProto 

func Step_ToProto(mapCtx *direct.MapContext, in *krm.Step) *pb.Step

Override because of unhandled Any / Value / Struct fields

func StreamLocation_FromProto 

func StreamLocation_FromProto(mapCtx *direct.MapContext, in *pb.StreamLocation) *krm.StreamLocation

func StreamLocation_ToProto 

func StreamLocation_ToProto(mapCtx *direct.MapContext, in *krm.StreamLocation) *pb.StreamLocation

func StreamingApplianceSnapshotConfig_FromProto 

func StreamingApplianceSnapshotConfig_FromProto(mapCtx *direct.MapContext, in *pb.StreamingApplianceSnapshotConfig) *krm.StreamingApplianceSnapshotConfig

func StreamingApplianceSnapshotConfig_ToProto 

func StreamingApplianceSnapshotConfig_ToProto(mapCtx *direct.MapContext, in *krm.StreamingApplianceSnapshotConfig) *pb.StreamingApplianceSnapshotConfig

func StreamingComputationRanges_FromProto 

func StreamingComputationRanges_FromProto(mapCtx *direct.MapContext, in *pb.StreamingComputationRanges) *krm.StreamingComputationRanges

func StreamingComputationRanges_ToProto 

func StreamingComputationRanges_ToProto(mapCtx *direct.MapContext, in *krm.StreamingComputationRanges) *pb.StreamingComputationRanges

func StreamingSideInputLocation_FromProto 

func StreamingSideInputLocation_FromProto(mapCtx *direct.MapContext, in *pb.StreamingSideInputLocation) *krm.StreamingSideInputLocation

func StreamingSideInputLocation_ToProto 

func StreamingSideInputLocation_ToProto(mapCtx *direct.MapContext, in *krm.StreamingSideInputLocation) *pb.StreamingSideInputLocation

func StreamingStageLocation_FromProto 

func StreamingStageLocation_FromProto(mapCtx *direct.MapContext, in *pb.StreamingStageLocation) *krm.StreamingStageLocation

func StreamingStageLocation_ToProto 

func StreamingStageLocation_ToProto(mapCtx *direct.MapContext, in *krm.StreamingStageLocation) *pb.StreamingStageLocation

func StructuredMessage_FromProto 

func StructuredMessage_FromProto(mapCtx *direct.MapContext, in *pb.StructuredMessage) *krm.StructuredMessage

func StructuredMessage_Parameter_FromProto 

func StructuredMessage_Parameter_FromProto(mapCtx *direct.MapContext, in *pb.StructuredMessage_Parameter) *krm.StructuredMessage_Parameter

Override because of unhandled Any / Value / Struct fields

func StructuredMessage_Parameter_ToProto 

func StructuredMessage_Parameter_ToProto(mapCtx *direct.MapContext, in *krm.StructuredMessage_Parameter) *pb.StructuredMessage_Parameter

Override because of unhandled Any / Value / Struct fields

func StructuredMessage_ToProto 

func StructuredMessage_ToProto(mapCtx *direct.MapContext, in *krm.StructuredMessage) *pb.StructuredMessage

func TaskRunnerSettings_FromProto 

func TaskRunnerSettings_FromProto(mapCtx *direct.MapContext, in *pb.TaskRunnerSettings) *krm.TaskRunnerSettings

func TaskRunnerSettings_ToProto 

func TaskRunnerSettings_ToProto(mapCtx *direct.MapContext, in *krm.TaskRunnerSettings) *pb.TaskRunnerSettings

func Timestamp_FromProto 

func Timestamp_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func Timestamp_ToProto 

func Timestamp_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func TopologyConfig_FromProto 

func TopologyConfig_FromProto(mapCtx *direct.MapContext, in *pb.TopologyConfig) *krm.TopologyConfig

func TopologyConfig_ToProto 

func TopologyConfig_ToProto(mapCtx *direct.MapContext, in *krm.TopologyConfig) *pb.TopologyConfig

func TransformSummary_FromProto 

func TransformSummary_FromProto(mapCtx *direct.MapContext, in *pb.TransformSummary) *krm.TransformSummary

func TransformSummary_ToProto 

func TransformSummary_ToProto(mapCtx *direct.MapContext, in *krm.TransformSummary) *pb.TransformSummary

func WorkItemDetails_EndTime_FromProto 

func WorkItemDetails_EndTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func WorkItemDetails_EndTime_ToProto 

func WorkItemDetails_EndTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func WorkItemDetails_FromProto 

func WorkItemDetails_FromProto(mapCtx *direct.MapContext, in *pb.WorkItemDetails) *krm.WorkItemDetails

func WorkItemDetails_StartTime_FromProto 

func WorkItemDetails_StartTime_FromProto(mapCtx *direct.MapContext, in *timestamppb.Timestamp) *string

func WorkItemDetails_StartTime_ToProto 

func WorkItemDetails_StartTime_ToProto(mapCtx *direct.MapContext, in *string) *timestamppb.Timestamp

func WorkItemDetails_ToProto 

func WorkItemDetails_ToProto(mapCtx *direct.MapContext, in *krm.WorkItemDetails) *pb.WorkItemDetails

func WorkerDetails_FromProto 

func WorkerDetails_FromProto(mapCtx *direct.MapContext, in *pb.WorkerDetails) *krm.WorkerDetails

func WorkerDetails_ToProto 

func WorkerDetails_ToProto(mapCtx *direct.MapContext, in *krm.WorkerDetails) *pb.WorkerDetails

func WorkerPool_FromProto 

func WorkerPool_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPool) *krm.WorkerPool

Override because of unhandled Any / Value / Struct fields

func WorkerPool_ToProto 

func WorkerPool_ToProto(mapCtx *direct.MapContext, in *krm.WorkerPool) *pb.WorkerPool

Override because of unhandled Any / Value / Struct fields

func WorkerSettings_FromProto 

func WorkerSettings_FromProto(mapCtx *direct.MapContext, in *pb.WorkerSettings) *krm.WorkerSettings

func WorkerSettings_ToProto 

func WorkerSettings_ToProto(mapCtx *direct.MapContext, in *krm.WorkerSettings) *pb.WorkerSettings

Types

This section is empty.

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.