Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: expose bucket notifications apis
- Loading branch information
1 parent
9df0f93
commit ce09c25
Showing
13 changed files
with
838 additions
and
369 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
134 changes: 132 additions & 2 deletions
134
google-cloud-storage/src/main/java/com/google/cloud/storage/Notification.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,9 +1,139 @@ | ||
| /* | ||
| * Copyright 2020 Google LLC | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package com.google.cloud.storage; | ||
|
|
||
| import static com.google.common.base.Preconditions.checkNotNull; | ||
|
|
||
| import java.util.Map; | ||
| import java.util.Objects; | ||
|
|
||
| /** | ||
| * Google Storage Notification object; | ||
| * | ||
| * @see <a href="https://cloud.google.com/storage/docs/json_api/v1/notifications">notifications</a> | ||
| */ | ||
| public class Notification extends NotificationInfo { | ||
|
|
||
| Notification(Builder builder) { | ||
| super(builder); | ||
| private final StorageOptions options; | ||
| private transient Storage storage; | ||
|
|
||
| /** Builder for {@code Notification}. */ | ||
| public static class Builder extends NotificationInfo.Builder { | ||
| private final Storage storage; | ||
| private final NotificationInfo.BuilderImpl infoBuilder; | ||
|
|
||
| Builder(Notification notification) { | ||
| this.storage = notification.storage; | ||
| this.infoBuilder = new NotificationInfo.BuilderImpl(notification); | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setGeneratedId(String generatedId) { | ||
| infoBuilder.setGeneratedId(generatedId); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setSelfLink(String selfLink) { | ||
| infoBuilder.setSelfLink(selfLink); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setTopic(String topic) { | ||
| infoBuilder.setTopic(topic); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setPayloadFormat(PayloadFormat payloadFormat) { | ||
| infoBuilder.setPayloadFormat(payloadFormat); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setObjectNamePrefix(String objectNamePrefix) { | ||
| infoBuilder.setObjectNamePrefix(objectNamePrefix); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setEventTypes(Iterable<String> eventTypes) { | ||
| infoBuilder.setEventTypes(eventTypes); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setEtag(String etag) { | ||
| infoBuilder.setEtag(etag); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder setCustomAttributes(Map<String, String> customAttributes) { | ||
| infoBuilder.setCustomAttributes(customAttributes); | ||
| return this; | ||
| } | ||
|
|
||
| @Override | ||
| public Notification build() { | ||
| return new Notification(storage, infoBuilder); | ||
| } | ||
| } | ||
|
|
||
| Notification(Storage storage, NotificationInfo.BuilderImpl infoBuilder) { | ||
| super(infoBuilder); | ||
| this.storage = checkNotNull(storage); | ||
| this.options = storage.getOptions(); | ||
| } | ||
|
|
||
| /** Returns the notification's {@code Storage} object used to issue requests. */ | ||
| public Storage getStorage() { | ||
| return storage; | ||
| } | ||
|
|
||
| @Override | ||
| public Builder toBuilder() { | ||
| return new Notification.Builder(this); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean equals(Object o) { | ||
| if (this == o) { | ||
| return true; | ||
| } | ||
| if (o == null || getClass() != o.getClass()) { | ||
| return false; | ||
| } | ||
| if (!super.equals(o)) { | ||
| return false; | ||
| } | ||
| Notification that = (Notification) o; | ||
| return Objects.equals(toPb(), that.toPb()) && Objects.equals(options, that.options); | ||
| } | ||
|
|
||
| @Override | ||
| public int hashCode() { | ||
| return Objects.hash(super.hashCode(), options, storage); | ||
| } | ||
|
|
||
| static Notification fromPb( | ||
| Storage storage, com.google.api.services.storage.model.Notification notificationPb) { | ||
| return new Notification( | ||
| storage, new NotificationInfo.BuilderImpl(NotificationInfo.fromPb(notificationPb))); | ||
| } | ||
| } |
Oops, something went wrong.