trait Publisher extends AnyRef
The service that an application uses to manipulate topics, and to send messages to a topic.
- Source
- Publisher.scala
- Alphabetic
- By Inheritance
- Publisher
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
createTopic(in: Topic): Future[Topic]
Creates the given topic with the given name.
Creates the given topic with the given name. See the <a href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name rules</a>.
-
abstract
def
deleteTopic(in: DeleteTopicRequest): Future[Empty]
Deletes the topic with the given name.
Deletes the topic with the given name. Returns
NOT_FOUND
if the topic does not exist. After a topic is deleted, a new topic may be created with the same name; this is an entirely new topic with none of the old configuration or subscriptions. Existing subscriptions to this topic are not deleted, but theirtopic
field is set to_deleted-topic_
. -
abstract
def
getTopic(in: GetTopicRequest): Future[Topic]
Gets the configuration of a topic.
-
abstract
def
listTopicSnapshots(in: ListTopicSnapshotsRequest): Future[ListTopicSnapshotsResponse]
Lists the names of the snapshots on this topic.
Lists the names of the snapshots on this topic. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
-
abstract
def
listTopicSubscriptions(in: ListTopicSubscriptionsRequest): Future[ListTopicSubscriptionsResponse]
Lists the names of the subscriptions on this topic.
-
abstract
def
listTopics(in: ListTopicsRequest): Future[ListTopicsResponse]
Lists matching topics.
-
abstract
def
publish(in: PublishRequest): Future[PublishResponse]
Adds one or more messages to the topic.
Adds one or more messages to the topic. Returns
NOT_FOUND
if the topic does not exist. -
abstract
def
updateTopic(in: UpdateTopicRequest): Future[Topic]
Updates an existing topic.
Updates an existing topic. Note that certain properties of a topic are not modifiable.
Concrete 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
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )