object CloudStorageConfig extends GeneratedMessageCompanion[CloudStorageConfig]
- Source
- CloudStorageConfig.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CloudStorageConfig
- GeneratedMessageCompanion
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- final case class AvroConfig(writeMetadata: 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
When true, write the subscription name, message_id, publish_time, attributes, and ordering_key as additional fields in the output.
- 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_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 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, outputFormat: OutputFormat, maxDuration: Option[Duration], maxBytes: Long, state: State): 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]