final case class CloudStorageConfig(bucket: String = "", filenamePrefix: String = "", filenameSuffix: String = "", filenameDatetimeFormat: String = "", outputFormat: OutputFormat = com.google.pubsub.v1.pubsub.CloudStorageConfig.OutputFormat.Empty, maxDuration: Option[Duration] = _root_.scala.None, maxBytes: Long = 0L, maxMessages: Long = 0L, state: State = com.google.pubsub.v1.pubsub.CloudStorageConfig.State.STATE_UNSPECIFIED, serviceAccountEmail: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[CloudStorageConfig] with Product with Serializable
Configuration for a Cloud Storage subscription.
- bucket
Required. User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like "gs://". See the [bucket naming requirements] (https://cloud.google.com/storage/docs/buckets#naming).
- filenamePrefix
Optional. User-provided prefix for Cloud Storage filename. See the [object naming requirements](https://cloud.google.com/storage/docs/objects#naming).
- filenameSuffix
Optional. User-provided suffix for Cloud Storage filename. See the [object naming requirements](https://cloud.google.com/storage/docs/objects#naming). Must not end in "/".
- filenameDatetimeFormat
Optional. User-provided format string specifying how to represent datetimes in Cloud Storage filenames. See the [datetime format guidance](https://cloud.google.com/pubsub/docs/create-cloudstorage-subscription#file_names).
- maxDuration
Optional. The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. May not exceed the subscription's acknowledgement deadline.
- maxBytes
Optional. The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. The max_bytes limit may be exceeded in cases where messages are larger than the limit.
- maxMessages
Optional. The maximum number of messages that can be written to a Cloud Storage file before a new file is created. Min 1000 messages.
- state
Output only. An output-only field that indicates whether or not the subscription can receive messages.
- serviceAccountEmail
Optional. The service account to use to write to Cloud Storage. The subscription creator or updater that specifies this field must have
iam.serviceAccounts.actAs
permission on the service account. If not specified, the Pub/Sub [service agent](https://cloud.google.com/iam/docs/service-agents), service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
- Annotations
- @SerialVersionUID()
- Source
- CloudStorageConfig.scala
- Alphabetic
- By Inheritance
- CloudStorageConfig
- Updatable
- GeneratedMessage
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CloudStorageConfig(bucket: String = "", filenamePrefix: String = "", filenameSuffix: String = "", filenameDatetimeFormat: String = "", outputFormat: OutputFormat = com.google.pubsub.v1.pubsub.CloudStorageConfig.OutputFormat.Empty, maxDuration: Option[Duration] = _root_.scala.None, maxBytes: Long = 0L, maxMessages: Long = 0L, state: State = com.google.pubsub.v1.pubsub.CloudStorageConfig.State.STATE_UNSPECIFIED, serviceAccountEmail: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)
- bucket
Required. User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like "gs://". See the [bucket naming requirements] (https://cloud.google.com/storage/docs/buckets#naming).
- filenamePrefix
Optional. User-provided prefix for Cloud Storage filename. See the [object naming requirements](https://cloud.google.com/storage/docs/objects#naming).
- filenameSuffix
Optional. User-provided suffix for Cloud Storage filename. See the [object naming requirements](https://cloud.google.com/storage/docs/objects#naming). Must not end in "/".
- filenameDatetimeFormat
Optional. User-provided format string specifying how to represent datetimes in Cloud Storage filenames. See the [datetime format guidance](https://cloud.google.com/pubsub/docs/create-cloudstorage-subscription#file_names).
- maxDuration
Optional. The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. May not exceed the subscription's acknowledgement deadline.
- maxBytes
Optional. The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. The max_bytes limit may be exceeded in cases where messages are larger than the limit.
- maxMessages
Optional. The maximum number of messages that can be written to a Cloud Storage file before a new file is created. Min 1000 messages.
- state
Output only. An output-only field that indicates whether or not the subscription can receive messages.
- serviceAccountEmail
Optional. The service account to use to write to Cloud Storage. The subscription creator or updater that specifies this field must have
iam.serviceAccounts.actAs
permission on the service account. If not specified, the Pub/Sub [service agent](https://cloud.google.com/iam/docs/service-agents), service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bucket: String
- def clearMaxDuration: CloudStorageConfig
- def clearOutputFormat: CloudStorageConfig
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def companion: CloudStorageConfig.type
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- def discardUnknownFields: CloudStorageConfig
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val filenameDatetimeFormat: String
- val filenamePrefix: String
- val filenameSuffix: String
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def getAvroConfig: AvroConfig
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getField(__field: FieldDescriptor): PValue
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- def getFieldByNumber(__fieldNumber: Int): Any
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- def getMaxDuration: Duration
- def getTextConfig: TextConfig
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxBytes: Long
- val maxDuration: Option[Duration]
- val maxMessages: Long
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val outputFormat: OutputFormat
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def serializedSize: Int
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- val serviceAccountEmail: String
- val state: State
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def toByteArray: Array[Byte]
- Definition Classes
- GeneratedMessage
- final def toByteString: ByteString
- Definition Classes
- GeneratedMessage
- final def toPMessage: PMessage
- Definition Classes
- GeneratedMessage
- def toProtoString: String
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- val unknownFields: UnknownFieldSet
- def update(ms: (Lens[CloudStorageConfig, CloudStorageConfig]) => Mutation[CloudStorageConfig]*): CloudStorageConfig
- Definition Classes
- Updatable
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withAvroConfig(__v: AvroConfig): CloudStorageConfig
- def withBucket(__v: String): CloudStorageConfig
- def withFilenameDatetimeFormat(__v: String): CloudStorageConfig
- def withFilenamePrefix(__v: String): CloudStorageConfig
- def withFilenameSuffix(__v: String): CloudStorageConfig
- def withMaxBytes(__v: Long): CloudStorageConfig
- def withMaxDuration(__v: Duration): CloudStorageConfig
- def withMaxMessages(__v: Long): CloudStorageConfig
- def withOutputFormat(__v: OutputFormat): CloudStorageConfig
- def withServiceAccountEmail(__v: String): CloudStorageConfig
- def withState(__v: State): CloudStorageConfig
- def withTextConfig(__v: TextConfig): CloudStorageConfig
- def withUnknownFields(__v: UnknownFieldSet): CloudStorageConfig
- final def writeDelimitedTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage
- def writeTo(_output__: CodedOutputStream): Unit
- Definition Classes
- CloudStorageConfig → GeneratedMessage
- final def writeTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage