object CloudStorageConfig extends GeneratedMessageCompanion[CloudStorageConfig]
- Source
- CloudStorageConfig.scala
- Alphabetic
- By Inheritance
- CloudStorageConfig
- GeneratedMessageCompanion
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class AvroConfig(writeMetadata: Boolean = false, useTopicSchema: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[AvroConfig] with Product with Serializable
Configuration for writing message data in Avro format.
Configuration for writing message data in Avro format. Message payloads and metadata will be written to files as an Avro binary.
- writeMetadata
Optional. When true, write the subscription name, message_id, publish_time, attributes, and ordering_key as additional fields in the output. The subscription name, message_id, and publish_time fields are put in their own fields while all other message properties other than data (for example, an ordering_key, if present) are added as entries in the attributes map.
- useTopicSchema
Optional. When true, the output Cloud Storage file will be serialized using the topic schema, if it exists.
- Annotations
- @SerialVersionUID()
- implicit class CloudStorageConfigLens[UpperPB] extends ObjectLens[UpperPB, CloudStorageConfig]
- sealed trait OutputFormat extends GeneratedOneof
- sealed abstract class State extends GeneratedEnum
Possible states for a Cloud Storage subscription.
- final case class TextConfig(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[TextConfig] with Product with Serializable
Configuration for writing message data in text format.
Configuration for writing message data in text format. Message payloads will be written to files as raw text, separated by a newline.
- Annotations
- @SerialVersionUID()
- type ValueType = CloudStorageConfig
- Definition Classes
- GeneratedMessageCompanion
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 val AVRO_CONFIG_FIELD_NUMBER: Int(5)
- final val BUCKET_FIELD_NUMBER: Int(1)
- final val FILENAME_DATETIME_FORMAT_FIELD_NUMBER: Int(10)
- final val FILENAME_PREFIX_FIELD_NUMBER: Int(2)
- final val FILENAME_SUFFIX_FIELD_NUMBER: Int(3)
- final val MAX_BYTES_FIELD_NUMBER: Int(7)
- final val MAX_DURATION_FIELD_NUMBER: Int(6)
- final val MAX_MESSAGES_FIELD_NUMBER: Int(8)
- final val SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER: Int(11)
- final val STATE_FIELD_NUMBER: Int(9)
- final val TEXT_CONFIG_FIELD_NUMBER: Int(4)
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- lazy val defaultInstance: CloudStorageConfig
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- def enumCompanionForField(field: FieldDescriptor): GeneratedEnumCompanion[_]
- Definition Classes
- GeneratedMessageCompanion
- def enumCompanionForFieldNumber(__fieldNumber: Int): GeneratedEnumCompanion[_]
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def fromAscii(s: String): CloudStorageConfig
- Definition Classes
- GeneratedMessageCompanion
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def javaDescriptor: Descriptor
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- def merge(a: CloudStorageConfig, input: CodedInputStream): CloudStorageConfig
- Definition Classes
- GeneratedMessageCompanion
- implicit def messageCompanion: GeneratedMessageCompanion[CloudStorageConfig]
- def messageCompanionForField(field: FieldDescriptor): GeneratedMessageCompanion[_]
- Definition Classes
- GeneratedMessageCompanion
- def messageCompanionForFieldNumber(__number: Int): GeneratedMessageCompanion[_]
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- implicit def messageReads: Reads[CloudStorageConfig]
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- lazy val nestedMessagesCompanions: Seq[GeneratedMessageCompanion[_ <: GeneratedMessage]]
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def of(bucket: String, filenamePrefix: String, filenameSuffix: String, filenameDatetimeFormat: String, outputFormat: OutputFormat, maxDuration: Option[Duration], maxBytes: Long, maxMessages: Long, state: State, serviceAccountEmail: String): CloudStorageConfig
- def parseDelimitedFrom(input: InputStream): Option[CloudStorageConfig]
- Definition Classes
- GeneratedMessageCompanion
- def parseDelimitedFrom(input: CodedInputStream): Option[CloudStorageConfig]
- Definition Classes
- GeneratedMessageCompanion
- def parseFrom(_input__: CodedInputStream): CloudStorageConfig
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- def parseFrom(s: Array[Byte]): CloudStorageConfig
- Definition Classes
- GeneratedMessageCompanion
- def parseFrom(input: InputStream): CloudStorageConfig
- Definition Classes
- GeneratedMessageCompanion
- def scalaDescriptor: Descriptor
- Definition Classes
- CloudStorageConfig → GeneratedMessageCompanion
- def streamFromDelimitedInput(input: InputStream): Stream[CloudStorageConfig]
- Definition Classes
- GeneratedMessageCompanion
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toByteArray(a: CloudStorageConfig): Array[Byte]
- Definition Classes
- GeneratedMessageCompanion
- def toString(): String
- Definition Classes
- AnyRef → Any
- def validate(s: Array[Byte]): Try[CloudStorageConfig]
- Definition Classes
- GeneratedMessageCompanion
- def validateAscii(s: String): Either[TextFormatError, CloudStorageConfig]
- Definition Classes
- GeneratedMessageCompanion
- 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()
- object AvroConfig extends GeneratedMessageCompanion[AvroConfig]
- object OutputFormat extends Serializable
- object State extends GeneratedEnumCompanion[State]
- object TextConfig extends GeneratedMessageCompanion[TextConfig]