final case class BigtableConfig(table: String = "", appProfileId: String = "", serviceAccountEmail: String = "", writeMetadata: Boolean = false, state: State = com.google.pubsub.v1.pubsub.BigtableConfig.State.STATE_UNSPECIFIED, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[BigtableConfig] with Product with Serializable
Configuration for a Bigtable subscription. The Pub/Sub message will be written to a Bigtable row as follows: - row key: subscription name and message ID delimited by #. - columns: message bytes written to a single column family "data" with an empty-string column qualifier. - cell timestamp: the message publish timestamp.
- table
Optional. The unique name of the table to write messages to. Values are of the form
projects/<project>/instances/<instance>/tables/<table>.- appProfileId
Optional. The app profile to use for the Bigtable writes. If not specified, the "default" application profile will be used. The app profile must use single-cluster routing.
- serviceAccountEmail
Optional. The service account to use to write to Bigtable. The subscription creator or updater that specifies this field must have
iam.serviceAccounts.actAspermission 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.- writeMetadata
Optional. When true, write the subscription name, message_id, publish_time, attributes, and ordering_key to additional columns in the table under the pubsub_metadata column family. The subscription name, message_id, and publish_time fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column.
- state
Output only. An output-only field that indicates whether or not the subscription can receive messages.
- Annotations
- @SerialVersionUID()
- Source
- BigtableConfig.scala
- Alphabetic
- By Inheritance
- BigtableConfig
- Updatable
- GeneratedMessage
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new BigtableConfig(table: String = "", appProfileId: String = "", serviceAccountEmail: String = "", writeMetadata: Boolean = false, state: State = com.google.pubsub.v1.pubsub.BigtableConfig.State.STATE_UNSPECIFIED, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)
- table
Optional. The unique name of the table to write messages to. Values are of the form
projects/<project>/instances/<instance>/tables/<table>.- appProfileId
Optional. The app profile to use for the Bigtable writes. If not specified, the "default" application profile will be used. The app profile must use single-cluster routing.
- serviceAccountEmail
Optional. The service account to use to write to Bigtable. The subscription creator or updater that specifies this field must have
iam.serviceAccounts.actAspermission 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.- writeMetadata
Optional. When true, write the subscription name, message_id, publish_time, attributes, and ordering_key to additional columns in the table under the pubsub_metadata column family. The subscription name, message_id, and publish_time fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column.
- state
Output only. An output-only field that indicates whether or not the subscription can receive messages.
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
- val appProfileId: String
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def companion: BigtableConfig.type
- Definition Classes
- BigtableConfig → GeneratedMessage
- def discardUnknownFields: BigtableConfig
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getField(__field: FieldDescriptor): PValue
- Definition Classes
- BigtableConfig → GeneratedMessage
- def getFieldByNumber(__fieldNumber: Int): Any
- Definition Classes
- BigtableConfig → GeneratedMessage
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def serializedSize: Int
- Definition Classes
- BigtableConfig → GeneratedMessage
- val serviceAccountEmail: String
- val state: State
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val table: String
- 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
- BigtableConfig → GeneratedMessage
- val unknownFields: UnknownFieldSet
- def update(ms: (Lens[BigtableConfig, BigtableConfig]) => Mutation[BigtableConfig]*): BigtableConfig
- Definition Classes
- Updatable
- 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()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withAppProfileId(__v: String): BigtableConfig
- def withServiceAccountEmail(__v: String): BigtableConfig
- def withState(__v: State): BigtableConfig
- def withTable(__v: String): BigtableConfig
- def withUnknownFields(__v: UnknownFieldSet): BigtableConfig
- def withWriteMetadata(__v: Boolean): BigtableConfig
- final def writeDelimitedTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage
- val writeMetadata: Boolean
- def writeTo(_output__: CodedOutputStream): Unit
- Definition Classes
- BigtableConfig → GeneratedMessage
- final def writeTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage