# 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): 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): A pubsub subscription, in the form of \"pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>\" Defaults to: `null`. - timestampLabel (String): 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): A pubsub topic, in the form of \"pubsub.googleapis.com/topics/<project-id>/<topic-name>\" Defaults to: `null`. - trackingSubscription (String): 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`. """ defstruct [ :"dropLateData", :"idLabel", :"subscription", :"timestampLabel", :"topic", :"trackingSubscription", :"withAttributes" ] end defimpl Poison.Decoder, for: GoogleApi.Dataflow.V1b3.Model.PubsubLocation do def decode(value, _options) do value end end defimpl Poison.Encoder, for: GoogleApi.Dataflow.V1b3.Model.PubsubLocation do def encode(value, options) do GoogleApi.Dataflow.V1b3.Deserializer.serialize_non_nil(value, options) end end