# Copyright 2017 Google Inc. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # NOTE: This class is auto generated by the swagger code generator program. # https://github.com/swagger-api/swagger-codegen.git # Do not edit the class manually. defmodule GoogleApi.Dataflow.V1b3.Model.PubsubLocation do @moduledoc """ Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job. ## Attributes - dropLateData (boolean()): Indicates whether the pipeline allows late-arriving data. Defaults to: `null`. - idLabel (String.t): If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort. Defaults to: `null`. - subscription (String.t): A pubsub subscription, in the form of \"pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>\" Defaults to: `null`. - timestampLabel (String.t): If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival. Defaults to: `null`. - topic (String.t): A pubsub topic, in the form of \"pubsub.googleapis.com/topics/<project-id>/<topic-name>\" Defaults to: `null`. - trackingSubscription (String.t): If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation. Defaults to: `null`. - withAttributes (boolean()): If true, then the client has requested to get pubsub attributes. Defaults to: `null`. """ use GoogleApi.Gax.ModelBase @type t :: %__MODULE__{ :dropLateData => any(), :idLabel => any(), :subscription => any(), :timestampLabel => any(), :topic => any(), :trackingSubscription => any(), :withAttributes => any() } field(:dropLateData) field(:idLabel) field(:subscription) field(:timestampLabel) field(:topic) field(:trackingSubscription) field(:withAttributes) end defimpl Poison.Decoder, for: GoogleApi.Dataflow.V1b3.Model.PubsubLocation do def decode(value, options) do GoogleApi.Dataflow.V1b3.Model.PubsubLocation.decode(value, options) end end defimpl Poison.Encoder, for: GoogleApi.Dataflow.V1b3.Model.PubsubLocation do def encode(value, options) do GoogleApi.Gax.ModelBase.encode(value, options) end end