Class Sink (3.10.4)

public class Sink extends SinkInfo

Cloud Logging sinks can be used to control the export of your logs. Each sink specifies the export of a set of log entries to a certain destination. A sink consists of a name, unique to the project, a filter for choosing the log entries to export and a destination for the log entries.

Sink destination can either be a Google Cloud Storage bucket (see SinkInfo.Destination.BucketDestination, a Google Cloud BigQuery dataset (see SinkInfo.Destination.DatasetDestination) or a Google CloudPub/Sub topic (see SinkInfo.Destination.TopicDestination).

Sink adds a layer of service-related functionality over SinkInfo. Objects of this class are immutable. To get a Sink object with the most recent information use #reload or #reloadAsync. See Also: About Sinks

Inheritance

Object > SinkInfo > Sink

Inherited Members

SinkInfo.<T>getDestination()

SinkInfo.equals(Object)

SinkInfo.getFilter()

SinkInfo.getName()

SinkInfo.getVersionFormat()

SinkInfo.hashCode()

SinkInfo.newBuilder(String,SinkInfo.Destination)

SinkInfo.of(String,SinkInfo.Destination)

SinkInfo.toBuilder()

SinkInfo.toString()

Object.clone()

Object.finalize()

Object.getClass()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

delete()

public boolean delete()

Deletes this sink.

Example of deleting the sink.


 boolean deleted = sink.delete();
 if (deleted) {
   // the sink was deleted
 } else {
   // the sink was not found
 }

Returns

Type	Description
boolean	`true` if the sink was deleted, `false` if it was not found

deleteAsync()

public ApiFuture<Boolean> deleteAsync()

Sends a request for deleting this sink. This method returns a ApiFuture object to consume the result. ApiFuture#get() returns true if the sink was deleted, false if it was not found.

Example of asynchronously deleting the sink.


 ApiFuture<Boolean> future = sink.deleteAsync();
 // ...
 boolean deleted = future.get();
 if (deleted) {
   // the sink was deleted
 } else {
   // the sink was not found
 }

Returns

Type	Description
ApiFuture<Boolean>

equals(Object obj)

public final boolean equals(Object obj)

Parameter

Name	Description
obj	`Object`

Returns

Type	Description
boolean

Overrides

SinkInfo.equals(Object obj)

getLogging()

public Logging getLogging()

Returns the sinks's Logging object used to issue requests.

Returns

Type	Description
Logging

hashCode()

public final int hashCode()

Returns

Type	Description
int

Overrides

SinkInfo.hashCode()

reload()

public Sink reload()

Fetches current sink's latest information. Returns null if the sink does not exist.

Example of getting the sink's latest information.


 Sink latestSink = sink.reload();
 if (latestSink == null) {
   // the sink was not found
 }

Returns

Type	Description
Sink	a `Sink` object with latest information or `null` if not found

reloadAsync()

public ApiFuture<Sink> reloadAsync()

Sends a request to fetch current sink's latest information. This method returns a ApiFuture object to consume the result. ApiFuture#get() returns a Sink object with latest information or null if not found.

Example of asynchronously getting the sink's latest information.


 ApiFuture<Sink> future = sink.reloadAsync();
 // ...
 Sink latestSink = future.get();
 if (latestSink == null) {
   // the sink was not found
 }

Returns

Type	Description
ApiFuture<Sink>

toBuilder()

public Sink.Builder toBuilder()

Returns a builder for this SinkInfo object.

Returns

Type	Description
Sink.Builder

Overrides

SinkInfo.toBuilder()

update()

public Sink update()

Updates current sink. If the sink does not exist, it is created.

Example of updating the sink's information.


 Sink updatedSink = sink.toBuilder()
     .setFilter("severity<=error") .build()="" .update();="">

Returns

Type	Description
Sink	a `Sink` object with updated information

updateAsync()

public ApiFuture<Sink> updateAsync()

Sends a request to update current sink. If the sink does not exist, it is created. This method returns a ApiFuture object to consume the result. ApiFuture#get() returns a Sink object with updated information.

Example of asynchronously updating the sink's information.


 ApiFuture<Sink> future = sink.toBuilder()
     .setFilter("severity<=error") .build()="" .updateasync();="" ...="" sink="" updatedsink="future.get();">

Returns

Type	Description
ApiFuture<Sink>