Packages

final case class CloudStorage(state: State = com.google.pubsub.v1.pubsub.IngestionDataSourceSettings.CloudStorage.State.STATE_UNSPECIFIED, bucket: String = "", inputFormat: InputFormat = com.google.pubsub.v1.pubsub.IngestionDataSourceSettings.CloudStorage.InputFormat.Empty, minimumObjectCreateTime: Option[Timestamp] = _root_.scala.None, matchGlob: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[CloudStorage] with Product with Serializable

Ingestion settings for Cloud Storage.

state

Output only. An output-only field that indicates the state of the Cloud Storage ingestion source.

bucket

Optional. Cloud Storage bucket. The bucket name must be without any prefix like "gs://". See the [bucket naming requirements] (https://cloud.google.com/storage/docs/buckets#naming).

minimumObjectCreateTime

Optional. Only objects with a larger or equal creation timestamp will be ingested.

matchGlob

Optional. Glob pattern used to match objects that will be ingested. If unset, all objects will be ingested. See the [supported patterns](https://cloud.google.com/storage/docs/json_api/v1/objects/list#list-objects-and-prefixes-using-glob).

Annotations
@SerialVersionUID()
Source
IngestionDataSourceSettings.scala
Linear Supertypes
Updatable[CloudStorage], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CloudStorage
  2. Updatable
  3. GeneratedMessage
  4. Serializable
  5. Product
  6. Equals
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CloudStorage(state: State = com.google.pubsub.v1.pubsub.IngestionDataSourceSettings.CloudStorage.State.STATE_UNSPECIFIED, bucket: String = "", inputFormat: InputFormat = com.google.pubsub.v1.pubsub.IngestionDataSourceSettings.CloudStorage.InputFormat.Empty, minimumObjectCreateTime: Option[Timestamp] = _root_.scala.None, matchGlob: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)

    state

    Output only. An output-only field that indicates the state of the Cloud Storage ingestion source.

    bucket

    Optional. Cloud Storage bucket. The bucket name must be without any prefix like "gs://". See the [bucket naming requirements] (https://cloud.google.com/storage/docs/buckets#naming).

    minimumObjectCreateTime

    Optional. Only objects with a larger or equal creation timestamp will be ingested.

    matchGlob

    Optional. Glob pattern used to match objects that will be ingested. If unset, all objects will be ingested. See the [supported patterns](https://cloud.google.com/storage/docs/json_api/v1/objects/list#list-objects-and-prefixes-using-glob).

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val bucket: String
  6. def clearInputFormat: CloudStorage
  7. def clearMinimumObjectCreateTime: CloudStorage
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. def companion: CloudStorage.type
    Definition Classes
    CloudStorage → GeneratedMessage
  10. def discardUnknownFields: CloudStorage
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  13. def getAvroFormat: AvroFormat
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    CloudStorage → GeneratedMessage
  16. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    CloudStorage → GeneratedMessage
  17. def getMinimumObjectCreateTime: Timestamp
  18. def getPubsubAvroFormat: PubSubAvroFormat
  19. def getTextFormat: TextFormat
  20. val inputFormat: InputFormat
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. val matchGlob: String
  23. val minimumObjectCreateTime: Option[Timestamp]
  24. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  25. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  26. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  27. def productElementNames: Iterator[String]
    Definition Classes
    Product
  28. def serializedSize: Int
    Definition Classes
    CloudStorage → GeneratedMessage
  29. val state: State
  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  32. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  33. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  34. def toProtoString: String
    Definition Classes
    CloudStorage → GeneratedMessage
  35. val unknownFields: UnknownFieldSet
  36. def update(ms: (Lens[CloudStorage, CloudStorage]) => Mutation[CloudStorage]*): CloudStorage
    Definition Classes
    Updatable
  37. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  39. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  40. def withAvroFormat(__v: AvroFormat): CloudStorage
  41. def withBucket(__v: String): CloudStorage
  42. def withInputFormat(__v: InputFormat): CloudStorage
  43. def withMatchGlob(__v: String): CloudStorage
  44. def withMinimumObjectCreateTime(__v: Timestamp): CloudStorage
  45. def withPubsubAvroFormat(__v: PubSubAvroFormat): CloudStorage
  46. def withState(__v: State): CloudStorage
  47. def withTextFormat(__v: TextFormat): CloudStorage
  48. def withUnknownFields(__v: UnknownFieldSet): CloudStorage
  49. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  50. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    CloudStorage → GeneratedMessage
  51. final def writeTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage

Inherited from Updatable[CloudStorage]

Inherited from GeneratedMessage

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped