public final class PubSubProtocol extends Object
Modifier and Type | Class and Description |
---|---|
static class |
PubSubProtocol.CloseSubscriptionRequest
Protobuf type
Hedwig.CloseSubscriptionRequest |
static interface |
PubSubProtocol.CloseSubscriptionRequestOrBuilder |
static class |
PubSubProtocol.ConsumeRequest
Protobuf type
Hedwig.ConsumeRequest |
static interface |
PubSubProtocol.ConsumeRequestOrBuilder |
static class |
PubSubProtocol.HubInfoData
Protobuf type
Hedwig.HubInfoData |
static interface |
PubSubProtocol.HubInfoDataOrBuilder |
static class |
PubSubProtocol.HubLoadData
Protobuf type
Hedwig.HubLoadData |
static interface |
PubSubProtocol.HubLoadDataOrBuilder |
static class |
PubSubProtocol.LedgerRange
Protobuf type
Hedwig.LedgerRange |
static interface |
PubSubProtocol.LedgerRangeOrBuilder |
static class |
PubSubProtocol.LedgerRanges
Protobuf type
Hedwig.LedgerRanges |
static interface |
PubSubProtocol.LedgerRangesOrBuilder |
static class |
PubSubProtocol.ManagerMeta
Protobuf type
Hedwig.ManagerMeta |
static interface |
PubSubProtocol.ManagerMetaOrBuilder |
static class |
PubSubProtocol.Map
common structure to store header or properties
|
static interface |
PubSubProtocol.MapOrBuilder |
static class |
PubSubProtocol.Message
this is the structure that will be serialized
|
static class |
PubSubProtocol.MessageHeader
message header
|
static interface |
PubSubProtocol.MessageHeaderOrBuilder |
static interface |
PubSubProtocol.MessageOrBuilder |
static class |
PubSubProtocol.MessageSeqId
Protobuf type
Hedwig.MessageSeqId |
static interface |
PubSubProtocol.MessageSeqIdOrBuilder |
static class |
PubSubProtocol.OperationType
Protobuf enum
Hedwig.OperationType |
static class |
PubSubProtocol.ProtocolVersion
Protobuf enum
Hedwig.ProtocolVersion |
static class |
PubSubProtocol.PublishRequest
Protobuf type
Hedwig.PublishRequest |
static interface |
PubSubProtocol.PublishRequestOrBuilder |
static class |
PubSubProtocol.PublishResponse
Protobuf type
Hedwig.PublishResponse |
static interface |
PubSubProtocol.PublishResponseOrBuilder |
static class |
PubSubProtocol.PubSubRequest
A PubSubRequest is just a union of the various request types, with
an enum telling us which type it is.
|
static interface |
PubSubProtocol.PubSubRequestOrBuilder |
static class |
PubSubProtocol.PubSubResponse
Protobuf type
Hedwig.PubSubResponse |
static interface |
PubSubProtocol.PubSubResponseOrBuilder |
static class |
PubSubProtocol.RegionSpecificSeqId
Protobuf type
Hedwig.RegionSpecificSeqId |
static interface |
PubSubProtocol.RegionSpecificSeqIdOrBuilder |
static class |
PubSubProtocol.ResponseBody
Protobuf type
Hedwig.ResponseBody |
static interface |
PubSubProtocol.ResponseBodyOrBuilder |
static class |
PubSubProtocol.StartDeliveryRequest
Protobuf type
Hedwig.StartDeliveryRequest |
static interface |
PubSubProtocol.StartDeliveryRequestOrBuilder |
static class |
PubSubProtocol.StatusCode
Protobuf enum
Hedwig.StatusCode |
static class |
PubSubProtocol.StopDeliveryRequest
Protobuf type
Hedwig.StopDeliveryRequest |
static interface |
PubSubProtocol.StopDeliveryRequestOrBuilder |
static class |
PubSubProtocol.SubscribeRequest
Protobuf type
Hedwig.SubscribeRequest |
static interface |
PubSubProtocol.SubscribeRequestOrBuilder |
static class |
PubSubProtocol.SubscribeResponse
Protobuf type
Hedwig.SubscribeResponse |
static interface |
PubSubProtocol.SubscribeResponseOrBuilder |
static class |
PubSubProtocol.SubscriptionData
Protobuf type
Hedwig.SubscriptionData |
static interface |
PubSubProtocol.SubscriptionDataOrBuilder |
static class |
PubSubProtocol.SubscriptionEvent
Identify an event happened for a subscription
|
static class |
PubSubProtocol.SubscriptionEventResponse
a response carries an event for a subscription sent to client
|
static interface |
PubSubProtocol.SubscriptionEventResponseOrBuilder |
static class |
PubSubProtocol.SubscriptionOptions
used in client only
options are stored in SubscriptionPreferences structure
|
static interface |
PubSubProtocol.SubscriptionOptionsOrBuilder |
static class |
PubSubProtocol.SubscriptionPreferences
record all preferences for a subscription,
would be serialized to be stored in meta store
|
static interface |
PubSubProtocol.SubscriptionPreferencesOrBuilder |
static class |
PubSubProtocol.SubscriptionState
Protobuf type
Hedwig.SubscriptionState |
static interface |
PubSubProtocol.SubscriptionStateOrBuilder |
static class |
PubSubProtocol.UnsubscribeRequest
Protobuf type
Hedwig.UnsubscribeRequest |
static interface |
PubSubProtocol.UnsubscribeRequestOrBuilder |
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Descriptors.FileDescriptor |
getDescriptor() |
static void |
registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) |
static void |
registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry) |
public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry)
public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry)
public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor()
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.