Current section

Files

Jump to
google_api_dataflow lib google_api dataflow v1b3 model pubsub_location.ex
Raw

lib/google_api/dataflow/v1b3/model/pubsub_location.ex

# 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