getEventsList() {
+ if (eventsBuilder_ == null) {
+ return java.util.Collections.unmodifiableList(events_);
+ } else {
+ return eventsBuilder_.getMessageList();
+ }
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public int getEventsCount() {
+ if (eventsBuilder_ == null) {
+ return events_.size();
+ } else {
+ return eventsBuilder_.getCount();
+ }
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public io.odpf.proton.raccoon.Event getEvents(int index) {
+ if (eventsBuilder_ == null) {
+ return events_.get(index);
+ } else {
+ return eventsBuilder_.getMessage(index);
+ }
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder setEvents(
+ int index, io.odpf.proton.raccoon.Event value) {
+ if (eventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureEventsIsMutable();
+ events_.set(index, value);
+ onChanged();
+ } else {
+ eventsBuilder_.setMessage(index, value);
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder setEvents(
+ int index, io.odpf.proton.raccoon.Event.Builder builderForValue) {
+ if (eventsBuilder_ == null) {
+ ensureEventsIsMutable();
+ events_.set(index, builderForValue.build());
+ onChanged();
+ } else {
+ eventsBuilder_.setMessage(index, builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder addEvents(io.odpf.proton.raccoon.Event value) {
+ if (eventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureEventsIsMutable();
+ events_.add(value);
+ onChanged();
+ } else {
+ eventsBuilder_.addMessage(value);
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder addEvents(
+ int index, io.odpf.proton.raccoon.Event value) {
+ if (eventsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureEventsIsMutable();
+ events_.add(index, value);
+ onChanged();
+ } else {
+ eventsBuilder_.addMessage(index, value);
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder addEvents(
+ io.odpf.proton.raccoon.Event.Builder builderForValue) {
+ if (eventsBuilder_ == null) {
+ ensureEventsIsMutable();
+ events_.add(builderForValue.build());
+ onChanged();
+ } else {
+ eventsBuilder_.addMessage(builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder addEvents(
+ int index, io.odpf.proton.raccoon.Event.Builder builderForValue) {
+ if (eventsBuilder_ == null) {
+ ensureEventsIsMutable();
+ events_.add(index, builderForValue.build());
+ onChanged();
+ } else {
+ eventsBuilder_.addMessage(index, builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder addAllEvents(
+ java.lang.Iterable values) {
+ if (eventsBuilder_ == null) {
+ ensureEventsIsMutable();
+ com.google.protobuf.AbstractMessageLite.Builder.addAll(
+ values, events_);
+ onChanged();
+ } else {
+ eventsBuilder_.addAllMessages(values);
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder clearEvents() {
+ if (eventsBuilder_ == null) {
+ events_ = java.util.Collections.emptyList();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ } else {
+ eventsBuilder_.clear();
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public Builder removeEvents(int index) {
+ if (eventsBuilder_ == null) {
+ ensureEventsIsMutable();
+ events_.remove(index);
+ onChanged();
+ } else {
+ eventsBuilder_.remove(index);
+ }
+ return this;
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public io.odpf.proton.raccoon.Event.Builder getEventsBuilder(
+ int index) {
+ return getEventsFieldBuilder().getBuilder(index);
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public io.odpf.proton.raccoon.EventOrBuilder getEventsOrBuilder(
+ int index) {
+ if (eventsBuilder_ == null) {
+ return events_.get(index); } else {
+ return eventsBuilder_.getMessageOrBuilder(index);
+ }
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public java.util.List
+ getEventsOrBuilderList() {
+ if (eventsBuilder_ != null) {
+ return eventsBuilder_.getMessageOrBuilderList();
+ } else {
+ return java.util.Collections.unmodifiableList(events_);
+ }
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public io.odpf.proton.raccoon.Event.Builder addEventsBuilder() {
+ return getEventsFieldBuilder().addBuilder(
+ io.odpf.proton.raccoon.Event.getDefaultInstance());
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public io.odpf.proton.raccoon.Event.Builder addEventsBuilder(
+ int index) {
+ return getEventsFieldBuilder().addBuilder(
+ index, io.odpf.proton.raccoon.Event.getDefaultInstance());
+ }
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ public java.util.List
+ getEventsBuilderList() {
+ return getEventsFieldBuilder().getBuilderList();
+ }
+ private com.google.protobuf.RepeatedFieldBuilderV3<
+ io.odpf.proton.raccoon.Event, io.odpf.proton.raccoon.Event.Builder, io.odpf.proton.raccoon.EventOrBuilder>
+ getEventsFieldBuilder() {
+ if (eventsBuilder_ == null) {
+ eventsBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
+ io.odpf.proton.raccoon.Event, io.odpf.proton.raccoon.Event.Builder, io.odpf.proton.raccoon.EventOrBuilder>(
+ events_,
+ ((bitField0_ & 0x00000001) != 0),
+ getParentForChildren(),
+ isClean());
+ events_ = null;
+ }
+ return eventsBuilder_;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:odpf.raccoon.v1beta1.SendEventRequest)
+ }
+
+ // @@protoc_insertion_point(class_scope:odpf.raccoon.v1beta1.SendEventRequest)
+ private static final io.odpf.proton.raccoon.SendEventRequest DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new io.odpf.proton.raccoon.SendEventRequest();
+ }
+
+ public static io.odpf.proton.raccoon.SendEventRequest getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @java.lang.Override
+ public SendEventRequest parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new SendEventRequest(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public io.odpf.proton.raccoon.SendEventRequest getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+}
+
diff --git a/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventRequestOrBuilder.java b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventRequestOrBuilder.java
new file mode 100644
index 00000000..626b6a67
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventRequestOrBuilder.java
@@ -0,0 +1,132 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: .temp/odpf/raccoon/v1beta1/raccoon.proto
+
+package io.odpf.proton.raccoon;
+
+public interface SendEventRequestOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:odpf.raccoon.v1beta1.SendEventRequest)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ *
+ * `req_guid` is unique identifier of the request the client is making.
+ * Raccoon uses the identifier to send response of the request. The client can handle the
+ * response accordingly. For example, the client can retry the request in case the response is
+ * giving `INTERNAL_ERROR` code with "publisher failed" reason.
+ * This identifier is necessary because on event-based protocols like WebSocket the response is
+ * returned asynchronously. If there is no identifier, no way the client can tell which response
+ * belongs to which request.
+ * Apart from sending response, `req_guid` is used to log some informations on 'debug' level. You can search the
+ * debug logs with `ReqGUID` keyword.
+ *
+ *
+ * string req_guid = 1 [json_name = "reqGuid"];
+ * @return The reqGuid.
+ */
+ java.lang.String getReqGuid();
+ /**
+ *
+ * `req_guid` is unique identifier of the request the client is making.
+ * Raccoon uses the identifier to send response of the request. The client can handle the
+ * response accordingly. For example, the client can retry the request in case the response is
+ * giving `INTERNAL_ERROR` code with "publisher failed" reason.
+ * This identifier is necessary because on event-based protocols like WebSocket the response is
+ * returned asynchronously. If there is no identifier, no way the client can tell which response
+ * belongs to which request.
+ * Apart from sending response, `req_guid` is used to log some informations on 'debug' level. You can search the
+ * debug logs with `ReqGUID` keyword.
+ *
+ *
+ * string req_guid = 1 [json_name = "reqGuid"];
+ * @return The bytes for reqGuid.
+ */
+ com.google.protobuf.ByteString
+ getReqGuidBytes();
+
+ /**
+ *
+ * `sent_time` defines the time the request is sent.
+ * `sent_time` is used to calculate various metrics. The main metric uses `sent_time` is duration from the
+ * request is sent until the events are published.
+ *
+ *
+ * .google.protobuf.Timestamp sent_time = 2 [json_name = "sentTime"];
+ * @return Whether the sentTime field is set.
+ */
+ boolean hasSentTime();
+ /**
+ *
+ * `sent_time` defines the time the request is sent.
+ * `sent_time` is used to calculate various metrics. The main metric uses `sent_time` is duration from the
+ * request is sent until the events are published.
+ *
+ *
+ * .google.protobuf.Timestamp sent_time = 2 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ com.google.protobuf.Timestamp getSentTime();
+ /**
+ *
+ * `sent_time` defines the time the request is sent.
+ * `sent_time` is used to calculate various metrics. The main metric uses `sent_time` is duration from the
+ * request is sent until the events are published.
+ *
+ *
+ * .google.protobuf.Timestamp sent_time = 2 [json_name = "sentTime"];
+ */
+ com.google.protobuf.TimestampOrBuilder getSentTimeOrBuilder();
+
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ java.util.List
+ getEventsList();
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ io.odpf.proton.raccoon.Event getEvents(int index);
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ int getEventsCount();
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ java.util.List
+ getEventsOrBuilderList();
+ /**
+ *
+ * `events` is where the client put all the events wrapped in `Event`.
+ * As mentioned above, the request allows the client to push more than one event. Normally you want to batch
+ * the events to optimize the network call.
+ *
+ *
+ * repeated .odpf.raccoon.v1beta1.Event events = 3 [json_name = "events"];
+ */
+ io.odpf.proton.raccoon.EventOrBuilder getEventsOrBuilder(
+ int index);
+}
diff --git a/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponse.java b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponse.java
new file mode 100644
index 00000000..f98ce4c1
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponse.java
@@ -0,0 +1,1304 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: .temp/odpf/raccoon/v1beta1/raccoon.proto
+
+package io.odpf.proton.raccoon;
+
+/**
+ * Protobuf type {@code odpf.raccoon.v1beta1.SendEventResponse}
+ */
+public final class SendEventResponse extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:odpf.raccoon.v1beta1.SendEventResponse)
+ SendEventResponseOrBuilder {
+private static final long serialVersionUID = 0L;
+ // Use SendEventResponse.newBuilder() to construct.
+ private SendEventResponse(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private SendEventResponse() {
+ status_ = 0;
+ code_ = 0;
+ reason_ = "";
+ }
+
+ @java.lang.Override
+ @SuppressWarnings({"unused"})
+ protected java.lang.Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new SendEventResponse();
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private SendEventResponse(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new java.lang.NullPointerException();
+ }
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 8: {
+ int rawValue = input.readEnum();
+
+ status_ = rawValue;
+ break;
+ }
+ case 16: {
+ int rawValue = input.readEnum();
+
+ code_ = rawValue;
+ break;
+ }
+ case 24: {
+
+ sentTime_ = input.readInt64();
+ break;
+ }
+ case 34: {
+ java.lang.String s = input.readStringRequireUtf8();
+
+ reason_ = s;
+ break;
+ }
+ case 42: {
+ if (!((mutable_bitField0_ & 0x00000001) != 0)) {
+ data_ = com.google.protobuf.MapField.newMapField(
+ DataDefaultEntryHolder.defaultEntry);
+ mutable_bitField0_ |= 0x00000001;
+ }
+ com.google.protobuf.MapEntry
+ data__ = input.readMessage(
+ DataDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry);
+ data_.getMutableMap().put(
+ data__.getKey(), data__.getValue());
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_descriptor;
+ }
+
+ @SuppressWarnings({"rawtypes"})
+ @java.lang.Override
+ protected com.google.protobuf.MapField internalGetMapField(
+ int number) {
+ switch (number) {
+ case 5:
+ return internalGetData();
+ default:
+ throw new RuntimeException(
+ "Invalid map field number: " + number);
+ }
+ }
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.odpf.proton.raccoon.SendEventResponse.class, io.odpf.proton.raccoon.SendEventResponse.Builder.class);
+ }
+
+ public static final int STATUS_FIELD_NUMBER = 1;
+ private int status_;
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The enum numeric value on the wire for status.
+ */
+ @java.lang.Override public int getStatusValue() {
+ return status_;
+ }
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The status.
+ */
+ @java.lang.Override public io.odpf.proton.raccoon.Status getStatus() {
+ @SuppressWarnings("deprecation")
+ io.odpf.proton.raccoon.Status result = io.odpf.proton.raccoon.Status.valueOf(status_);
+ return result == null ? io.odpf.proton.raccoon.Status.UNRECOGNIZED : result;
+ }
+
+ public static final int CODE_FIELD_NUMBER = 2;
+ private int code_;
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The enum numeric value on the wire for code.
+ */
+ @java.lang.Override public int getCodeValue() {
+ return code_;
+ }
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The code.
+ */
+ @java.lang.Override public io.odpf.proton.raccoon.Code getCode() {
+ @SuppressWarnings("deprecation")
+ io.odpf.proton.raccoon.Code result = io.odpf.proton.raccoon.Code.valueOf(code_);
+ return result == null ? io.odpf.proton.raccoon.Code.UNRECOGNIZED : result;
+ }
+
+ public static final int SENT_TIME_FIELD_NUMBER = 3;
+ private long sentTime_;
+ /**
+ *
+ * `sent_time` is UNIX timestamp populated by Raccoon by the time the response is sent.
+ *
+ *
+ * int64 sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ @java.lang.Override
+ public long getSentTime() {
+ return sentTime_;
+ }
+
+ public static final int REASON_FIELD_NUMBER = 4;
+ private volatile java.lang.Object reason_;
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The reason.
+ */
+ @java.lang.Override
+ public java.lang.String getReason() {
+ java.lang.Object ref = reason_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ reason_ = s;
+ return s;
+ }
+ }
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The bytes for reason.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getReasonBytes() {
+ java.lang.Object ref = reason_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ reason_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int DATA_FIELD_NUMBER = 5;
+ private static final class DataDefaultEntryHolder {
+ static final com.google.protobuf.MapEntry<
+ java.lang.String, java.lang.String> defaultEntry =
+ com.google.protobuf.MapEntry
+ .newDefaultInstance(
+ io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_DataEntry_descriptor,
+ com.google.protobuf.WireFormat.FieldType.STRING,
+ "",
+ com.google.protobuf.WireFormat.FieldType.STRING,
+ "");
+ }
+ private com.google.protobuf.MapField<
+ java.lang.String, java.lang.String> data_;
+ private com.google.protobuf.MapField
+ internalGetData() {
+ if (data_ == null) {
+ return com.google.protobuf.MapField.emptyMapField(
+ DataDefaultEntryHolder.defaultEntry);
+ }
+ return data_;
+ }
+
+ public int getDataCount() {
+ return internalGetData().getMap().size();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ @java.lang.Override
+ public boolean containsData(
+ java.lang.String key) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ return internalGetData().getMap().containsKey(key);
+ }
+ /**
+ * Use {@link #getDataMap()} instead.
+ */
+ @java.lang.Override
+ @java.lang.Deprecated
+ public java.util.Map getData() {
+ return getDataMap();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.util.Map getDataMap() {
+ return internalGetData().getMap();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.lang.String getDataOrDefault(
+ java.lang.String key,
+ java.lang.String defaultValue) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ java.util.Map map =
+ internalGetData().getMap();
+ return map.containsKey(key) ? map.get(key) : defaultValue;
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.lang.String getDataOrThrow(
+ java.lang.String key) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ java.util.Map map =
+ internalGetData().getMap();
+ if (!map.containsKey(key)) {
+ throw new java.lang.IllegalArgumentException();
+ }
+ return map.get(key);
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (status_ != io.odpf.proton.raccoon.Status.STATUS_UNSPECIFIED.getNumber()) {
+ output.writeEnum(1, status_);
+ }
+ if (code_ != io.odpf.proton.raccoon.Code.CODE_UNSPECIFIED.getNumber()) {
+ output.writeEnum(2, code_);
+ }
+ if (sentTime_ != 0L) {
+ output.writeInt64(3, sentTime_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(reason_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 4, reason_);
+ }
+ com.google.protobuf.GeneratedMessageV3
+ .serializeStringMapTo(
+ output,
+ internalGetData(),
+ DataDefaultEntryHolder.defaultEntry,
+ 5);
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (status_ != io.odpf.proton.raccoon.Status.STATUS_UNSPECIFIED.getNumber()) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeEnumSize(1, status_);
+ }
+ if (code_ != io.odpf.proton.raccoon.Code.CODE_UNSPECIFIED.getNumber()) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeEnumSize(2, code_);
+ }
+ if (sentTime_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(3, sentTime_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(reason_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, reason_);
+ }
+ for (java.util.Map.Entry entry
+ : internalGetData().getMap().entrySet()) {
+ com.google.protobuf.MapEntry
+ data__ = DataDefaultEntryHolder.defaultEntry.newBuilderForType()
+ .setKey(entry.getKey())
+ .setValue(entry.getValue())
+ .build();
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(5, data__);
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.odpf.proton.raccoon.SendEventResponse)) {
+ return super.equals(obj);
+ }
+ io.odpf.proton.raccoon.SendEventResponse other = (io.odpf.proton.raccoon.SendEventResponse) obj;
+
+ if (status_ != other.status_) return false;
+ if (code_ != other.code_) return false;
+ if (getSentTime()
+ != other.getSentTime()) return false;
+ if (!getReason()
+ .equals(other.getReason())) return false;
+ if (!internalGetData().equals(
+ other.internalGetData())) return false;
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + STATUS_FIELD_NUMBER;
+ hash = (53 * hash) + status_;
+ hash = (37 * hash) + CODE_FIELD_NUMBER;
+ hash = (53 * hash) + code_;
+ hash = (37 * hash) + SENT_TIME_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getSentTime());
+ hash = (37 * hash) + REASON_FIELD_NUMBER;
+ hash = (53 * hash) + getReason().hashCode();
+ if (!internalGetData().getMap().isEmpty()) {
+ hash = (37 * hash) + DATA_FIELD_NUMBER;
+ hash = (53 * hash) + internalGetData().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.odpf.proton.raccoon.SendEventResponse parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.odpf.proton.raccoon.SendEventResponse prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code odpf.raccoon.v1beta1.SendEventResponse}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:odpf.raccoon.v1beta1.SendEventResponse)
+ io.odpf.proton.raccoon.SendEventResponseOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_descriptor;
+ }
+
+ @SuppressWarnings({"rawtypes"})
+ protected com.google.protobuf.MapField internalGetMapField(
+ int number) {
+ switch (number) {
+ case 5:
+ return internalGetData();
+ default:
+ throw new RuntimeException(
+ "Invalid map field number: " + number);
+ }
+ }
+ @SuppressWarnings({"rawtypes"})
+ protected com.google.protobuf.MapField internalGetMutableMapField(
+ int number) {
+ switch (number) {
+ case 5:
+ return internalGetMutableData();
+ default:
+ throw new RuntimeException(
+ "Invalid map field number: " + number);
+ }
+ }
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.odpf.proton.raccoon.SendEventResponse.class, io.odpf.proton.raccoon.SendEventResponse.Builder.class);
+ }
+
+ // Construct using io.odpf.proton.raccoon.SendEventResponse.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ }
+ }
+ @java.lang.Override
+ public Builder clear() {
+ super.clear();
+ status_ = 0;
+
+ code_ = 0;
+
+ sentTime_ = 0L;
+
+ reason_ = "";
+
+ internalGetMutableData().clear();
+ return this;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return io.odpf.proton.raccoon.EventProto.internal_static_odpf_raccoon_v1beta1_SendEventResponse_descriptor;
+ }
+
+ @java.lang.Override
+ public io.odpf.proton.raccoon.SendEventResponse getDefaultInstanceForType() {
+ return io.odpf.proton.raccoon.SendEventResponse.getDefaultInstance();
+ }
+
+ @java.lang.Override
+ public io.odpf.proton.raccoon.SendEventResponse build() {
+ io.odpf.proton.raccoon.SendEventResponse result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @java.lang.Override
+ public io.odpf.proton.raccoon.SendEventResponse buildPartial() {
+ io.odpf.proton.raccoon.SendEventResponse result = new io.odpf.proton.raccoon.SendEventResponse(this);
+ int from_bitField0_ = bitField0_;
+ result.status_ = status_;
+ result.code_ = code_;
+ result.sentTime_ = sentTime_;
+ result.reason_ = reason_;
+ result.data_ = internalGetData();
+ result.data_.makeImmutable();
+ onBuilt();
+ return result;
+ }
+
+ @java.lang.Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @java.lang.Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.setField(field, value);
+ }
+ @java.lang.Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @java.lang.Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @java.lang.Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, java.lang.Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @java.lang.Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @java.lang.Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof io.odpf.proton.raccoon.SendEventResponse) {
+ return mergeFrom((io.odpf.proton.raccoon.SendEventResponse)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(io.odpf.proton.raccoon.SendEventResponse other) {
+ if (other == io.odpf.proton.raccoon.SendEventResponse.getDefaultInstance()) return this;
+ if (other.status_ != 0) {
+ setStatusValue(other.getStatusValue());
+ }
+ if (other.code_ != 0) {
+ setCodeValue(other.getCodeValue());
+ }
+ if (other.getSentTime() != 0L) {
+ setSentTime(other.getSentTime());
+ }
+ if (!other.getReason().isEmpty()) {
+ reason_ = other.reason_;
+ onChanged();
+ }
+ internalGetMutableData().mergeFrom(
+ other.internalGetData());
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @java.lang.Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @java.lang.Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ io.odpf.proton.raccoon.SendEventResponse parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (io.odpf.proton.raccoon.SendEventResponse) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+ private int bitField0_;
+
+ private int status_ = 0;
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The enum numeric value on the wire for status.
+ */
+ @java.lang.Override public int getStatusValue() {
+ return status_;
+ }
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @param value The enum numeric value on the wire for status to set.
+ * @return This builder for chaining.
+ */
+ public Builder setStatusValue(int value) {
+
+ status_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The status.
+ */
+ @java.lang.Override
+ public io.odpf.proton.raccoon.Status getStatus() {
+ @SuppressWarnings("deprecation")
+ io.odpf.proton.raccoon.Status result = io.odpf.proton.raccoon.Status.valueOf(status_);
+ return result == null ? io.odpf.proton.raccoon.Status.UNRECOGNIZED : result;
+ }
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @param value The status to set.
+ * @return This builder for chaining.
+ */
+ public Builder setStatus(io.odpf.proton.raccoon.Status value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ status_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return This builder for chaining.
+ */
+ public Builder clearStatus() {
+
+ status_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int code_ = 0;
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The enum numeric value on the wire for code.
+ */
+ @java.lang.Override public int getCodeValue() {
+ return code_;
+ }
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @param value The enum numeric value on the wire for code to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCodeValue(int value) {
+
+ code_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The code.
+ */
+ @java.lang.Override
+ public io.odpf.proton.raccoon.Code getCode() {
+ @SuppressWarnings("deprecation")
+ io.odpf.proton.raccoon.Code result = io.odpf.proton.raccoon.Code.valueOf(code_);
+ return result == null ? io.odpf.proton.raccoon.Code.UNRECOGNIZED : result;
+ }
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @param value The code to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCode(io.odpf.proton.raccoon.Code value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ code_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return This builder for chaining.
+ */
+ public Builder clearCode() {
+
+ code_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private long sentTime_ ;
+ /**
+ *
+ * `sent_time` is UNIX timestamp populated by Raccoon by the time the response is sent.
+ *
+ *
+ * int64 sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ @java.lang.Override
+ public long getSentTime() {
+ return sentTime_;
+ }
+ /**
+ *
+ * `sent_time` is UNIX timestamp populated by Raccoon by the time the response is sent.
+ *
+ *
+ * int64 sent_time = 3 [json_name = "sentTime"];
+ * @param value The sentTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSentTime(long value) {
+
+ sentTime_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `sent_time` is UNIX timestamp populated by Raccoon by the time the response is sent.
+ *
+ *
+ * int64 sent_time = 3 [json_name = "sentTime"];
+ * @return This builder for chaining.
+ */
+ public Builder clearSentTime() {
+
+ sentTime_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object reason_ = "";
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The reason.
+ */
+ public java.lang.String getReason() {
+ java.lang.Object ref = reason_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ reason_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The bytes for reason.
+ */
+ public com.google.protobuf.ByteString
+ getReasonBytes() {
+ java.lang.Object ref = reason_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ reason_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @param value The reason to set.
+ * @return This builder for chaining.
+ */
+ public Builder setReason(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ reason_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return This builder for chaining.
+ */
+ public Builder clearReason() {
+
+ reason_ = getDefaultInstance().getReason();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @param value The bytes for reason to set.
+ * @return This builder for chaining.
+ */
+ public Builder setReasonBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ reason_ = value;
+ onChanged();
+ return this;
+ }
+
+ private com.google.protobuf.MapField<
+ java.lang.String, java.lang.String> data_;
+ private com.google.protobuf.MapField
+ internalGetData() {
+ if (data_ == null) {
+ return com.google.protobuf.MapField.emptyMapField(
+ DataDefaultEntryHolder.defaultEntry);
+ }
+ return data_;
+ }
+ private com.google.protobuf.MapField
+ internalGetMutableData() {
+ onChanged();;
+ if (data_ == null) {
+ data_ = com.google.protobuf.MapField.newMapField(
+ DataDefaultEntryHolder.defaultEntry);
+ }
+ if (!data_.isMutable()) {
+ data_ = data_.copy();
+ }
+ return data_;
+ }
+
+ public int getDataCount() {
+ return internalGetData().getMap().size();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ @java.lang.Override
+ public boolean containsData(
+ java.lang.String key) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ return internalGetData().getMap().containsKey(key);
+ }
+ /**
+ * Use {@link #getDataMap()} instead.
+ */
+ @java.lang.Override
+ @java.lang.Deprecated
+ public java.util.Map getData() {
+ return getDataMap();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.util.Map getDataMap() {
+ return internalGetData().getMap();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.lang.String getDataOrDefault(
+ java.lang.String key,
+ java.lang.String defaultValue) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ java.util.Map map =
+ internalGetData().getMap();
+ return map.containsKey(key) ? map.get(key) : defaultValue;
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ @java.lang.Override
+
+ public java.lang.String getDataOrThrow(
+ java.lang.String key) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ java.util.Map map =
+ internalGetData().getMap();
+ if (!map.containsKey(key)) {
+ throw new java.lang.IllegalArgumentException();
+ }
+ return map.get(key);
+ }
+
+ public Builder clearData() {
+ internalGetMutableData().getMutableMap()
+ .clear();
+ return this;
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ public Builder removeData(
+ java.lang.String key) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ internalGetMutableData().getMutableMap()
+ .remove(key);
+ return this;
+ }
+ /**
+ * Use alternate mutation accessors instead.
+ */
+ @java.lang.Deprecated
+ public java.util.Map
+ getMutableData() {
+ return internalGetMutableData().getMutableMap();
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ public Builder putData(
+ java.lang.String key,
+ java.lang.String value) {
+ if (key == null) { throw new NullPointerException("map key"); }
+ if (value == null) {
+ throw new NullPointerException("map value");
+}
+
+ internalGetMutableData().getMutableMap()
+ .put(key, value);
+ return this;
+ }
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ public Builder putAllData(
+ java.util.Map values) {
+ internalGetMutableData().getMutableMap()
+ .putAll(values);
+ return this;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:odpf.raccoon.v1beta1.SendEventResponse)
+ }
+
+ // @@protoc_insertion_point(class_scope:odpf.raccoon.v1beta1.SendEventResponse)
+ private static final io.odpf.proton.raccoon.SendEventResponse DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new io.odpf.proton.raccoon.SendEventResponse();
+ }
+
+ public static io.odpf.proton.raccoon.SendEventResponse getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @java.lang.Override
+ public SendEventResponse parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new SendEventResponse(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public io.odpf.proton.raccoon.SendEventResponse getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+}
+
diff --git a/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponseOrBuilder.java b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponseOrBuilder.java
new file mode 100644
index 00000000..47f33fe1
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/proton/raccoon/SendEventResponseOrBuilder.java
@@ -0,0 +1,151 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: .temp/odpf/raccoon/v1beta1/raccoon.proto
+
+package io.odpf.proton.raccoon;
+
+public interface SendEventResponseOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:odpf.raccoon.v1beta1.SendEventResponse)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The enum numeric value on the wire for status.
+ */
+ int getStatusValue();
+ /**
+ *
+ * `status` denotes status of the request.
+ * Only 3 values are valid. `SUCCESS` means the the request is processed
+ * successfully. `ERROR` means the request failed to be processed. `UNKNOWN_STATUS`
+ * means Raccoon unable to determine whether the request is success or not.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Status status = 1 [json_name = "status"];
+ * @return The status.
+ */
+ io.odpf.proton.raccoon.Status getStatus();
+
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The enum numeric value on the wire for code.
+ */
+ int getCodeValue();
+ /**
+ *
+ * `code` gives more detail of what happened to the request.
+ * Details of available `code` can be seen below.
+ *
+ *
+ * .odpf.raccoon.v1beta1.Code code = 2 [json_name = "code"];
+ * @return The code.
+ */
+ io.odpf.proton.raccoon.Code getCode();
+
+ /**
+ *
+ * `sent_time` is UNIX timestamp populated by Raccoon by the time the response is sent.
+ *
+ *
+ * int64 sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ long getSentTime();
+
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The reason.
+ */
+ java.lang.String getReason();
+ /**
+ *
+ * `reason` is additional-human readable information to provide more context to `status` and `code`.
+ * There is no predefined structure for this. The value is arbitrary.
+ *
+ *
+ * string reason = 4 [json_name = "reason"];
+ * @return The bytes for reason.
+ */
+ com.google.protobuf.ByteString
+ getReasonBytes();
+
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ int getDataCount();
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ boolean containsData(
+ java.lang.String key);
+ /**
+ * Use {@link #getDataMap()} instead.
+ */
+ @java.lang.Deprecated
+ java.util.Map
+ getData();
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+ java.util.Map
+ getDataMap();
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ java.lang.String getDataOrDefault(
+ java.lang.String key,
+ java.lang.String defaultValue);
+ /**
+ *
+ * `data` is arbitrary extra metadata.
+ * Arbitrary key-value makes the field flexible for future changes. `req_guid` is also sent as part
+ * of `data`. The client may fetch req_guid as key to get the `req_guid` value.
+ *
+ *
+ * map<string, string> data = 5 [json_name = "data"];
+ */
+
+ java.lang.String getDataOrThrow(
+ java.lang.String key);
+}
diff --git a/clients/java/src/main/java/io/odpf/proton/raccoon/Status.java b/clients/java/src/main/java/io/odpf/proton/raccoon/Status.java
new file mode 100644
index 00000000..1e75c0dc
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/proton/raccoon/Status.java
@@ -0,0 +1,122 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: .temp/odpf/raccoon/v1beta1/raccoon.proto
+
+package io.odpf.proton.raccoon;
+
+/**
+ * Protobuf enum {@code odpf.raccoon.v1beta1.Status}
+ */
+public enum Status
+ implements com.google.protobuf.ProtocolMessageEnum {
+ /**
+ * STATUS_UNSPECIFIED = 0;
+ */
+ STATUS_UNSPECIFIED(0),
+ /**
+ * STATUS_SUCCESS = 1;
+ */
+ STATUS_SUCCESS(1),
+ /**
+ * STATUS_ERROR = 2;
+ */
+ STATUS_ERROR(2),
+ UNRECOGNIZED(-1),
+ ;
+
+ /**
+ * STATUS_UNSPECIFIED = 0;
+ */
+ public static final int STATUS_UNSPECIFIED_VALUE = 0;
+ /**
+ * STATUS_SUCCESS = 1;
+ */
+ public static final int STATUS_SUCCESS_VALUE = 1;
+ /**
+ * STATUS_ERROR = 2;
+ */
+ public static final int STATUS_ERROR_VALUE = 2;
+
+
+ public final int getNumber() {
+ if (this == UNRECOGNIZED) {
+ throw new java.lang.IllegalArgumentException(
+ "Can't get the number of an unknown enum value.");
+ }
+ return value;
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ * @deprecated Use {@link #forNumber(int)} instead.
+ */
+ @java.lang.Deprecated
+ public static Status valueOf(int value) {
+ return forNumber(value);
+ }
+
+ /**
+ * @param value The numeric wire value of the corresponding enum entry.
+ * @return The enum associated with the given numeric wire value.
+ */
+ public static Status forNumber(int value) {
+ switch (value) {
+ case 0: return STATUS_UNSPECIFIED;
+ case 1: return STATUS_SUCCESS;
+ case 2: return STATUS_ERROR;
+ default: return null;
+ }
+ }
+
+ public static com.google.protobuf.Internal.EnumLiteMap
+ internalGetValueMap() {
+ return internalValueMap;
+ }
+ private static final com.google.protobuf.Internal.EnumLiteMap<
+ Status> internalValueMap =
+ new com.google.protobuf.Internal.EnumLiteMap() {
+ public Status findValueByNumber(int number) {
+ return Status.forNumber(number);
+ }
+ };
+
+ public final com.google.protobuf.Descriptors.EnumValueDescriptor
+ getValueDescriptor() {
+ if (this == UNRECOGNIZED) {
+ throw new java.lang.IllegalStateException(
+ "Can't get the descriptor of an unrecognized enum value.");
+ }
+ return getDescriptor().getValues().get(ordinal());
+ }
+ public final com.google.protobuf.Descriptors.EnumDescriptor
+ getDescriptorForType() {
+ return getDescriptor();
+ }
+ public static final com.google.protobuf.Descriptors.EnumDescriptor
+ getDescriptor() {
+ return io.odpf.proton.raccoon.EventProto.getDescriptor().getEnumTypes().get(0);
+ }
+
+ private static final Status[] VALUES = values();
+
+ public static Status valueOf(
+ com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+ if (desc.getType() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "EnumValueDescriptor is not for this type.");
+ }
+ if (desc.getIndex() == -1) {
+ return UNRECOGNIZED;
+ }
+ return VALUES[desc.getIndex()];
+ }
+
+ private final int value;
+
+ private Status(int value) {
+ this.value = value;
+ }
+
+ // @@protoc_insertion_point(enum_scope:odpf.raccoon.v1beta1.Status)
+}
+
diff --git a/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClient.java b/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClient.java
new file mode 100644
index 00000000..f14b816b
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClient.java
@@ -0,0 +1,17 @@
+package io.odpf.raccoon.client;
+
+import io.odpf.raccoon.model.Event;
+import io.odpf.raccoon.model.Response;
+
+/**
+ * An interface for the raccoon clients.
+ */
+public interface RaccoonClient {
+ /**
+ * Sends a request to raccoon with the message provided.
+ *
+ * @param events The raccoon event message array.
+ * @return {@link Response} The raccoon response.
+ */
+ Response send(Event[] events);
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClientFactory.java b/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClientFactory.java
new file mode 100644
index 00000000..81f08656
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/client/RaccoonClientFactory.java
@@ -0,0 +1,18 @@
+package io.odpf.raccoon.client;
+
+import lombok.NonNull;
+
+/**
+ * Factory for raccoon client.
+ */
+public class RaccoonClientFactory {
+ /**
+ * Creates the new Rest client for the raccoon.
+ *
+ * @param restConfig The rest config options.
+ * @return RestClient The rest client.
+ */
+ public static RaccoonClient getRestClient(@NonNull RestConfig restConfig) {
+ return new RestClient(restConfig);
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/client/RestClient.java b/clients/java/src/main/java/io/odpf/raccoon/client/RestClient.java
new file mode 100644
index 00000000..f78bfbe8
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/client/RestClient.java
@@ -0,0 +1,142 @@
+package io.odpf.raccoon.client;
+
+import com.google.api.client.http.HttpStatusCodes;
+import com.google.common.io.ByteStreams;
+import com.google.protobuf.ByteString;
+import io.odpf.proton.raccoon.Event.Builder;
+import io.odpf.proton.raccoon.SendEventRequest;
+import io.odpf.proton.raccoon.SendEventResponse;
+import io.odpf.raccoon.model.Event;
+import io.odpf.raccoon.model.Response;
+import io.odpf.raccoon.wire.JsonWire;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.ServiceUnavailableRetryStrategy;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ByteArrayEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.protocol.HttpContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.UUID;
+
+/**
+ * Class for the http client implementation.
+ */
+ class RestClient implements RaccoonClient {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(RestClient.class);
+
+ private final RestConfig restConfig;
+
+ /**
+ * @param restConfig The rest config options.
+ */
+ RestClient(RestConfig restConfig) {
+ this.restConfig = restConfig;
+ this.restConfig.setHttpClient(this.getHttpClient());
+ }
+
+ /**
+ * Send creates a batch request, produces a request guid, and sends an HTTP
+ * request.
+ *
+ * @param events The raccoon message array.
+ * @return {@link Response} The response for the given raccoon request.
+ */
+ @Override
+ public Response send(Event[] events) {
+ String reqGuid = UUID.randomUUID().toString();
+ CloseableHttpResponse response = null;
+ String errorMessage;
+ try {
+ LOGGER.info("send: started request, url:{}, req-id: {}", this.restConfig.getUrl(), reqGuid);
+ SendEventRequest.Builder builder = SendEventRequest.newBuilder();
+ builder.setReqGuid(reqGuid);
+
+ for (Event e : events) {
+ Builder protoEvents = io.odpf.proton.raccoon.Event.newBuilder();
+ protoEvents.setType(e.getType());
+ protoEvents.setEventBytes(ByteString.copyFrom(this.restConfig.getSerializer().serialize(e.getData())));
+
+ builder.addEvents(protoEvents.build());
+ }
+
+ // wire request.
+ SendEventRequest postRequest = builder.build();
+
+ HttpPost httPost = new HttpPost(restConfig.getUrl());
+ httPost.addHeader("Content-Type", this.restConfig.getMarshaler().getContentType());
+ httPost.setEntity(new ByteArrayEntity(this.restConfig.getMarshaler().marshal(postRequest)));
+
+ this.restConfig.getHeaders().forEach(httPost::addHeader);
+
+ response = this.restConfig.getHttpClient().execute(httPost);
+ SendEventResponse eventResponse = (SendEventResponse) this.restConfig.getMarshaler().unmarshal(
+ ByteStreams.toByteArray(response.getEntity()
+ .getContent()),
+ this.restConfig.getMarshaler() instanceof JsonWire ? SendEventResponse.newBuilder()
+ : SendEventResponse.parser());
+
+ return Response.builder().isSuccess(true)
+ .reqGuid(reqGuid)
+ .status(eventResponse.getStatusValue())
+ .code(eventResponse.getCodeValue())
+ .sentTime(eventResponse.getSentTime())
+ .data(eventResponse.getDataMap())
+ .build();
+
+ } catch (Exception ex) {
+ LOGGER.error(ex.getMessage());
+ errorMessage = ex.getMessage();
+ } finally {
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+ LOGGER.error("send: exception when closing httpclient", e);
+ errorMessage = e.getMessage();
+ }
+ }
+ LOGGER.info("send: ended request, url:{}, req-id: {}", this.restConfig.getUrl(), reqGuid);
+ }
+
+ return Response.builder()
+ .isSuccess(false)
+ .reqGuid(reqGuid)
+ .errorMessage(errorMessage)
+ .build();
+ }
+
+ /**
+ * Creates the new HTTP client and set the retry handler with the provided settings.
+ *
+ * @return The new HTTP client.
+ */
+ private CloseableHttpClient getHttpClient() {
+
+ return HttpClients
+ .custom()
+ .setRetryHandler((exception, executionCount, context) -> executionCount < restConfig.getRetryMax())
+ .setServiceUnavailableRetryStrategy(new ServiceUnavailableRetryStrategy() {
+
+ @Override
+ public boolean retryRequest(HttpResponse response, int executionCount, HttpContext context) {
+ LOGGER.warn("Retrying the http request, retry-count:{}, response-code:{}", executionCount,
+ response.getStatusLine().getStatusCode());
+ return executionCount < restConfig.getRetryMax()
+ && response.getStatusLine().getStatusCode() != HttpStatusCodes.STATUS_CODE_OK;
+ }
+
+ @Override
+ public long getRetryInterval() {
+ return restConfig.getRetryWait();
+ }
+
+ })
+ .build();
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/client/RestConfig.java b/clients/java/src/main/java/io/odpf/raccoon/client/RestConfig.java
new file mode 100644
index 00000000..932f045e
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/client/RestConfig.java
@@ -0,0 +1,73 @@
+package io.odpf.raccoon.client;
+
+import io.odpf.raccoon.serializer.JsonSerializer;
+import io.odpf.raccoon.serializer.Serializer;
+import io.odpf.raccoon.wire.JsonWire;
+import io.odpf.raccoon.wire.WireMarshaler;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.Singular;
+import org.apache.http.impl.client.CloseableHttpClient;
+
+import java.util.Map;
+
+@Getter
+@Setter
+@Builder(toBuilder = true)
+
+/*
+ * Rest config options for the Raccoon http request.
+ */
+public class RestConfig {
+ /**
+ * The default max retry attempts.
+ */
+ private static final int MAX_RETRY = 3;
+
+ /**
+ * The default delay between retries.
+ */
+ private static final int RETRY_WAIT_MILISECONDS = 1000;
+
+ /**
+ * The raccoon http endpoint to make the request.
+ */
+ @Builder.Default
+ private String url = "http://localhost:8080/api/v1/events";
+
+ /**
+ * The max retry attempts to be made on failed requests.
+ */
+ @Builder.Default
+ private Integer retryMax = MAX_RETRY;
+
+ /**
+ * The sleep time between the retry requests in miliseconds.
+ */
+ @Builder.Default
+ private long retryWait = RETRY_WAIT_MILISECONDS;
+
+ /**
+ * The serializer for the raccoon batch request.
+ */
+ @Builder.Default
+ private Serializer serializer = new JsonSerializer();
+
+ /**
+ * The marshaler for the wire request made to the raccoon.
+ */
+ @Builder.Default
+ private WireMarshaler marshaler = new JsonWire();
+
+ /**
+ * The http request headers.
+ */
+ @Singular
+ private Map headers;
+
+ /**
+ * The http client.
+ */
+ private CloseableHttpClient httpClient;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/exception/DeserializationException.java b/clients/java/src/main/java/io/odpf/raccoon/exception/DeserializationException.java
new file mode 100644
index 00000000..92bc622e
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/exception/DeserializationException.java
@@ -0,0 +1,16 @@
+package io.odpf.raccoon.exception;
+
+/**
+ * Exception thrown when the deserialization process fails.
+ */
+public class DeserializationException extends RuntimeException {
+ /**
+ * Constructs a new {@link DeserializationException} with specified detail
+ * message.
+ *
+ * @param msg The error message.
+ */
+ public DeserializationException(final String msg) {
+ super(msg);
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/exception/SerializationException.java b/clients/java/src/main/java/io/odpf/raccoon/exception/SerializationException.java
new file mode 100644
index 00000000..8f3d600d
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/exception/SerializationException.java
@@ -0,0 +1,16 @@
+package io.odpf.raccoon.exception;
+
+/**
+ * Exception thrown when the serialization process fails.
+ */
+public class SerializationException extends RuntimeException {
+ /**
+ * Constructs a new {@link SerializationException} with specified detail
+ * message.
+ *
+ * @param msg The error message.
+ */
+ public SerializationException(final String msg) {
+ super(msg);
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/model/Event.java b/clients/java/src/main/java/io/odpf/raccoon/model/Event.java
new file mode 100644
index 00000000..cbf4f551
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/model/Event.java
@@ -0,0 +1,23 @@
+package io.odpf.raccoon.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+@AllArgsConstructor
+@Data
+
+/*
+ * Class holds the raccoon event, and it's type name.
+ */
+public class Event {
+
+ /**
+ * The event type name.
+ */
+ private String type;
+
+ /**
+ * The event batch.
+ */
+ private Object data;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/model/Response.java b/clients/java/src/main/java/io/odpf/raccoon/model/Response.java
new file mode 100644
index 00000000..2481f4b7
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/model/Response.java
@@ -0,0 +1,57 @@
+package io.odpf.raccoon.model;
+
+import java.util.Map;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Data
+@Builder(toBuilder = true)
+
+/*
+ * Response holds the information about the request.
+ */
+public class Response {
+
+ /**
+ * The status of the raccoon request.
+ */
+ private boolean isSuccess;
+
+ /**
+ * The request guid of the request.
+ */
+ private String reqGuid;
+
+ /**
+ * The error message which gets populated on the failed requests.
+ */
+ private String errorMessage;
+
+ /**
+ * The {@link ResponseStatus} denotes status of the request.
+ */
+ private int status;
+
+ /**
+ * The {@link ResponseCode} gives more detail of what happened to the request.
+ */
+ private int code;
+
+ /**
+ * The sentTime is UNIX timestamp populated by Raccoon by the time the response
+ * is
+ * sent.
+ */
+ private long sentTime;
+
+ /**
+ * Data is arbitrary extra metadata.
+ * The data map will contain the "req_guid" key
+ */
+ private Map data;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/model/ResponseCode.java b/clients/java/src/main/java/io/odpf/raccoon/model/ResponseCode.java
new file mode 100644
index 00000000..00f254fb
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/model/ResponseCode.java
@@ -0,0 +1,36 @@
+package io.odpf.raccoon.model;
+
+public class ResponseCode {
+ /*
+ * `CODE_UNSPECIFIED` indicates no appropriate/existing code can describe it.
+ */
+ public static final int CODE_UNSPECIFIED = 0;
+
+ /*
+ * `OK` indicates the request is processed successfully.
+ */
+ public static final int CODE_OK = 1;
+
+ /*
+ * `BAD_REQUEST` indicates there is something wrong with the request.
+ */
+ public static final int CODE_BAD_REQUEST = 2;
+
+ /*
+ * `INTERNAL_ERROR` indicates that Raccoon encountered an unexpected condition
+ * that prevented it from fulfilling the request.
+ */
+ public static final int CODE_INTERNAL_ERROR = 3;
+
+ /*
+ * `MAX_CONNECTION_LIMIT_REACHED` indicates that Raccoon is unable to accepts
+ * new connection due to max connection is reached.
+ */
+
+ public static final int CODE_MAX_CONNECTION_LIMIT_REACHED = 4;
+
+ /*
+ * `MAX_USER_LIMIT_REACHED` indicates that existing connection with the same ID.
+ */
+ public static final int CODE_MAX_USER_LIMIT_REACHED = 5;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/model/ResponseStatus.java b/clients/java/src/main/java/io/odpf/raccoon/model/ResponseStatus.java
new file mode 100644
index 00000000..5a4be642
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/model/ResponseStatus.java
@@ -0,0 +1,18 @@
+package io.odpf.raccoon.model;
+
+public class ResponseStatus {
+ /*
+ * `UNSPECIFIED` indicates if request is failed for the unknown reasons.
+ */
+ public static final int STATUS_UNSPECIFIED = 0;
+
+ /*
+ * 'SUCCESS' indicates if the request is successful.
+ */
+ public static final int STATUS_SUCCESS = 1;
+
+ /*
+ * 'ERROR' indicates if the request is failed.
+ */
+ public static final int STATUS_ERROR = 2;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/serializer/JsonSerializer.java b/clients/java/src/main/java/io/odpf/raccoon/serializer/JsonSerializer.java
new file mode 100644
index 00000000..9f580299
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/serializer/JsonSerializer.java
@@ -0,0 +1,46 @@
+package io.odpf.raccoon.serializer;
+
+import com.google.gson.Gson;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.MessageOrBuilder;
+import com.google.protobuf.util.JsonFormat;
+import io.odpf.raccoon.exception.SerializationException;
+
+/**
+ Json class to convert raccoon messages.
+**/
+public class JsonSerializer implements Serializer {
+
+ private final Gson gson;
+
+ /**
+ * Initializes the gson instance.
+ */
+ public JsonSerializer() {
+ this.gson = new Gson();
+ }
+
+ /**
+ * Json serializer for the raccoon messages.
+ *
+ * @see io.odpf.raccoon.serializer.Serializer#serialize(java.lang.Object)
+ * @param any is the object to be serialized.
+ * @return returns the json bytes.
+ **/
+ @Override
+ public byte[] serialize(Object any) throws SerializationException {
+ if (any instanceof MessageOrBuilder) {
+ try {
+ return JsonFormat.printer()
+ .omittingInsignificantWhitespace()
+ .preservingProtoFieldNames()
+ .print((MessageOrBuilder) any)
+ .getBytes();
+ } catch (InvalidProtocolBufferException e) {
+ throw new SerializationException(e.getMessage());
+ }
+ }
+
+ return this.gson.toJson(any).getBytes();
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/serializer/ProtoSerializer.java b/clients/java/src/main/java/io/odpf/raccoon/serializer/ProtoSerializer.java
new file mode 100644
index 00000000..c61bbd54
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/serializer/ProtoSerializer.java
@@ -0,0 +1,23 @@
+package io.odpf.raccoon.serializer;
+
+import com.google.protobuf.GeneratedMessageV3;
+import io.odpf.raccoon.exception.SerializationException;
+
+public class ProtoSerializer implements Serializer {
+
+ /**
+ * Converts a proto object to the byte array.
+ *
+ * @param any proto object to be serialized.
+ * @return the proto byte array.
+ * @throws SerializationException Throws exceptions if the object is non-proto.
+ */
+ @Override
+ public byte[] serialize(Object any) throws SerializationException {
+ if (any instanceof GeneratedMessageV3) {
+ return ((GeneratedMessageV3) any).toByteArray();
+ }
+
+ throw new SerializationException("Error: unable to serialize non proto object");
+ }
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/serializer/Serializer.java b/clients/java/src/main/java/io/odpf/raccoon/serializer/Serializer.java
new file mode 100644
index 00000000..596342a1
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/serializer/Serializer.java
@@ -0,0 +1,17 @@
+package io.odpf.raccoon.serializer;
+
+import io.odpf.raccoon.exception.SerializationException;
+
+/*
+ Interface serializer defines a conversion for raccoon message to byte sequence.
+*/
+public interface Serializer {
+ /**
+ * Serialize the given object into the byte array.
+ *
+ * @param any object to be serialized.
+ * @return the serialized byte array.
+ * @throws SerializationException if the object fail to serialize.
+ */
+ byte[] serialize(Object any) throws SerializationException;
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/wire/JsonWire.java b/clients/java/src/main/java/io/odpf/raccoon/wire/JsonWire.java
new file mode 100644
index 00000000..fbd81408
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/wire/JsonWire.java
@@ -0,0 +1,80 @@
+package io.odpf.raccoon.wire;
+
+import com.google.gson.Gson;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.Message;
+import com.google.protobuf.MessageOrBuilder;
+import com.google.protobuf.util.JsonFormat;
+import io.odpf.raccoon.exception.DeserializationException;
+import io.odpf.raccoon.exception.SerializationException;
+
+/**
+ * Json class to convert raccoon messages to/from the proto3.
+ */
+public class JsonWire implements WireMarshaler {
+
+ private final Gson gson;
+
+ public JsonWire() {
+ this.gson = new Gson();
+ }
+
+ /**
+ * Converts a raccoon message to the json.
+ *
+ * @param any object to be marshaled.
+ * @return the marshal byte array.
+ * @throws SerializationException Throws exceptions if fail to serialize.
+ */
+ @Override
+ public byte[] marshal(Object any) throws SerializationException {
+ try {
+ if (any instanceof MessageOrBuilder) {
+ return JsonFormat.printer()
+ .omittingInsignificantWhitespace()
+ .preservingProtoFieldNames()
+ .print((MessageOrBuilder) any)
+ .getBytes();
+ }
+
+ return this.gson.toJson(any).getBytes();
+
+ } catch (InvalidProtocolBufferException e) {
+ throw new SerializationException(e.getMessage());
+ }
+ }
+
+ /**
+ * Converts the json bytes back into the object.
+ *
+ * @param any object to be unmarshal.
+ * @param type object to be used for unmarshal.
+ * @return the unmarshal object.
+ * @throws DeserializationException Throws exceptions if fail to deserialize.
+ */
+ @Override
+ public Object unmarshal(byte[] any, Object type) throws DeserializationException {
+ try {
+ if (type instanceof Message.Builder) {
+ Message.Builder builder = (Message.Builder) type;
+ JsonFormat.parser().merge(new String(any), builder);
+ return builder.build();
+ }
+
+ return this.gson.fromJson(new String(any), type.getClass());
+ } catch (InvalidProtocolBufferException e) {
+ throw new DeserializationException(e.getMessage());
+ }
+ }
+
+ /**
+ * Wire content type for the json marshaled request.
+ *
+ * @return the content type.
+ */
+ @Override
+ public String getContentType() {
+ return "application/json";
+ }
+
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/wire/ProtoWire.java b/clients/java/src/main/java/io/odpf/raccoon/wire/ProtoWire.java
new file mode 100644
index 00000000..a8860beb
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/wire/ProtoWire.java
@@ -0,0 +1,61 @@
+package io.odpf.raccoon.wire;
+
+import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.Parser;
+import io.odpf.raccoon.exception.DeserializationException;
+import io.odpf.raccoon.exception.SerializationException;
+
+/**
+ * Proto class to convert raccoon messages to/from the proto3.
+ */
+public class ProtoWire implements WireMarshaler {
+
+ /**
+ * Converts a raccoon request to the proto.
+ *
+ * @param any proto object to be marshaled.
+ * @return the marshal byte array.
+ * @throws SerializationException Throws when the serialization fails.
+ */
+ @Override
+ public byte[] marshal(Object any) throws SerializationException {
+ if (any instanceof GeneratedMessageV3) {
+ return ((GeneratedMessageV3) any).toByteArray();
+ }
+
+ throw new SerializationException("unable to serialize the non proto message");
+ }
+
+ /**
+ * Converts the raccoon request proto bytes back into the object.
+ *
+ * @param any proto object to be unmarshal.
+ * @param type prototype to be used for unmarshal.
+ * @return the unmarshalled object.
+ * @throws DeserializationException Throws when the deserialization fails.
+ */
+ @Override
+ public Object unmarshal(byte[] any, Object type) throws DeserializationException {
+ try {
+ if (type instanceof Parser) {
+ return ((Parser) type).parseFrom(any);
+ }
+ } catch (InvalidProtocolBufferException e) {
+ throw new DeserializationException(e.getMessage());
+ }
+
+ throw new DeserializationException("unable to deserialize using the non proto parser");
+ }
+
+ /**
+ * Wire content type for the proto marshaled request.
+ *
+ * @return the content type.
+ */
+ @Override
+ public String getContentType() {
+ return "application/proto";
+ }
+
+}
diff --git a/clients/java/src/main/java/io/odpf/raccoon/wire/WireMarshaler.java b/clients/java/src/main/java/io/odpf/raccoon/wire/WireMarshaler.java
new file mode 100644
index 00000000..e3eb4da2
--- /dev/null
+++ b/clients/java/src/main/java/io/odpf/raccoon/wire/WireMarshaler.java
@@ -0,0 +1,35 @@
+package io.odpf.raccoon.wire;
+
+import io.odpf.raccoon.exception.DeserializationException;
+import io.odpf.raccoon.exception.SerializationException;
+
+/**
+ * An interface for marshaling/unmarshalling the wire requests.
+ */
+public interface WireMarshaler {
+ /**
+ * Marshal the given object into the byte array.
+ *
+ * @param any serializable object.
+ * @return the byte array.
+ * @throws SerializationException throw when the serialization fails.
+ */
+ byte[] marshal(Object any) throws SerializationException;
+
+ /**
+ * Unmarshal the given byte array into the object.
+ *
+ * @param any serializable byte array.
+ * @param type the type to be
+ * @return The object un-marshalled from the byte array.
+ * @throws DeserializationException throw when the deserialization fails.
+ */
+ Object unmarshal(byte[] any, Object type) throws DeserializationException;
+
+ /**
+ * Content type of the wire request.
+ *
+ * @return the content type.
+ */
+ String getContentType();
+}
diff --git a/clients/java/src/test/java/buf.gen.yaml b/clients/java/src/test/java/buf.gen.yaml
new file mode 100644
index 00000000..9b19a023
--- /dev/null
+++ b/clients/java/src/test/java/buf.gen.yaml
@@ -0,0 +1,4 @@
+version: v1
+plugins:
+ - remote: buf.build/protocolbuffers/plugins/java:v3.19.1-1
+ out: .
\ No newline at end of file
diff --git a/clients/java/src/test/java/io/odpf/raccoon/RestClientTest.java b/clients/java/src/test/java/io/odpf/raccoon/RestClientTest.java
new file mode 100644
index 00000000..399899c6
--- /dev/null
+++ b/clients/java/src/test/java/io/odpf/raccoon/RestClientTest.java
@@ -0,0 +1,169 @@
+package io.odpf.raccoon;
+
+import com.github.tomakehurst.wiremock.junit.WireMockRule;
+import com.google.protobuf.Timestamp;
+import com.google.protobuf.util.JsonFormat;
+import io.odpf.proton.raccoon.SendEventResponse;
+import io.odpf.raccoon.client.RaccoonClient;
+import io.odpf.raccoon.client.RaccoonClientFactory;
+import io.odpf.raccoon.client.RestConfig;
+import io.odpf.raccoon.model.Event;
+import io.odpf.raccoon.model.Response;
+import io.odpf.raccoon.model.ResponseCode;
+import io.odpf.raccoon.model.ResponseStatus;
+import io.odpf.raccoon.serializer.JsonSerializer;
+import io.odpf.raccoon.serializer.ProtoSerializer;
+import io.odpf.raccoon.wire.JsonWire;
+import io.odpf.raccoon.wire.ProtoWire;
+import org.junit.Assert;
+import org.junit.Rule;
+import org.junit.Test;
+import sample.PageEventProto;
+
+import java.util.HashMap;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+public class RestClientTest {
+
+ @Rule
+ public WireMockRule service = new WireMockRule(8082);
+
+ @Test
+ public void testProtoSend() throws Exception {
+
+ String reqGuid = UUID.randomUUID().toString();
+ service.stubFor(
+ post("/api/v1/events")
+ .withHeader("Content-Type", containing("proto"))
+ .willReturn(ok()
+ .withHeader("Content-Type", "application/proto")
+ .withBody(getProtoResponse(reqGuid))));
+
+ RestConfig config = RestConfig.builder()
+ .url(service.url("/api/v1/events"))
+ .header("x-connection-id", "123")
+ .serializer(new ProtoSerializer())
+ .marshaler(new ProtoWire()).build();
+
+ RaccoonClient restClient = RaccoonClientFactory.getRestClient(config);
+
+ PageEventProto.PageEvent pageEvent = getPageEvent(reqGuid);
+
+ Response response = restClient.send(
+ new Event[] {
+ new Event("page", pageEvent)
+ });
+
+ Assert.assertTrue(response.isSuccess());
+ Assert.assertEquals(response.getCode(), ResponseCode.CODE_OK);
+ Assert.assertEquals(response.getStatus(), ResponseStatus.STATUS_SUCCESS);
+ Assert.assertTrue(response.getData().containsKey("req_guid"));
+ Assert.assertNull(response.getErrorMessage());
+ Assert.assertNotNull(response.getReqGuid());
+ }
+
+ @Test
+ public void testJsonSend() throws Exception {
+ String reqGuid = UUID.randomUUID().toString();
+ service.stubFor(
+ post("/api/v1/events")
+ .withHeader("Content-Type", containing("json"))
+ .willReturn(ok()
+ .withHeader("Content-Type", "application/json")
+ .withBody(getJsonResponse(reqGuid))));
+
+ RestConfig config = RestConfig.builder()
+ .url(service.url("/api/v1/events"))
+ .header("x-connection-id", "123")
+ .serializer(new JsonSerializer())
+ .marshaler(new JsonWire()).build();
+
+ RaccoonClient restClient = RaccoonClientFactory.getRestClient(config);
+
+ PageEventProto.PageEvent pageEvent = getPageEvent(reqGuid);
+
+ Response response = restClient.send(
+ new Event[] {
+ new Event("page", pageEvent)
+ });
+
+ Assert.assertTrue(response.isSuccess());
+ Assert.assertEquals(response.getCode(), ResponseCode.CODE_OK);
+ Assert.assertEquals(response.getStatus(), ResponseStatus.STATUS_SUCCESS);
+ Assert.assertTrue(response.getData().containsKey("req_guid"));
+ Assert.assertNull(response.getErrorMessage());
+ Assert.assertNotNull(response.getReqGuid());
+ }
+
+ @Test
+ public void testSendServiceUnavailable() {
+ String reqGuid = UUID.randomUUID().toString();
+ service.stubFor(
+ post("/api/v1/events")
+ .withHeader("Content-Type", containing("json"))
+ .willReturn(serviceUnavailable()
+ .withHeader("Content-Type", "application/json")));
+
+ RestConfig config = RestConfig.builder()
+ .url(service.url("/api/v1/events"))
+ .header("x-connection-id", "123")
+ .serializer(new JsonSerializer())
+ .marshaler(new JsonWire()).build();
+
+ RaccoonClient restClient = RaccoonClientFactory.getRestClient(config);
+
+ PageEventProto.PageEvent pageEvent = getPageEvent(reqGuid);
+
+ Response response = restClient.send(
+ new Event[] {
+ new Event("page", pageEvent)
+ });
+
+ Assert.assertFalse(response.isSuccess());
+ Assert.assertNull(response.getData());
+ Assert.assertNotNull(response.getErrorMessage());
+ Assert.assertNotNull(response.getReqGuid());
+ }
+
+ private static PageEventProto.PageEvent getPageEvent(String reqGuid) {
+ return PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(reqGuid)
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+ }
+
+ private static String getJsonResponse(String reqGuid) throws Exception {
+ HashMap data = new HashMap<>();
+ data.put("req_guid", reqGuid);
+
+ SendEventResponse sendEventResponse = SendEventResponse.newBuilder()
+ .setStatus(io.odpf.proton.raccoon.Status.STATUS_SUCCESS)
+ .setCode(io.odpf.proton.raccoon.Code.CODE_OK)
+ .setSentTime(TimeUnit.DAYS.toDays(1))
+ .putAllData(data)
+ .build();
+
+ return JsonFormat.printer()
+ .omittingInsignificantWhitespace()
+ .preservingProtoFieldNames()
+ .print(sendEventResponse);
+ }
+
+ private static byte[] getProtoResponse(String reqGuid) {
+ HashMap data = new HashMap<>();
+ data.put("req_guid", reqGuid);
+
+ SendEventResponse sendEventResponse = SendEventResponse.newBuilder()
+ .setStatus(io.odpf.proton.raccoon.Status.STATUS_SUCCESS)
+ .setCode(io.odpf.proton.raccoon.Code.CODE_OK)
+ .setSentTime(TimeUnit.DAYS.toDays(1))
+ .putAllData(data)
+ .build();
+
+ return sendEventResponse.toByteArray();
+ }
+}
diff --git a/clients/java/src/test/java/io/odpf/raccoon/serializer/JsonSerializerTest.java b/clients/java/src/test/java/io/odpf/raccoon/serializer/JsonSerializerTest.java
new file mode 100644
index 00000000..7f7ab350
--- /dev/null
+++ b/clients/java/src/test/java/io/odpf/raccoon/serializer/JsonSerializerTest.java
@@ -0,0 +1,37 @@
+package io.odpf.raccoon.serializer;
+
+import com.google.protobuf.Timestamp;
+import com.google.protobuf.util.JsonFormat;
+
+import sample.PageEventProto;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.UUID;
+
+public class JsonSerializerTest {
+
+ @Test
+ public void testSerialize() throws Exception {
+ // Arrange
+ Serializer serializer = new JsonSerializer();
+
+ // Act
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ byte[] actualBytes = serializer.serialize(pageEvent);
+
+ PageEventProto.PageEvent.Builder builder = PageEventProto.PageEvent.newBuilder();
+ JsonFormat.parser().merge(new String(actualBytes), builder);
+ PageEventProto.PageEvent actual = builder.build();
+
+ // Assert
+ Assert.assertEquals(pageEvent.getEventGuid(), actual.getEventGuid());
+ Assert.assertEquals(pageEvent.getEventName(), actual.getEventName());
+ }
+}
diff --git a/clients/java/src/test/java/io/odpf/raccoon/serializer/ProtoSerializerTest.java b/clients/java/src/test/java/io/odpf/raccoon/serializer/ProtoSerializerTest.java
new file mode 100644
index 00000000..e0e33130
--- /dev/null
+++ b/clients/java/src/test/java/io/odpf/raccoon/serializer/ProtoSerializerTest.java
@@ -0,0 +1,34 @@
+package io.odpf.raccoon.serializer;
+
+import com.google.protobuf.Timestamp;
+
+import sample.PageEventProto;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.UUID;
+
+public class ProtoSerializerTest {
+
+ @Test
+ public void testSerialize() throws Exception {
+ // Arrange
+ Serializer serializer = new ProtoSerializer();
+
+ // Act
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ byte[] pageBytes = serializer.serialize(pageEvent);
+
+ PageEventProto.PageEvent actual = PageEventProto.PageEvent.parser().parseFrom(pageBytes);
+
+ // Assert
+ Assert.assertEquals(pageEvent.getEventGuid(), actual.getEventGuid());
+ Assert.assertEquals(pageEvent.getEventName(), actual.getEventName());
+ }
+}
diff --git a/clients/java/src/test/java/io/odpf/raccoon/wire/JsonWireTest.java b/clients/java/src/test/java/io/odpf/raccoon/wire/JsonWireTest.java
new file mode 100644
index 00000000..957d3376
--- /dev/null
+++ b/clients/java/src/test/java/io/odpf/raccoon/wire/JsonWireTest.java
@@ -0,0 +1,83 @@
+package io.odpf.raccoon.wire;
+
+import com.google.protobuf.Timestamp;
+import com.google.protobuf.util.JsonFormat;
+import io.odpf.proton.raccoon.Event;
+import io.odpf.proton.raccoon.SendEventRequest;
+import sample.PageEventProto;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.UUID;
+
+public class JsonWireTest {
+ private final WireMarshaler marshaler;
+
+ public JsonWireTest() {
+ this.marshaler = new JsonWire();
+ }
+
+ @Test
+ public void testMarshal() throws Exception {
+ // arrange
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ SendEventRequest sendEventRequest = SendEventRequest.newBuilder()
+ .setReqGuid(UUID.randomUUID().toString())
+ .addEvents(
+ Event.newBuilder()
+ .setType("page-event")
+ .setEventBytes(pageEvent.toByteString())
+ .build())
+ .build();
+
+ // act
+ byte[] requestBytes = this.marshaler.marshal(sendEventRequest);
+ SendEventRequest.Builder actual = SendEventRequest.newBuilder();
+ JsonFormat.parser().merge(new String(requestBytes), actual);
+
+ // assert
+ Assert.assertEquals(sendEventRequest.getReqGuid(), actual.getReqGuid());
+ Assert.assertEquals(sendEventRequest.getEventsCount(), actual.getEventsCount());
+ Assert.assertEquals(sendEventRequest.getEvents(0).getEventBytes(), actual.getEvents(0).getEventBytes());
+ }
+
+ @Test
+ public void testUnmarshal() throws Exception {
+ // arrange
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ SendEventRequest sendEventRequest = SendEventRequest.newBuilder()
+ .setReqGuid(UUID.randomUUID().toString())
+ .addEvents(
+ Event.newBuilder()
+ .setType("page-event")
+ .setEventBytes(pageEvent.toByteString())
+ .build())
+ .build();
+
+ // act
+ byte[] requestBytes = this.marshaler.marshal(sendEventRequest);
+ SendEventRequest actual = (SendEventRequest) this.marshaler.unmarshal(requestBytes,
+ SendEventRequest.newBuilder());
+
+ // assert
+ Assert.assertEquals(sendEventRequest.getReqGuid(), actual.getReqGuid());
+ Assert.assertEquals(sendEventRequest.getEventsCount(), actual.getEventsCount());
+ Assert.assertEquals(sendEventRequest.getEvents(0).getEventBytes(), actual.getEvents(0).getEventBytes());
+ }
+
+ @Test
+ public void testGetContentType() {
+ Assert.assertEquals("application/json", this.marshaler.getContentType());
+ }
+}
diff --git a/clients/java/src/test/java/io/odpf/raccoon/wire/ProtoWireTest.java b/clients/java/src/test/java/io/odpf/raccoon/wire/ProtoWireTest.java
new file mode 100644
index 00000000..07ad42bc
--- /dev/null
+++ b/clients/java/src/test/java/io/odpf/raccoon/wire/ProtoWireTest.java
@@ -0,0 +1,81 @@
+package io.odpf.raccoon.wire;
+
+import com.google.protobuf.Timestamp;
+import io.odpf.proton.raccoon.Event;
+import io.odpf.proton.raccoon.SendEventRequest;
+import sample.PageEventProto;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.UUID;
+
+public class ProtoWireTest {
+ private final WireMarshaler marshaler;
+
+ public ProtoWireTest() {
+ this.marshaler = new ProtoWire();
+ }
+
+ @Test
+ public void testMarshal() throws Exception {
+ // arrange
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ SendEventRequest sendEventRequest = SendEventRequest.newBuilder()
+ .setReqGuid(UUID.randomUUID().toString())
+ .addEvents(
+ Event.newBuilder()
+ .setType("page-event")
+ .setEventBytes(pageEvent.toByteString())
+ .build())
+ .build();
+
+ // act
+ byte[] requestBytes = this.marshaler.marshal(sendEventRequest);
+ SendEventRequest actual = SendEventRequest.parseFrom(requestBytes);
+
+ // assert
+ Assert.assertEquals(sendEventRequest.getReqGuid(), actual.getReqGuid());
+ Assert.assertEquals(sendEventRequest.getEventsCount(), actual.getEventsCount());
+ Assert.assertEquals(sendEventRequest.getEvents(0).getEventBytes(), actual.getEvents(0).getEventBytes());
+ }
+
+ @Test
+ public void testUnmarshal() throws Exception {
+ // arrange
+ PageEventProto.PageEvent pageEvent = PageEventProto.PageEvent.newBuilder()
+ .setEventGuid(UUID.randomUUID().toString())
+ .setEventName("clicked")
+ .setSentTime(Timestamp.newBuilder().build())
+ .build();
+
+ SendEventRequest sendEventRequest = SendEventRequest.newBuilder()
+ .setReqGuid(UUID.randomUUID().toString())
+ .addEvents(
+ Event.newBuilder()
+ .setType("page-event")
+ .setEventBytes(pageEvent.toByteString())
+ .build())
+ .build();
+
+ // act
+ byte[] requestBytes = this.marshaler.marshal(sendEventRequest);
+ SendEventRequest actual = (SendEventRequest) this.marshaler.unmarshal(requestBytes,
+ SendEventRequest.parser());
+
+ // assert
+ Assert.assertEquals(sendEventRequest.getReqGuid(), actual.getReqGuid());
+ Assert.assertEquals(sendEventRequest.getEventsCount(), actual.getEventsCount());
+ Assert.assertEquals(sendEventRequest.getEvents(0).getEventBytes(), actual.getEvents(0).getEventBytes());
+ }
+
+ @Test
+ public void testGetContentType() {
+ Assert.assertEquals("application/proto", this.marshaler.getContentType());
+ }
+}
diff --git a/clients/java/src/test/java/sample.proto b/clients/java/src/test/java/sample.proto
new file mode 100644
index 00000000..957771d8
--- /dev/null
+++ b/clients/java/src/test/java/sample.proto
@@ -0,0 +1,11 @@
+syntax = "proto3";
+
+import "google/protobuf/timestamp.proto";
+option java_outer_classname = "PageEventProto";
+option java_package = "sample";
+
+message PageEvent {
+ string event_guid = 1;
+ string event_name = 2;
+ google.protobuf.Timestamp sent_time = 3;
+}
\ No newline at end of file
diff --git a/clients/java/src/test/java/sample/PageEventProto.java b/clients/java/src/test/java/sample/PageEventProto.java
new file mode 100644
index 00000000..a58d0449
--- /dev/null
+++ b/clients/java/src/test/java/sample/PageEventProto.java
@@ -0,0 +1,974 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: sample.proto
+
+package sample;
+
+public final class PageEventProto {
+ private PageEventProto() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+ public interface PageEventOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:PageEvent)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The eventGuid.
+ */
+ java.lang.String getEventGuid();
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The bytes for eventGuid.
+ */
+ com.google.protobuf.ByteString
+ getEventGuidBytes();
+
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The eventName.
+ */
+ java.lang.String getEventName();
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The bytes for eventName.
+ */
+ com.google.protobuf.ByteString
+ getEventNameBytes();
+
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return Whether the sentTime field is set.
+ */
+ boolean hasSentTime();
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ com.google.protobuf.Timestamp getSentTime();
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ com.google.protobuf.TimestampOrBuilder getSentTimeOrBuilder();
+ }
+ /**
+ * Protobuf type {@code PageEvent}
+ */
+ public static final class PageEvent extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:PageEvent)
+ PageEventOrBuilder {
+ private static final long serialVersionUID = 0L;
+ // Use PageEvent.newBuilder() to construct.
+ private PageEvent(com.google.protobuf.GeneratedMessageV3.Builder builder) {
+ super(builder);
+ }
+ private PageEvent() {
+ eventGuid_ = "";
+ eventName_ = "";
+ }
+
+ @java.lang.Override
+ @SuppressWarnings({"unused"})
+ protected java.lang.Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new PageEvent();
+ }
+
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private PageEvent(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ this();
+ if (extensionRegistry == null) {
+ throw new java.lang.NullPointerException();
+ }
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ java.lang.String s = input.readStringRequireUtf8();
+
+ eventGuid_ = s;
+ break;
+ }
+ case 18: {
+ java.lang.String s = input.readStringRequireUtf8();
+
+ eventName_ = s;
+ break;
+ }
+ case 26: {
+ com.google.protobuf.Timestamp.Builder subBuilder = null;
+ if (sentTime_ != null) {
+ subBuilder = sentTime_.toBuilder();
+ }
+ sentTime_ = input.readMessage(com.google.protobuf.Timestamp.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(sentTime_);
+ sentTime_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
+ default: {
+ if (!parseUnknownField(
+ input, unknownFields, extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e).setUnfinishedMessage(this);
+ } finally {
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return sample.PageEventProto.internal_static_PageEvent_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return sample.PageEventProto.internal_static_PageEvent_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ sample.PageEventProto.PageEvent.class, sample.PageEventProto.PageEvent.Builder.class);
+ }
+
+ public static final int EVENT_GUID_FIELD_NUMBER = 1;
+ private volatile java.lang.Object eventGuid_;
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The eventGuid.
+ */
+ @java.lang.Override
+ public java.lang.String getEventGuid() {
+ java.lang.Object ref = eventGuid_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventGuid_ = s;
+ return s;
+ }
+ }
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The bytes for eventGuid.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getEventGuidBytes() {
+ java.lang.Object ref = eventGuid_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventGuid_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int EVENT_NAME_FIELD_NUMBER = 2;
+ private volatile java.lang.Object eventName_;
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The eventName.
+ */
+ @java.lang.Override
+ public java.lang.String getEventName() {
+ java.lang.Object ref = eventName_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventName_ = s;
+ return s;
+ }
+ }
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The bytes for eventName.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getEventNameBytes() {
+ java.lang.Object ref = eventName_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SENT_TIME_FIELD_NUMBER = 3;
+ private com.google.protobuf.Timestamp sentTime_;
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return Whether the sentTime field is set.
+ */
+ @java.lang.Override
+ public boolean hasSentTime() {
+ return sentTime_ != null;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ @java.lang.Override
+ public com.google.protobuf.Timestamp getSentTime() {
+ return sentTime_ == null ? com.google.protobuf.Timestamp.getDefaultInstance() : sentTime_;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ @java.lang.Override
+ public com.google.protobuf.TimestampOrBuilder getSentTimeOrBuilder() {
+ return getSentTime();
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(eventGuid_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 1, eventGuid_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(eventName_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 2, eventName_);
+ }
+ if (sentTime_ != null) {
+ output.writeMessage(3, getSentTime());
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(eventGuid_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, eventGuid_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(eventName_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, eventName_);
+ }
+ if (sentTime_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(3, getSentTime());
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof sample.PageEventProto.PageEvent)) {
+ return super.equals(obj);
+ }
+ sample.PageEventProto.PageEvent other = (sample.PageEventProto.PageEvent) obj;
+
+ if (!getEventGuid()
+ .equals(other.getEventGuid())) return false;
+ if (!getEventName()
+ .equals(other.getEventName())) return false;
+ if (hasSentTime() != other.hasSentTime()) return false;
+ if (hasSentTime()) {
+ if (!getSentTime()
+ .equals(other.getSentTime())) return false;
+ }
+ if (!unknownFields.equals(other.unknownFields)) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + EVENT_GUID_FIELD_NUMBER;
+ hash = (53 * hash) + getEventGuid().hashCode();
+ hash = (37 * hash) + EVENT_NAME_FIELD_NUMBER;
+ hash = (53 * hash) + getEventName().hashCode();
+ if (hasSentTime()) {
+ hash = (37 * hash) + SENT_TIME_FIELD_NUMBER;
+ hash = (53 * hash) + getSentTime().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static sample.PageEventProto.PageEvent parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static sample.PageEventProto.PageEvent parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static sample.PageEventProto.PageEvent parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static sample.PageEventProto.PageEvent parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(sample.PageEventProto.PageEvent prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code PageEvent}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:PageEvent)
+ sample.PageEventProto.PageEventOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return sample.PageEventProto.internal_static_PageEvent_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return sample.PageEventProto.internal_static_PageEvent_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ sample.PageEventProto.PageEvent.class, sample.PageEventProto.PageEvent.Builder.class);
+ }
+
+ // Construct using sample.PageEventProto.PageEvent.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessageV3
+ .alwaysUseFieldBuilders) {
+ }
+ }
+ @java.lang.Override
+ public Builder clear() {
+ super.clear();
+ eventGuid_ = "";
+
+ eventName_ = "";
+
+ if (sentTimeBuilder_ == null) {
+ sentTime_ = null;
+ } else {
+ sentTime_ = null;
+ sentTimeBuilder_ = null;
+ }
+ return this;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return sample.PageEventProto.internal_static_PageEvent_descriptor;
+ }
+
+ @java.lang.Override
+ public sample.PageEventProto.PageEvent getDefaultInstanceForType() {
+ return sample.PageEventProto.PageEvent.getDefaultInstance();
+ }
+
+ @java.lang.Override
+ public sample.PageEventProto.PageEvent build() {
+ sample.PageEventProto.PageEvent result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @java.lang.Override
+ public sample.PageEventProto.PageEvent buildPartial() {
+ sample.PageEventProto.PageEvent result = new sample.PageEventProto.PageEvent(this);
+ result.eventGuid_ = eventGuid_;
+ result.eventName_ = eventName_;
+ if (sentTimeBuilder_ == null) {
+ result.sentTime_ = sentTime_;
+ } else {
+ result.sentTime_ = sentTimeBuilder_.build();
+ }
+ onBuilt();
+ return result;
+ }
+
+ @java.lang.Override
+ public Builder clone() {
+ return super.clone();
+ }
+ @java.lang.Override
+ public Builder setField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.setField(field, value);
+ }
+ @java.lang.Override
+ public Builder clearField(
+ com.google.protobuf.Descriptors.FieldDescriptor field) {
+ return super.clearField(field);
+ }
+ @java.lang.Override
+ public Builder clearOneof(
+ com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+ return super.clearOneof(oneof);
+ }
+ @java.lang.Override
+ public Builder setRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ int index, java.lang.Object value) {
+ return super.setRepeatedField(field, index, value);
+ }
+ @java.lang.Override
+ public Builder addRepeatedField(
+ com.google.protobuf.Descriptors.FieldDescriptor field,
+ java.lang.Object value) {
+ return super.addRepeatedField(field, value);
+ }
+ @java.lang.Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof sample.PageEventProto.PageEvent) {
+ return mergeFrom((sample.PageEventProto.PageEvent)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(sample.PageEventProto.PageEvent other) {
+ if (other == sample.PageEventProto.PageEvent.getDefaultInstance()) return this;
+ if (!other.getEventGuid().isEmpty()) {
+ eventGuid_ = other.eventGuid_;
+ onChanged();
+ }
+ if (!other.getEventName().isEmpty()) {
+ eventName_ = other.eventName_;
+ onChanged();
+ }
+ if (other.hasSentTime()) {
+ mergeSentTime(other.getSentTime());
+ }
+ this.mergeUnknownFields(other.unknownFields);
+ onChanged();
+ return this;
+ }
+
+ @java.lang.Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @java.lang.Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ sample.PageEventProto.PageEvent parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (sample.PageEventProto.PageEvent) e.getUnfinishedMessage();
+ throw e.unwrapIOException();
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+
+ private java.lang.Object eventGuid_ = "";
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The eventGuid.
+ */
+ public java.lang.String getEventGuid() {
+ java.lang.Object ref = eventGuid_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventGuid_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return The bytes for eventGuid.
+ */
+ public com.google.protobuf.ByteString
+ getEventGuidBytes() {
+ java.lang.Object ref = eventGuid_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventGuid_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @param value The eventGuid to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventGuid(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ eventGuid_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @return This builder for chaining.
+ */
+ public Builder clearEventGuid() {
+
+ eventGuid_ = getDefaultInstance().getEventGuid();
+ onChanged();
+ return this;
+ }
+ /**
+ * string event_guid = 1 [json_name = "eventGuid"];
+ * @param value The bytes for eventGuid to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventGuidBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ eventGuid_ = value;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object eventName_ = "";
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The eventName.
+ */
+ public java.lang.String getEventName() {
+ java.lang.Object ref = eventName_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ eventName_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return The bytes for eventName.
+ */
+ public com.google.protobuf.ByteString
+ getEventNameBytes() {
+ java.lang.Object ref = eventName_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ eventName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @param value The eventName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventName(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ eventName_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @return This builder for chaining.
+ */
+ public Builder clearEventName() {
+
+ eventName_ = getDefaultInstance().getEventName();
+ onChanged();
+ return this;
+ }
+ /**
+ * string event_name = 2 [json_name = "eventName"];
+ * @param value The bytes for eventName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEventNameBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+
+ eventName_ = value;
+ onChanged();
+ return this;
+ }
+
+ private com.google.protobuf.Timestamp sentTime_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder> sentTimeBuilder_;
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return Whether the sentTime field is set.
+ */
+ public boolean hasSentTime() {
+ return sentTimeBuilder_ != null || sentTime_ != null;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ * @return The sentTime.
+ */
+ public com.google.protobuf.Timestamp getSentTime() {
+ if (sentTimeBuilder_ == null) {
+ return sentTime_ == null ? com.google.protobuf.Timestamp.getDefaultInstance() : sentTime_;
+ } else {
+ return sentTimeBuilder_.getMessage();
+ }
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public Builder setSentTime(com.google.protobuf.Timestamp value) {
+ if (sentTimeBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ sentTime_ = value;
+ onChanged();
+ } else {
+ sentTimeBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public Builder setSentTime(
+ com.google.protobuf.Timestamp.Builder builderForValue) {
+ if (sentTimeBuilder_ == null) {
+ sentTime_ = builderForValue.build();
+ onChanged();
+ } else {
+ sentTimeBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public Builder mergeSentTime(com.google.protobuf.Timestamp value) {
+ if (sentTimeBuilder_ == null) {
+ if (sentTime_ != null) {
+ sentTime_ =
+ com.google.protobuf.Timestamp.newBuilder(sentTime_).mergeFrom(value).buildPartial();
+ } else {
+ sentTime_ = value;
+ }
+ onChanged();
+ } else {
+ sentTimeBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public Builder clearSentTime() {
+ if (sentTimeBuilder_ == null) {
+ sentTime_ = null;
+ onChanged();
+ } else {
+ sentTime_ = null;
+ sentTimeBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public com.google.protobuf.Timestamp.Builder getSentTimeBuilder() {
+
+ onChanged();
+ return getSentTimeFieldBuilder().getBuilder();
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ public com.google.protobuf.TimestampOrBuilder getSentTimeOrBuilder() {
+ if (sentTimeBuilder_ != null) {
+ return sentTimeBuilder_.getMessageOrBuilder();
+ } else {
+ return sentTime_ == null ?
+ com.google.protobuf.Timestamp.getDefaultInstance() : sentTime_;
+ }
+ }
+ /**
+ * .google.protobuf.Timestamp sent_time = 3 [json_name = "sentTime"];
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder>
+ getSentTimeFieldBuilder() {
+ if (sentTimeBuilder_ == null) {
+ sentTimeBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ com.google.protobuf.Timestamp, com.google.protobuf.Timestamp.Builder, com.google.protobuf.TimestampOrBuilder>(
+ getSentTime(),
+ getParentForChildren(),
+ isClean());
+ sentTime_ = null;
+ }
+ return sentTimeBuilder_;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:PageEvent)
+ }
+
+ // @@protoc_insertion_point(class_scope:PageEvent)
+ private static final sample.PageEventProto.PageEvent DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new sample.PageEventProto.PageEvent();
+ }
+
+ public static sample.PageEventProto.PageEvent getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @java.lang.Override
+ public PageEvent parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new PageEvent(input, extensionRegistry);
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public sample.PageEventProto.PageEvent getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+ }
+
+ private static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_PageEvent_descriptor;
+ private static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_PageEvent_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+ private static com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+ static {
+ java.lang.String[] descriptorData = {
+ "\n\014sample.proto\032\037google/protobuf/timestam" +
+ "p.proto\"\202\001\n\tPageEvent\022\035\n\nevent_guid\030\001 \001(" +
+ "\tR\teventGuid\022\035\n\nevent_name\030\002 \001(\tR\teventN" +
+ "ame\0227\n\tsent_time\030\003 \001(\0132\032.google.protobuf" +
+ ".TimestampR\010sentTimeB\030\n\006sampleB\016PageEven" +
+ "tProtob\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[] {
+ com.google.protobuf.TimestampProto.getDescriptor(),
+ });
+ internal_static_PageEvent_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_PageEvent_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_PageEvent_descriptor,
+ new java.lang.String[] { "EventGuid", "EventName", "SentTime", });
+ com.google.protobuf.TimestampProto.getDescriptor();
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}