Package com.google.cloud.hadoop.util

Class GoogleCloudStorageEventBus

java.lang.Object
com.google.cloud.hadoop.util.GoogleCloudStorageEventBus
public class GoogleCloudStorageEventBus extends Object
Event Bus class

  • Constructor Details

    • GoogleCloudStorageEventBus

      public GoogleCloudStorageEventBus()

  • Method Details

    • register

      public static void register(Object obj)
      Method to register an obj to event bus
      Parameters:
      obj - to register to event bus

    • unregister

      public static void unregister(Object obj)
      Method to unregister an obj to event bus
      Parameters:
      obj - to unregister from event bus
      Throws:
      IllegalArgumentException - if the object was not previously registered.

    • onGcsRequest

      public static void onGcsRequest(GcsRequestExecutionEvent event)
      Posting Gcs request execution event i.e. request to gcs is being initiated.
      Parameters:
      event - dummy event to map to request execution type.

    • postOnException

      public static void postOnException()
      Posting Exception to invoke corresponding Subscriber method. Passing a dummy exception as EventBus has @ElementTypesAreNonnullByDefault annotation.

    • onGrpcStatus

      public static void onGrpcStatus(io.grpc.Status status)
      Posting grpc Status to invoke the corresponding Subscriber method.
      Parameters:
      status - status object of grpc response

    • postGcsJsonApiEvent

      public static void postGcsJsonApiEvent(IGcsJsonApiEvent gcsJsonApiEvent)

    • postWriteChecksumFailure

      public static void postWriteChecksumFailure()