final case class MessageStoragePolicy(allowedPersistenceRegions: Seq[String] = _root_.scala.Seq.empty, enforceInTransit: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[MessageStoragePolicy] with Product with Serializable
A policy constraining the storage of messages published to the topic.
- allowedPersistenceRegions
Optional. A list of IDs of Google Cloud regions where messages that are published to the topic may be persisted in storage. Messages published by publishers running in non-allowed Google Cloud regions (or running outside of Google Cloud altogether) are routed for storage in one of the allowed regions. An empty list means that no regions are allowed, and is not a valid configuration.
- enforceInTransit
Optional. If true,
allowed_persistence_regions
is also used to enforce in-transit guarantees for messages. That is, Pub/Sub will fail Publish operations on this topic and subscribe operations on any subscription attached to this topic in any region that is not inallowed_persistence_regions
.
- Annotations
- @SerialVersionUID()
- Source
- MessageStoragePolicy.scala
- Alphabetic
- By Inheritance
- MessageStoragePolicy
- Updatable
- GeneratedMessage
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MessageStoragePolicy(allowedPersistenceRegions: Seq[String] = _root_.scala.Seq.empty, enforceInTransit: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)
- allowedPersistenceRegions
Optional. A list of IDs of Google Cloud regions where messages that are published to the topic may be persisted in storage. Messages published by publishers running in non-allowed Google Cloud regions (or running outside of Google Cloud altogether) are routed for storage in one of the allowed regions. An empty list means that no regions are allowed, and is not a valid configuration.
- enforceInTransit
Optional. If true,
allowed_persistence_regions
is also used to enforce in-transit guarantees for messages. That is, Pub/Sub will fail Publish operations on this topic and subscribe operations on any subscription attached to this topic in any region that is not inallowed_persistence_regions
.
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
- def addAllAllowedPersistenceRegions(__vs: Iterable[String]): MessageStoragePolicy
- def addAllowedPersistenceRegions(__vs: String*): MessageStoragePolicy
- val allowedPersistenceRegions: Seq[String]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clearAllowedPersistenceRegions: MessageStoragePolicy
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def companion: MessageStoragePolicy.type
- Definition Classes
- MessageStoragePolicy → GeneratedMessage
- def discardUnknownFields: MessageStoragePolicy
- val enforceInTransit: Boolean
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getField(__field: FieldDescriptor): PValue
- Definition Classes
- MessageStoragePolicy → GeneratedMessage
- def getFieldByNumber(__fieldNumber: Int): Any
- Definition Classes
- MessageStoragePolicy → 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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def serializedSize: Int
- Definition Classes
- MessageStoragePolicy → GeneratedMessage
- 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
- MessageStoragePolicy → GeneratedMessage
- val unknownFields: UnknownFieldSet
- def update(ms: (Lens[MessageStoragePolicy, MessageStoragePolicy]) => Mutation[MessageStoragePolicy]*): MessageStoragePolicy
- 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 withAllowedPersistenceRegions(__v: Seq[String]): MessageStoragePolicy
- def withEnforceInTransit(__v: Boolean): MessageStoragePolicy
- def withUnknownFields(__v: UnknownFieldSet): MessageStoragePolicy
- final def writeDelimitedTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage
- def writeTo(_output__: CodedOutputStream): Unit
- Definition Classes
- MessageStoragePolicy → GeneratedMessage
- final def writeTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage