gogol-dataflow-0.4.0: Google Dataflow SDK.

Copyright(c) 2015-2016 Brendan Hay
LicenseMozilla Public License, v. 2.0.
MaintainerBrendan Hay <brendan.g.hay@gmail.com>
Stabilityauto-generated
Portabilitynon-portable (GHC extensions)
Safe HaskellNone
LanguageHaskell2010

Network.Google.Dataflow

Contents

Description

Manages Google Cloud Dataflow projects on Google Cloud Platform.

See: Dataflow API Reference

Synopsis

Service Configuration

dataflowService :: ServiceConfig Source #

Default request referring to version v1b3 of the Dataflow API. This contains the host and root path used as a starting point for constructing service requests.

OAuth Scopes

computeScope :: Proxy '["https://www.googleapis.com/auth/compute"] Source #

View and manage your Google Compute Engine resources

userInfoEmailScope :: Proxy '["https://www.googleapis.com/auth/userinfo.email"] Source #

View your email address

cloudPlatformScope :: Proxy '["https://www.googleapis.com/auth/cloud-platform"] Source #

View and manage your data across Google Cloud Platform services

computeReadOnlyScope :: Proxy '["https://www.googleapis.com/auth/compute.readonly"] Source #

View your Google Compute Engine resources

API Declaration

Resources

dataflow.projects.jobs.aggregated

dataflow.projects.jobs.create

dataflow.projects.jobs.debug.getConfig

dataflow.projects.jobs.debug.sendCapture

dataflow.projects.jobs.get

dataflow.projects.jobs.getMetrics

dataflow.projects.jobs.list

dataflow.projects.jobs.messages.list

dataflow.projects.jobs.snapshot

dataflow.projects.jobs.update

dataflow.projects.jobs.workItems.lease

dataflow.projects.jobs.workItems.reportStatus

dataflow.projects.locations.jobs.create

dataflow.projects.locations.jobs.debug.getConfig

dataflow.projects.locations.jobs.debug.sendCapture

dataflow.projects.locations.jobs.get

dataflow.projects.locations.jobs.getMetrics

dataflow.projects.locations.jobs.list

dataflow.projects.locations.jobs.messages.list

dataflow.projects.locations.jobs.snapshot

dataflow.projects.locations.jobs.update

dataflow.projects.locations.jobs.workItems.lease

dataflow.projects.locations.jobs.workItems.reportStatus

dataflow.projects.locations.templates.create

dataflow.projects.locations.templates.get

dataflow.projects.locations.templates.launch

dataflow.projects.locations.workerMessages

dataflow.projects.templates.create

dataflow.projects.templates.get

dataflow.projects.templates.launch

dataflow.projects.workerMessages

Types

NameAndKindKind

data NameAndKindKind Source #

Counter aggregation kind.

Constructors

Invalid

INVALID Counter aggregation kind was not set.

Sum

SUM Aggregated value is the sum of all contributed values.

Max

MAX Aggregated value is the max of all contributed values.

Min

MIN Aggregated value is the min of all contributed values.

Mean

MEAN Aggregated value is the mean of all contributed values.

OR

OR Aggregated value represents the logical 'or' of all contributed values.

And

AND Aggregated value represents the logical 'and' of all contributed values.

Set

SET Aggregated value is a set of unique contributed values.

Distribution

DISTRIBUTION Aggregated value captures statistics about a distribution.

LatestValue

LATEST_VALUE Aggregated value tracks the latest value of a variable.

Instances
Enum NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Eq NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Data NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> NameAndKindKind -> c NameAndKindKind #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c NameAndKindKind #

toConstr :: NameAndKindKind -> Constr #

dataTypeOf :: NameAndKindKind -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c NameAndKindKind) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c NameAndKindKind) #

gmapT :: (forall b. Data b => b -> b) -> NameAndKindKind -> NameAndKindKind #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> NameAndKindKind -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> NameAndKindKind -> r #

gmapQ :: (forall d. Data d => d -> u) -> NameAndKindKind -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> NameAndKindKind -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> NameAndKindKind -> m NameAndKindKind #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> NameAndKindKind -> m NameAndKindKind #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> NameAndKindKind -> m NameAndKindKind #

Ord NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Read NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Show NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Generic NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Associated Types

type Rep NameAndKindKind :: Type -> Type #

Hashable NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

ToJSON NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

FromJSON NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

FromHttpApiData NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

ToHttpApiData NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

type Rep NameAndKindKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

type Rep NameAndKindKind = D1 (MetaData "NameAndKindKind" "Network.Google.Dataflow.Types.Sum" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (((C1 (MetaCons "Invalid" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Sum" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "Max" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "Min" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Mean" PrefixI False) (U1 :: Type -> Type)))) :+: ((C1 (MetaCons "OR" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "And" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "Set" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "Distribution" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "LatestValue" PrefixI False) (U1 :: Type -> Type)))))

JobExecutionInfoStages

data JobExecutionInfoStages Source #

A mapping from each stage to the information about that stage.

See: jobExecutionInfoStages smart constructor.

Instances
Eq JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> JobExecutionInfoStages -> c JobExecutionInfoStages #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c JobExecutionInfoStages #

toConstr :: JobExecutionInfoStages -> Constr #

dataTypeOf :: JobExecutionInfoStages -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c JobExecutionInfoStages) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c JobExecutionInfoStages) #

gmapT :: (forall b. Data b => b -> b) -> JobExecutionInfoStages -> JobExecutionInfoStages #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> JobExecutionInfoStages -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> JobExecutionInfoStages -> r #

gmapQ :: (forall d. Data d => d -> u) -> JobExecutionInfoStages -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> JobExecutionInfoStages -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> JobExecutionInfoStages -> m JobExecutionInfoStages #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> JobExecutionInfoStages -> m JobExecutionInfoStages #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> JobExecutionInfoStages -> m JobExecutionInfoStages #

Show JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep JobExecutionInfoStages :: Type -> Type #

ToJSON JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep JobExecutionInfoStages Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep JobExecutionInfoStages = D1 (MetaData "JobExecutionInfoStages" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" True) (C1 (MetaCons "JobExecutionInfoStages'" PrefixI True) (S1 (MetaSel (Just "_jeisAddtional") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (HashMap Text JobExecutionStageInfo))))

jobExecutionInfoStages Source #

Creates a value of JobExecutionInfoStages with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ComputationTopology

data ComputationTopology Source #

All configuration data for a particular Computation.

See: computationTopology smart constructor.

Instances
Eq ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ComputationTopology -> c ComputationTopology #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ComputationTopology #

toConstr :: ComputationTopology -> Constr #

dataTypeOf :: ComputationTopology -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c ComputationTopology) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ComputationTopology) #

gmapT :: (forall b. Data b => b -> b) -> ComputationTopology -> ComputationTopology #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ComputationTopology -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ComputationTopology -> r #

gmapQ :: (forall d. Data d => d -> u) -> ComputationTopology -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ComputationTopology -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ComputationTopology -> m ComputationTopology #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ComputationTopology -> m ComputationTopology #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ComputationTopology -> m ComputationTopology #

Show ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep ComputationTopology :: Type -> Type #

ToJSON ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ComputationTopology Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ComputationTopology = D1 (MetaData "ComputationTopology" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "ComputationTopology'" PrefixI True) ((S1 (MetaSel (Just "_ctStateFamilies") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [StateFamilyConfig])) :*: (S1 (MetaSel (Just "_ctInputs") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [StreamLocation])) :*: S1 (MetaSel (Just "_ctKeyRanges") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [KeyRangeLocation])))) :*: (S1 (MetaSel (Just "_ctOutputs") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [StreamLocation])) :*: (S1 (MetaSel (Just "_ctComputationId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_ctSystemStageName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

computationTopology :: ComputationTopology Source #

Creates a value of ComputationTopology with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ctInputs :: Lens' ComputationTopology [StreamLocation] Source #

The inputs to the computation.

ctKeyRanges :: Lens' ComputationTopology [KeyRangeLocation] Source #

The key ranges processed by the computation.

ctOutputs :: Lens' ComputationTopology [StreamLocation] Source #

The outputs from the computation.

ctComputationId :: Lens' ComputationTopology (Maybe Text) Source #

The ID of the computation.

SourceSplitResponse

data SourceSplitResponse Source #

The response to a SourceSplitRequest.

See: sourceSplitResponse smart constructor.

Instances
Eq SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> SourceSplitResponse -> c SourceSplitResponse #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c SourceSplitResponse #

toConstr :: SourceSplitResponse -> Constr #

dataTypeOf :: SourceSplitResponse -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c SourceSplitResponse) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c SourceSplitResponse) #

gmapT :: (forall b. Data b => b -> b) -> SourceSplitResponse -> SourceSplitResponse #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> SourceSplitResponse -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> SourceSplitResponse -> r #

gmapQ :: (forall d. Data d => d -> u) -> SourceSplitResponse -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> SourceSplitResponse -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> SourceSplitResponse -> m SourceSplitResponse #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSplitResponse -> m SourceSplitResponse #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSplitResponse -> m SourceSplitResponse #

Show SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep SourceSplitResponse :: Type -> Type #

ToJSON SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep SourceSplitResponse Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep SourceSplitResponse = D1 (MetaData "SourceSplitResponse" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "SourceSplitResponse'" PrefixI True) (S1 (MetaSel (Just "_ssrBundles") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [DerivedSource])) :*: (S1 (MetaSel (Just "_ssrShards") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [SourceSplitShard])) :*: S1 (MetaSel (Just "_ssrOutcome") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSplitResponseOutcome)))))

sourceSplitResponse :: SourceSplitResponse Source #

Creates a value of SourceSplitResponse with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ssrBundles :: Lens' SourceSplitResponse [DerivedSource] Source #

If outcome is SPLITTING_HAPPENED, then this is a list of bundles into which the source was split. Otherwise this field is ignored. This list can be empty, which means the source represents an empty input.

ssrShards :: Lens' SourceSplitResponse [SourceSplitShard] Source #

DEPRECATED in favor of bundles.

ssrOutcome :: Lens' SourceSplitResponse (Maybe SourceSplitResponseOutcome) Source #

Indicates whether splitting happened and produced a list of bundles. If this is USE_CURRENT_SOURCE_AS_IS, the current source should be processed "as is" without splitting. "bundles" is ignored in this case. If this is SPLITTING_HAPPENED, then "bundles" contains a list of bundles into which the source was split.

ParameterMetadata

data ParameterMetadata Source #

Metadata for a specific parameter.

See: parameterMetadata smart constructor.

Instances
Eq ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ParameterMetadata -> c ParameterMetadata #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ParameterMetadata #

toConstr :: ParameterMetadata -> Constr #

dataTypeOf :: ParameterMetadata -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c ParameterMetadata) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ParameterMetadata) #

gmapT :: (forall b. Data b => b -> b) -> ParameterMetadata -> ParameterMetadata #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ParameterMetadata -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ParameterMetadata -> r #

gmapQ :: (forall d. Data d => d -> u) -> ParameterMetadata -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ParameterMetadata -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ParameterMetadata -> m ParameterMetadata #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ParameterMetadata -> m ParameterMetadata #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ParameterMetadata -> m ParameterMetadata #

Show ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep ParameterMetadata :: Type -> Type #

ToJSON ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ParameterMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ParameterMetadata = D1 (MetaData "ParameterMetadata" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "ParameterMetadata'" PrefixI True) ((S1 (MetaSel (Just "_pmHelpText") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_pmIsOptional") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Bool))) :*: (S1 (MetaSel (Just "_pmName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_pmRegexes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [Text])) :*: S1 (MetaSel (Just "_pmLabel") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

parameterMetadata :: ParameterMetadata Source #

Creates a value of ParameterMetadata with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

pmHelpText :: Lens' ParameterMetadata (Maybe Text) Source #

Required. The help text to display for the parameter.

pmIsOptional :: Lens' ParameterMetadata (Maybe Bool) Source #

Optional. Whether the parameter is optional. Defaults to false.

pmName :: Lens' ParameterMetadata (Maybe Text) Source #

Required. The name of the parameter.

pmRegexes :: Lens' ParameterMetadata [Text] Source #

Optional. Regexes that the parameter must match.

pmLabel :: Lens' ParameterMetadata (Maybe Text) Source #

Required. The label to display for the parameter.

CreateJobFromTemplateRequest

data CreateJobFromTemplateRequest Source #

A request to create a Cloud Dataflow job from a template.

See: createJobFromTemplateRequest smart constructor.

Instances
Eq CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> CreateJobFromTemplateRequest -> c CreateJobFromTemplateRequest #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c CreateJobFromTemplateRequest #

toConstr :: CreateJobFromTemplateRequest -> Constr #

dataTypeOf :: CreateJobFromTemplateRequest -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c CreateJobFromTemplateRequest) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c CreateJobFromTemplateRequest) #

gmapT :: (forall b. Data b => b -> b) -> CreateJobFromTemplateRequest -> CreateJobFromTemplateRequest #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> CreateJobFromTemplateRequest -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> CreateJobFromTemplateRequest -> r #

gmapQ :: (forall d. Data d => d -> u) -> CreateJobFromTemplateRequest -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> CreateJobFromTemplateRequest -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> CreateJobFromTemplateRequest -> m CreateJobFromTemplateRequest #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> CreateJobFromTemplateRequest -> m CreateJobFromTemplateRequest #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> CreateJobFromTemplateRequest -> m CreateJobFromTemplateRequest #

Show CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep CreateJobFromTemplateRequest :: Type -> Type #

ToJSON CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep CreateJobFromTemplateRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep CreateJobFromTemplateRequest = D1 (MetaData "CreateJobFromTemplateRequest" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "CreateJobFromTemplateRequest'" PrefixI True) ((S1 (MetaSel (Just "_cjftrLocation") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_cjftrEnvironment") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe RuntimeEnvironment))) :*: (S1 (MetaSel (Just "_cjftrJobName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_cjftrGcsPath") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_cjftrParameters") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe CreateJobFromTemplateRequestParameters))))))

createJobFromTemplateRequest :: CreateJobFromTemplateRequest Source #

Creates a value of CreateJobFromTemplateRequest with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

cjftrLocation :: Lens' CreateJobFromTemplateRequest (Maybe Text) Source #

The location to which to direct the request.

cjftrJobName :: Lens' CreateJobFromTemplateRequest (Maybe Text) Source #

Required. The job name to use for the created job.

cjftrGcsPath :: Lens' CreateJobFromTemplateRequest (Maybe Text) Source #

Required. A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with `gs://`.

Status

data Status Source #

The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by gRPC. The error model is designed to be: - Simple to use and understand for most users - Flexible enough to meet unexpected needs # Overview The `Status` message contains three pieces of data: error code, error message, and error details. The error code should be an enum value of google.rpc.Code, but it may accept additional error codes if needed. The error message should be a developer-facing English message that helps developers *understand* and *resolve* the error. If a localized user-facing error message is needed, put the localized message in the error details or localize it in the client. The optional error details may contain arbitrary information about the error. There is a predefined set of error detail types in the package `google.rpc` that can be used for common error conditions. # Language mapping The `Status` message is the logical representation of the error model, but it is not necessarily the actual wire format. When the `Status` message is exposed in different client libraries and different wire protocols, it can be mapped differently. For example, it will likely be mapped to some exceptions in Java, but more likely mapped to some error codes in C. # Other uses The error model and the `Status` message can be used in a variety of environments, either with or without APIs, to provide a consistent developer experience across different environments. Example uses of this error model include: - Partial errors. If a service needs to return partial errors to the client, it may embed the `Status` in the normal response to indicate the partial errors. - Workflow errors. A typical workflow has multiple steps. Each step may have a `Status` message for error reporting. - Batch operations. If a client uses batch request and batch response, the `Status` message should be used directly inside batch response, one for each error sub-response. - Asynchronous operations. If an API call embeds asynchronous operation results in its response, the status of those operations should be represented directly using the `Status` message. - Logging. If some API errors are stored in logs, the message `Status` could be used directly after any stripping needed for security/privacy reasons.

See: status smart constructor.

Instances
Eq Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

(==) :: Status -> Status -> Bool #

(/=) :: Status -> Status -> Bool #

Data Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Status -> c Status #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c Status #

toConstr :: Status -> Constr #

dataTypeOf :: Status -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c Status) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c Status) #

gmapT :: (forall b. Data b => b -> b) -> Status -> Status #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Status -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Status -> r #

gmapQ :: (forall d. Data d => d -> u) -> Status -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> Status -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Status -> m Status #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Status -> m Status #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Status -> m Status #

Show Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep Status :: Type -> Type #

Methods

from :: Status -> Rep Status x #

to :: Rep Status x -> Status #

ToJSON Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep Status Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep Status = D1 (MetaData "Status" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "Status'" PrefixI True) (S1 (MetaSel (Just "_sDetails") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [StatusDetailsItem])) :*: (S1 (MetaSel (Just "_sCode") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int32))) :*: S1 (MetaSel (Just "_sMessage") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

status :: Status Source #

Creates a value of Status with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

sDetails :: Lens' Status [StatusDetailsItem] Source #

A list of messages that carry the error details. There is a common set of message types for APIs to use.

sCode :: Lens' Status (Maybe Int32) Source #

The status code, which should be an enum value of google.rpc.Code.

sMessage :: Lens' Status (Maybe Text) Source #

A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client.

NameAndKind

data NameAndKind Source #

Basic metadata about a counter.

See: nameAndKind smart constructor.

Instances
Eq NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> NameAndKind -> c NameAndKind #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c NameAndKind #

toConstr :: NameAndKind -> Constr #

dataTypeOf :: NameAndKind -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c NameAndKind) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c NameAndKind) #

gmapT :: (forall b. Data b => b -> b) -> NameAndKind -> NameAndKind #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> NameAndKind -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> NameAndKind -> r #

gmapQ :: (forall d. Data d => d -> u) -> NameAndKind -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> NameAndKind -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> NameAndKind -> m NameAndKind #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> NameAndKind -> m NameAndKind #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> NameAndKind -> m NameAndKind #

Show NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep NameAndKind :: Type -> Type #

ToJSON NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep NameAndKind Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep NameAndKind = D1 (MetaData "NameAndKind" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "NameAndKind'" PrefixI True) (S1 (MetaSel (Just "_nakKind") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe NameAndKindKind)) :*: S1 (MetaSel (Just "_nakName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))

nameAndKind :: NameAndKind Source #

Creates a value of NameAndKind with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

nakKind :: Lens' NameAndKind (Maybe NameAndKindKind) Source #

Counter aggregation kind.

nakName :: Lens' NameAndKind (Maybe Text) Source #

Name of the counter.

IntegerList

data IntegerList Source #

A metric value representing a list of integers.

See: integerList smart constructor.

Instances
Eq IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> IntegerList -> c IntegerList #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c IntegerList #

toConstr :: IntegerList -> Constr #

dataTypeOf :: IntegerList -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c IntegerList) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c IntegerList) #

gmapT :: (forall b. Data b => b -> b) -> IntegerList -> IntegerList #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> IntegerList -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> IntegerList -> r #

gmapQ :: (forall d. Data d => d -> u) -> IntegerList -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> IntegerList -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> IntegerList -> m IntegerList #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> IntegerList -> m IntegerList #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> IntegerList -> m IntegerList #

Show IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep IntegerList :: Type -> Type #

ToJSON IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep IntegerList Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep IntegerList = D1 (MetaData "IntegerList" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" True) (C1 (MetaCons "IntegerList'" PrefixI True) (S1 (MetaSel (Just "_ilElements") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe [SplitInt64]))))

integerList :: IntegerList Source #

Creates a value of IntegerList with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ilElements :: Lens' IntegerList [SplitInt64] Source #

Elements of the list.

WorkItem

data WorkItem Source #

WorkItem represents basic information about a WorkItem to be executed in the cloud.

See: workItem smart constructor.

Instances
Eq WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> WorkItem -> c WorkItem #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c WorkItem #

toConstr :: WorkItem -> Constr #

dataTypeOf :: WorkItem -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c WorkItem) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c WorkItem) #

gmapT :: (forall b. Data b => b -> b) -> WorkItem -> WorkItem #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> WorkItem -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> WorkItem -> r #

gmapQ :: (forall d. Data d => d -> u) -> WorkItem -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> WorkItem -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> WorkItem -> m WorkItem #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkItem -> m WorkItem #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkItem -> m WorkItem #

Show WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep WorkItem :: Type -> Type #

Methods

from :: WorkItem -> Rep WorkItem x #

to :: Rep WorkItem x -> WorkItem #

ToJSON WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkItem Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkItem = D1 (MetaData "WorkItem" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "WorkItem'" PrefixI True) (((S1 (MetaSel (Just "_wiJobId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_wiReportStatusInterval") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe GDuration)) :*: S1 (MetaSel (Just "_wiShellTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe ShellTask)))) :*: ((S1 (MetaSel (Just "_wiStreamingSetupTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe StreamingSetupTask)) :*: S1 (MetaSel (Just "_wiInitialReportIndex") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int64)))) :*: (S1 (MetaSel (Just "_wiMapTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe MapTask)) :*: S1 (MetaSel (Just "_wiPackages") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [Package]))))) :*: (((S1 (MetaSel (Just "_wiStreamingComputationTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe StreamingComputationTask)) :*: S1 (MetaSel (Just "_wiSourceOperationTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceOperationRequest))) :*: (S1 (MetaSel (Just "_wiId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int64))) :*: S1 (MetaSel (Just "_wiProjectId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))) :*: ((S1 (MetaSel (Just "_wiLeaseExpireTime") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DateTime')) :*: S1 (MetaSel (Just "_wiConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) :*: (S1 (MetaSel (Just "_wiStreamingConfigTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe StreamingConfigTask)) :*: S1 (MetaSel (Just "_wiSeqMapTask") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SeqMapTask)))))))

wiJobId :: Lens' WorkItem (Maybe Text) Source #

Identifies the workflow job this WorkItem belongs to.

wiReportStatusInterval :: Lens' WorkItem (Maybe Scientific) Source #

Recommended reporting interval.

wiShellTask :: Lens' WorkItem (Maybe ShellTask) Source #

Additional information for ShellTask WorkItems.

wiStreamingSetupTask :: Lens' WorkItem (Maybe StreamingSetupTask) Source #

Additional information for StreamingSetupTask WorkItems.

wiInitialReportIndex :: Lens' WorkItem (Maybe Int64) Source #

The initial index to use when reporting the status of the WorkItem.

wiMapTask :: Lens' WorkItem (Maybe MapTask) Source #

Additional information for MapTask WorkItems.

wiPackages :: Lens' WorkItem [Package] Source #

Any required packages that need to be fetched in order to execute this WorkItem.

wiStreamingComputationTask :: Lens' WorkItem (Maybe StreamingComputationTask) Source #

Additional information for StreamingComputationTask WorkItems.

wiSourceOperationTask :: Lens' WorkItem (Maybe SourceOperationRequest) Source #

Additional information for source operation WorkItems.

wiId :: Lens' WorkItem (Maybe Int64) Source #

Identifies this WorkItem.

wiProjectId :: Lens' WorkItem (Maybe Text) Source #

Identifies the cloud project this WorkItem belongs to.

wiLeaseExpireTime :: Lens' WorkItem (Maybe UTCTime) Source #

Time when the lease on this Work will expire.

wiConfiguration :: Lens' WorkItem (Maybe Text) Source #

Work item-specific configuration as an opaque blob.

wiStreamingConfigTask :: Lens' WorkItem (Maybe StreamingConfigTask) Source #

Additional information for StreamingConfigTask WorkItems.

wiSeqMapTask :: Lens' WorkItem (Maybe SeqMapTask) Source #

Additional information for SeqMapTask WorkItems.

WorkerHealthReport

data WorkerHealthReport Source #

WorkerHealthReport contains information about the health of a worker. The VM should be identified by the labels attached to the WorkerMessage that this health ping belongs to.

See: workerHealthReport smart constructor.

Instances
Eq WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> WorkerHealthReport -> c WorkerHealthReport #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c WorkerHealthReport #

toConstr :: WorkerHealthReport -> Constr #

dataTypeOf :: WorkerHealthReport -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c WorkerHealthReport) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c WorkerHealthReport) #

gmapT :: (forall b. Data b => b -> b) -> WorkerHealthReport -> WorkerHealthReport #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> WorkerHealthReport -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> WorkerHealthReport -> r #

gmapQ :: (forall d. Data d => d -> u) -> WorkerHealthReport -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> WorkerHealthReport -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> WorkerHealthReport -> m WorkerHealthReport #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkerHealthReport -> m WorkerHealthReport #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkerHealthReport -> m WorkerHealthReport #

Show WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep WorkerHealthReport :: Type -> Type #

ToJSON WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkerHealthReport Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkerHealthReport = D1 (MetaData "WorkerHealthReport" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "WorkerHealthReport'" PrefixI True) ((S1 (MetaSel (Just "_whrVMIsHealthy") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Bool)) :*: S1 (MetaSel (Just "_whrReportInterval") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe GDuration))) :*: (S1 (MetaSel (Just "_whrPods") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [WorkerHealthReportPodsItem])) :*: S1 (MetaSel (Just "_whrVMStartupTime") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DateTime')))))

workerHealthReport :: WorkerHealthReport Source #

Creates a value of WorkerHealthReport with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

whrVMIsHealthy :: Lens' WorkerHealthReport (Maybe Bool) Source #

Whether the VM is healthy.

whrReportInterval :: Lens' WorkerHealthReport (Maybe Scientific) Source #

The interval at which the worker is sending health reports. The default value of 0 should be interpreted as the field is not being explicitly set by the worker.

whrPods :: Lens' WorkerHealthReport [WorkerHealthReportPodsItem] Source #

The pods running on the worker. See: http://kubernetes.io/v1.1/docs/api-reference/v1/definitions.html#_v1_pod This field is used by the worker to send the status of the indvidual containers running on each worker.

Snapshot

data Snapshot Source #

Represents a snapshot of a job.

See: snapshot smart constructor.

Instances
Eq Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Snapshot -> c Snapshot #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c Snapshot #

toConstr :: Snapshot -> Constr #

dataTypeOf :: Snapshot -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c Snapshot) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c Snapshot) #

gmapT :: (forall b. Data b => b -> b) -> Snapshot -> Snapshot #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Snapshot -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Snapshot -> r #

gmapQ :: (forall d. Data d => d -> u) -> Snapshot -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> Snapshot -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Snapshot -> m Snapshot #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Snapshot -> m Snapshot #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Snapshot -> m Snapshot #

Show Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep Snapshot :: Type -> Type #

Methods

from :: Snapshot -> Rep Snapshot x #

to :: Rep Snapshot x -> Snapshot #

ToJSON Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep Snapshot Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep Snapshot = D1 (MetaData "Snapshot" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "Snapshot'" PrefixI True) ((S1 (MetaSel (Just "_sCreationTime") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DateTime')) :*: S1 (MetaSel (Just "_sTtl") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe GDuration))) :*: (S1 (MetaSel (Just "_sSourceJobId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_sId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_sProjectId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

snapshot :: Snapshot Source #

Creates a value of Snapshot with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

sCreationTime :: Lens' Snapshot (Maybe UTCTime) Source #

The time this snapshot was created.

sTtl :: Lens' Snapshot (Maybe Scientific) Source #

The time after which this snapshot will be automatically deleted.

sSourceJobId :: Lens' Snapshot (Maybe Text) Source #

The job this snapshot was created from.

sId :: Lens' Snapshot (Maybe Text) Source #

The unique ID of this snapshot.

sProjectId :: Lens' Snapshot (Maybe Text) Source #

The project this snapshot belongs to.

SourceSplitOptions

data SourceSplitOptions Source #

Hints for splitting a Source into bundles (parts for parallel processing) using SourceSplitRequest.

See: sourceSplitOptions smart constructor.

Instances
Eq SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> SourceSplitOptions -> c SourceSplitOptions #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c SourceSplitOptions #

toConstr :: SourceSplitOptions -> Constr #

dataTypeOf :: SourceSplitOptions -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c SourceSplitOptions) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c SourceSplitOptions) #

gmapT :: (forall b. Data b => b -> b) -> SourceSplitOptions -> SourceSplitOptions #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> SourceSplitOptions -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> SourceSplitOptions -> r #

gmapQ :: (forall d. Data d => d -> u) -> SourceSplitOptions -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> SourceSplitOptions -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> SourceSplitOptions -> m SourceSplitOptions #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSplitOptions -> m SourceSplitOptions #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSplitOptions -> m SourceSplitOptions #

Show SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep SourceSplitOptions :: Type -> Type #

ToJSON SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep SourceSplitOptions Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep SourceSplitOptions = D1 (MetaData "SourceSplitOptions" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "SourceSplitOptions'" PrefixI True) (S1 (MetaSel (Just "_ssoDesiredShardSizeBytes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int64))) :*: S1 (MetaSel (Just "_ssoDesiredBundleSizeBytes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int64)))))

sourceSplitOptions :: SourceSplitOptions Source #

Creates a value of SourceSplitOptions with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ssoDesiredShardSizeBytes :: Lens' SourceSplitOptions (Maybe Int64) Source #

DEPRECATED in favor of desired_bundle_size_bytes.

ssoDesiredBundleSizeBytes :: Lens' SourceSplitOptions (Maybe Int64) Source #

The source should be split into a set of bundles where the estimated size of each is approximately this many bytes.

WorkerPoolMetadata

data WorkerPoolMetadata Source #

Metadata to set on the Google Compute Engine VMs.

See: workerPoolMetadata smart constructor.

Instances
Eq WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> WorkerPoolMetadata -> c WorkerPoolMetadata #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c WorkerPoolMetadata #

toConstr :: WorkerPoolMetadata -> Constr #

dataTypeOf :: WorkerPoolMetadata -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c WorkerPoolMetadata) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c WorkerPoolMetadata) #

gmapT :: (forall b. Data b => b -> b) -> WorkerPoolMetadata -> WorkerPoolMetadata #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> WorkerPoolMetadata -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> WorkerPoolMetadata -> r #

gmapQ :: (forall d. Data d => d -> u) -> WorkerPoolMetadata -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> WorkerPoolMetadata -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> WorkerPoolMetadata -> m WorkerPoolMetadata #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkerPoolMetadata -> m WorkerPoolMetadata #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> WorkerPoolMetadata -> m WorkerPoolMetadata #

Show WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep WorkerPoolMetadata :: Type -> Type #

ToJSON WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkerPoolMetadata Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep WorkerPoolMetadata = D1 (MetaData "WorkerPoolMetadata" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" True) (C1 (MetaCons "WorkerPoolMetadata'" PrefixI True) (S1 (MetaSel (Just "_wpmAddtional") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (HashMap Text Text))))

workerPoolMetadata Source #

Creates a value of WorkerPoolMetadata with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

AutoscalingSettings

data AutoscalingSettings Source #

Settings for WorkerPool autoscaling.

See: autoscalingSettings smart constructor.

Instances
Eq AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> AutoscalingSettings -> c AutoscalingSettings #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c AutoscalingSettings #

toConstr :: AutoscalingSettings -> Constr #

dataTypeOf :: AutoscalingSettings -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c AutoscalingSettings) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c AutoscalingSettings) #

gmapT :: (forall b. Data b => b -> b) -> AutoscalingSettings -> AutoscalingSettings #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> AutoscalingSettings -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> AutoscalingSettings -> r #

gmapQ :: (forall d. Data d => d -> u) -> AutoscalingSettings -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> AutoscalingSettings -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> AutoscalingSettings -> m AutoscalingSettings #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> AutoscalingSettings -> m AutoscalingSettings #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> AutoscalingSettings -> m AutoscalingSettings #

Show AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep AutoscalingSettings :: Type -> Type #

ToJSON AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep AutoscalingSettings Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep AutoscalingSettings = D1 (MetaData "AutoscalingSettings" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "AutoscalingSettings'" PrefixI True) (S1 (MetaSel (Just "_asMaxNumWorkers") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (Textual Int32))) :*: S1 (MetaSel (Just "_asAlgorithm") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe AutoscalingSettingsAlgorithm))))

autoscalingSettings :: AutoscalingSettings Source #

Creates a value of AutoscalingSettings with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

asMaxNumWorkers :: Lens' AutoscalingSettings (Maybe Int32) Source #

The maximum number of workers to cap scaling at.

JobExecutionStageInfo

data JobExecutionStageInfo Source #

Contains information about how a particular google.dataflow.v1beta3.Step will be executed.

See: jobExecutionStageInfo smart constructor.

Instances
Eq JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> JobExecutionStageInfo -> c JobExecutionStageInfo #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c JobExecutionStageInfo #

toConstr :: JobExecutionStageInfo -> Constr #

dataTypeOf :: JobExecutionStageInfo -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c JobExecutionStageInfo) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c JobExecutionStageInfo) #

gmapT :: (forall b. Data b => b -> b) -> JobExecutionStageInfo -> JobExecutionStageInfo #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> JobExecutionStageInfo -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> JobExecutionStageInfo -> r #

gmapQ :: (forall d. Data d => d -> u) -> JobExecutionStageInfo -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> JobExecutionStageInfo -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> JobExecutionStageInfo -> m JobExecutionStageInfo #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> JobExecutionStageInfo -> m JobExecutionStageInfo #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> JobExecutionStageInfo -> m JobExecutionStageInfo #

Show JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep JobExecutionStageInfo :: Type -> Type #

ToJSON JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep JobExecutionStageInfo Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep JobExecutionStageInfo = D1 (MetaData "JobExecutionStageInfo" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" True) (C1 (MetaCons "JobExecutionStageInfo'" PrefixI True) (S1 (MetaSel (Just "_jesiStepName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe [Text]))))

jobExecutionStageInfo :: JobExecutionStageInfo Source #

Creates a value of JobExecutionStageInfo with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

jesiStepName :: Lens' JobExecutionStageInfo [Text] Source #

The steps associated with the execution stage. Note that stages may have several steps, and that a given step might be run by more than one stage.

InstructionOutput

data InstructionOutput Source #

An output of an instruction.

See: instructionOutput smart constructor.

Instances
Eq InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InstructionOutput -> c InstructionOutput #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InstructionOutput #

toConstr :: InstructionOutput -> Constr #

dataTypeOf :: InstructionOutput -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c InstructionOutput) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InstructionOutput) #

gmapT :: (forall b. Data b => b -> b) -> InstructionOutput -> InstructionOutput #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InstructionOutput -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InstructionOutput -> r #

gmapQ :: (forall d. Data d => d -> u) -> InstructionOutput -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InstructionOutput -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InstructionOutput -> m InstructionOutput #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InstructionOutput -> m InstructionOutput #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InstructionOutput -> m InstructionOutput #

Show InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep InstructionOutput :: Type -> Type #

ToJSON InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep InstructionOutput Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep InstructionOutput = D1 (MetaData "InstructionOutput" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "InstructionOutput'" PrefixI True) ((S1 (MetaSel (Just "_ioOnlyCountValueBytes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Bool)) :*: (S1 (MetaSel (Just "_ioCodec") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InstructionOutputCodec)) :*: S1 (MetaSel (Just "_ioName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))) :*: (S1 (MetaSel (Just "_ioSystemName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_ioOriginalName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_ioOnlyCountKeyBytes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Bool))))))

instructionOutput :: InstructionOutput Source #

Creates a value of InstructionOutput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ioOnlyCountValueBytes :: Lens' InstructionOutput (Maybe Bool) Source #

For system-generated byte and mean byte metrics, certain instructions should only report the value size.

ioCodec :: Lens' InstructionOutput (Maybe InstructionOutputCodec) Source #

The codec to use to encode data being written via this output.

ioName :: Lens' InstructionOutput (Maybe Text) Source #

The user-provided name of this output.

ioSystemName :: Lens' InstructionOutput (Maybe Text) Source #

System-defined name of this output. Unique across the workflow.

ioOriginalName :: Lens' InstructionOutput (Maybe Text) Source #

System-defined name for this output in the original workflow graph. Outputs that do not contribute to an original instruction do not set this.

ioOnlyCountKeyBytes :: Lens' InstructionOutput (Maybe Bool) Source #

For system-generated byte and mean byte metrics, certain instructions should only report the key size.

IntegerGauge

data IntegerGauge Source #

A metric value representing temporal values of a variable.

See: integerGauge smart constructor.

Instances
Eq IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> IntegerGauge -> c IntegerGauge #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c IntegerGauge #

toConstr :: IntegerGauge -> Constr #

dataTypeOf :: IntegerGauge -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c IntegerGauge) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c IntegerGauge) #

gmapT :: (forall b. Data b => b -> b) -> IntegerGauge -> IntegerGauge #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> IntegerGauge -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> IntegerGauge -> r #

gmapQ :: (forall d. Data d => d -> u) -> IntegerGauge -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> IntegerGauge -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> IntegerGauge -> m IntegerGauge #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> IntegerGauge -> m IntegerGauge #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> IntegerGauge -> m IntegerGauge #

Show IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep IntegerGauge :: Type -> Type #

ToJSON IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep IntegerGauge Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep IntegerGauge = D1 (MetaData "IntegerGauge" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "IntegerGauge'" PrefixI True) (S1 (MetaSel (Just "_igValue") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SplitInt64)) :*: S1 (MetaSel (Just "_igTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DateTime'))))

integerGauge :: IntegerGauge Source #

Creates a value of IntegerGauge with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

igValue :: Lens' IntegerGauge (Maybe SplitInt64) Source #

The value of the variable represented by this gauge.

igTimestamp :: Lens' IntegerGauge (Maybe UTCTime) Source #

The time at which this value was measured. Measured as msecs from epoch.

LaunchTemplateParameters

data LaunchTemplateParameters Source #

Parameters to provide to the template being launched.

See: launchTemplateParameters smart constructor.

Instances
Eq LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> LaunchTemplateParameters -> c LaunchTemplateParameters #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c LaunchTemplateParameters #

toConstr :: LaunchTemplateParameters -> Constr #

dataTypeOf :: LaunchTemplateParameters -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c LaunchTemplateParameters) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c LaunchTemplateParameters) #

gmapT :: (forall b. Data b => b -> b) -> LaunchTemplateParameters -> LaunchTemplateParameters #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> LaunchTemplateParameters -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> LaunchTemplateParameters -> r #

gmapQ :: (forall d. Data d => d -> u) -> LaunchTemplateParameters -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> LaunchTemplateParameters -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> LaunchTemplateParameters -> m LaunchTemplateParameters #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> LaunchTemplateParameters -> m LaunchTemplateParameters #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> LaunchTemplateParameters -> m LaunchTemplateParameters #

Show LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep LaunchTemplateParameters :: Type -> Type #

ToJSON LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep LaunchTemplateParameters Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep LaunchTemplateParameters = D1 (MetaData "LaunchTemplateParameters" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "LaunchTemplateParameters'" PrefixI True) (S1 (MetaSel (Just "_ltpEnvironment") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe RuntimeEnvironment)) :*: (S1 (MetaSel (Just "_ltpJobName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_ltpParameters") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe LaunchTemplateParametersParameters)))))

launchTemplateParameters :: LaunchTemplateParameters Source #

Creates a value of LaunchTemplateParameters with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ltpJobName :: Lens' LaunchTemplateParameters (Maybe Text) Source #

Required. The job name to use for the created job.

ReportWorkItemStatusRequest

data ReportWorkItemStatusRequest Source #

Request to report the status of WorkItems.

See: reportWorkItemStatusRequest smart constructor.

Instances
Eq ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Data ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ReportWorkItemStatusRequest -> c ReportWorkItemStatusRequest #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ReportWorkItemStatusRequest #

toConstr :: ReportWorkItemStatusRequest -> Constr #

dataTypeOf :: ReportWorkItemStatusRequest -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c ReportWorkItemStatusRequest) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ReportWorkItemStatusRequest) #

gmapT :: (forall b. Data b => b -> b) -> ReportWorkItemStatusRequest -> ReportWorkItemStatusRequest #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ReportWorkItemStatusRequest -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ReportWorkItemStatusRequest -> r #

gmapQ :: (forall d. Data d => d -> u) -> ReportWorkItemStatusRequest -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ReportWorkItemStatusRequest -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ReportWorkItemStatusRequest -> m ReportWorkItemStatusRequest #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ReportWorkItemStatusRequest -> m ReportWorkItemStatusRequest #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ReportWorkItemStatusRequest -> m ReportWorkItemStatusRequest #

Show ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Generic ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

Associated Types

type Rep ReportWorkItemStatusRequest :: Type -> Type #

ToJSON ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

FromJSON ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ReportWorkItemStatusRequest Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Product

type Rep ReportWorkItemStatusRequest = D1 (MetaData "ReportWorkItemStatusRequest" "Network.Google.Dataflow.Types.Product" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "ReportWorkItemStatusRequest'" PrefixI True) ((S1 (MetaSel (Just "_rwisrCurrentWorkerTime") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DateTime')) :*: S1 (MetaSel (Just "_rwisrLocation") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) :*: (S1 (MetaSel (Just "_rwisrWorkItemStatuses") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [WorkItemStatus])) :*: S1 (MetaSel (Just "_rwisrWorkerId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

reportWorkItemStatusRequest :: ReportWorkItemStatusRequest Source #

Creates a value of ReportWorkItemStatusRequest with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

rwisrLocation :: Lens' ReportWorkItemStatusRequest (Maybe Text) Source #

The location which contains the WorkItem's job.

rwisrWorkItemStatuses :: Lens' ReportWorkItemStatusRequest [WorkItemStatus] Source #

The order is unimportant, except that the order of the WorkItemServiceState messages in the ReportWorkItemStatusResponse corresponds to the order of WorkItemStatus messages here.

rwisrWorkerId :: Lens' ReportWorkItemStatusRequest (Maybe Text) Source #

The ID of the worker reporting the WorkItem status. If this does not match the ID of the worker which the Dataflow service believes currently has the lease on the WorkItem, the report will be dropped (with an error response).

JobType

data JobType Source #

The type of Cloud Dataflow job.

Constructors

JobTypeUnknown

JOB_TYPE_UNKNOWN The type of the job is unspecified, or unknown.

JobTypeBatch

JOB_TYPE_BATCH A batch job with a well-defined end point: data is read, data is processed, data is written, and the job is done.

JobTypeStreaming

JOB_TYPE_STREAMING A continuously streaming job with no end: data is read, processed, and written continuously.

Instances
Enum JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Eq JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Methods

(==) :: JobType -> JobType -> Bool #

(/=) :: JobType -> JobType -> Bool #

Data JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> JobType -> c JobType #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c JobType #

toConstr :: JobType -> Constr #

dataTypeOf :: JobType -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c JobType) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c JobType) #

gmapT :: (forall b. Data b => b -> b) -> JobType -> JobType #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> JobType -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> JobType -> r #

gmapQ :: (forall d. Data d => d -> u) -> JobType -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> JobType -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> JobType -> m JobType #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> JobType -> m JobType #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> JobType -> m JobType #

Ord JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Read JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Show JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Generic JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Associated Types

type Rep JobType :: Type -> Type #

Methods

from :: JobType -> Rep JobType x #

to :: Rep JobType x -> JobType #

Hashable JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

Methods

hashWithSalt :: Int -> JobType -> Int #

hash :: JobType -> Int #

ToJSON JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

FromJSON JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

FromHttpApiData JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

ToHttpApiData JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

type Rep JobType Source # 
Instance details

Defined in Network.Google.Dataflow.Types.Sum

type Rep JobType = D1 (MetaData "JobType" "Network.Google.Dataflow.Types.Sum" "gogol-dataflow-0.4.0-3JQL14p7A16KlOtsdaG1RC" False) (C1 (MetaCons "JobTypeUnknown" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "JobTypeBatch" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "JobTypeStreaming" PrefixI False) (U1 :: Type -> Type)))

EnvironmentVersion

data EnvironmentVersion Source #

A structure describing which components and their versions of the service are required in order to run the job.

See: environmentVersion smart constructor.