Index (OpenCode Base Event 1.0.4 API)

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form

A

action() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns the value of the action record component.
action(Consumer) - Method in class cloud.opencode.base.event.saga.Saga.StepBuilder
addAllowedPackage(String) - Method in class cloud.opencode.base.event.security.SecureEventBus: Add an allowed package prefix 添加允许的包前缀
addInterceptor(EventInterceptor) - Method in class cloud.opencode.base.event.OpenEvent: Add an event interceptor 添加事件拦截器
addStep(SagaStep) - Method in class cloud.opencode.base.event.saga.Saga.Builder
addToWhitelist(Class) - Method in class cloud.opencode.base.event.security.SecureEventBus: Add a class to the listener whitelist 将类添加到监听器白名单
afterPublish(Event, boolean) - Method in interface cloud.opencode.base.event.interceptor.EventInterceptor: Called after an event has been dispatched to listeners 在事件分发给监听器之后调用
allowPublish(Event) - Method in class cloud.opencode.base.event.security.EventRateLimiter: Check if publishing is allowed 检查是否允许发布
Async - Annotation Interface in cloud.opencode.base.event.annotation: Async Processing Annotation 异步处理注解
asyncDispatcher(EventDispatcher) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Set the async dispatcher 设置异步分发器
AsyncDispatcher - Class in cloud.opencode.base.event.dispatcher: Asynchronous Event Dispatcher 异步事件分发器
AsyncDispatcher() - Constructor for class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Create async dispatcher with default virtual thread executor 使用默认虚拟线程执行器创建异步分发器
AsyncDispatcher(ExecutorService) - Constructor for class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Create async dispatcher with custom executor 使用自定义执行器创建异步分发器
asyncExecutor(ExecutorService) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Set the async executor 设置异步执行器
attempts() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns the value of the attempts record component.
await() - Method in class cloud.opencode.base.event.WaitableEvent: Wait for event processing to complete indefinitely 无限期等待事件处理完成
await(long) - Method in class cloud.opencode.base.event.WaitableEvent: Wait for event processing to complete 等待事件处理完成
awaitEvent(Duration) - Method in class cloud.opencode.base.event.testing.EventCaptor: Wait for at least one event to be captured 等待至少一个事件被捕获
awaitEvents(int, Duration) - Method in class cloud.opencode.base.event.testing.EventCaptor: Wait for a specific number of events to be captured 等待捕获特定数量的事件

B

beforePublish(Event) - Method in interface cloud.opencode.base.event.interceptor.EventInterceptor: Called before an event is dispatched to listeners 在事件分发给监听器之前调用
build() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor.Builder: Build a new HeartbeatMonitor instance.
build() - Method in class cloud.opencode.base.event.OpenEvent.Builder: Build the OpenEvent instance 构建OpenEvent实例
build() - Method in class cloud.opencode.base.event.saga.Saga.Builder
build() - Method in class cloud.opencode.base.event.saga.Saga.StepBuilder
builder() - Static method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Create a new builder.
builder() - Static method in class cloud.opencode.base.event.OpenEvent: Create a builder for custom configuration 创建用于自定义配置的构建器
builder() - Static method in class cloud.opencode.base.event.saga.Saga: Creates a new builder.
Builder() - Constructor for class cloud.opencode.base.event.OpenEvent.Builder

C

cancel() - Method in class cloud.opencode.base.event.Event: Cancel the event to stop further processing 取消事件以停止后续处理
cancel() - Method in class cloud.opencode.base.event.WaitableEvent
CANCELLED - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga was cancelled
checkPeriod(Duration) - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor.Builder: Set the check period (how often missed heartbeats are scanned).
clear() - Method in interface cloud.opencode.base.event.store.EventStore: Clear all stored events 清除所有存储的事件
clear() - Method in class cloud.opencode.base.event.store.InMemoryEventStore
clearAllStickyEvents() - Method in class cloud.opencode.base.event.OpenEvent: Remove all sticky events, releasing references for GC.
clearDeadLetterQueue() - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Clear dead letter queue 清除死信队列
close() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Alias for HeartbeatMonitor.stop(), implements AutoCloseable.
close() - Method in class cloud.opencode.base.event.OpenEvent: Shuts down the async executor and dispatchers, releasing resources.
close() - Method in class cloud.opencode.base.event.security.SecureEventBus: Close the secure event bus, releasing underlying resources.
close() - Method in interface cloud.opencode.base.event.Subscription: Close this subscription (delegates to unsubscribe) 关闭此订阅（委托给 unsubscribe）
cloud.opencode.base.event - module cloud.opencode.base.event: OpenCode Base Event Module OpenCode 基础事件模块
cloud.opencode.base.event - package cloud.opencode.base.event
cloud.opencode.base.event.annotation - package cloud.opencode.base.event.annotation
cloud.opencode.base.event.dispatcher - package cloud.opencode.base.event.dispatcher
cloud.opencode.base.event.exception - package cloud.opencode.base.event.exception
cloud.opencode.base.event.handler - package cloud.opencode.base.event.handler
cloud.opencode.base.event.interceptor - package cloud.opencode.base.event.interceptor
cloud.opencode.base.event.monitor - package cloud.opencode.base.event.monitor
cloud.opencode.base.event.saga - package cloud.opencode.base.event.saga
cloud.opencode.base.event.security - package cloud.opencode.base.event.security
cloud.opencode.base.event.serialization - package cloud.opencode.base.event.serialization
cloud.opencode.base.event.store - package cloud.opencode.base.event.store
cloud.opencode.base.event.testing - package cloud.opencode.base.event.testing
COMPENSATED - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga failed and compensation was executed
compensation() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns the value of the compensation record component.
compensation(Consumer) - Method in class cloud.opencode.base.event.saga.Saga.StepBuilder
complete() - Method in class cloud.opencode.base.event.WaitableEvent: Signal that event processing is complete 通知事件处理完成
COMPLETED - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga completed successfully
context() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the context record component.
count() - Method in interface cloud.opencode.base.event.store.EventStore: Get the total count of stored events 获取存储事件的总数
count() - Method in class cloud.opencode.base.event.store.InMemoryEventStore
count() - Method in class cloud.opencode.base.event.testing.EventCaptor: Get the number of captured events 获取捕获的事件数量
create() - Static method in class cloud.opencode.base.event.OpenEvent: Create a new OpenEvent instance 创建新的OpenEvent实例

D

DataEvent<T> - Class in cloud.opencode.base.event: Generic Data Event 泛型数据事件
DataEvent(T) - Constructor for class cloud.opencode.base.event.DataEvent: Create data event with payload 创建带载荷的数据事件
DataEvent(T, String) - Constructor for class cloud.opencode.base.event.DataEvent: Create data event with payload and source 创建带载荷和来源的数据事件
DeadEvent - Class in cloud.opencode.base.event: Dead Event - Wraps events that have no subscribers 死事件 - 包装没有订阅者的事件
DeadEvent(Event) - Constructor for class cloud.opencode.base.event.DeadEvent: Create a dead event wrapping the original unhandled event 创建包装原始未处理事件的死事件
deserialize(byte[], Class) - Static method in class cloud.opencode.base.event.serialization.EventSerializer: Deserializes bytes to an event.
deserializeFromString(String, Class) - Static method in class cloud.opencode.base.event.serialization.EventSerializer: Deserializes a Base64 string to an event.
dispatch(Event, List) - Method in class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Dispatch event to listeners asynchronously 异步将事件分发到监听器
dispatch(Event, List) - Method in interface cloud.opencode.base.event.dispatcher.EventDispatcher: Dispatch event to listeners 将事件分发到监听器
dispatch(Event, List) - Method in class cloud.opencode.base.event.dispatcher.SyncDispatcher: Dispatch event to listeners synchronously 同步将事件分发到监听器
dispatchAsync(Event, List) - Method in class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Dispatch event and return a future for completion 分发事件并返回完成的Future
DUPLICATE_LISTENER - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Duplicate listener - 重复注册

E

endTime() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the endTime record component.
equals(Object) - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class cloud.opencode.base.event.saga.SagaResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class cloud.opencode.base.event.saga.SagaStep: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class cloud.opencode.base.event.store.EventRecord: Indicates whether some other object is "equal to" this one.
error() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the error record component.
event() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns the value of the event record component.
event() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the event record component.
Event - Class in cloud.opencode.base.event: Event Base Class 事件基类
Event() - Constructor for class cloud.opencode.base.event.Event: Create event with no source 创建无来源的事件
Event(String) - Constructor for class cloud.opencode.base.event.Event: Create event with source 创建带来源的事件
EVENT_CANCELLED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Event cancelled - 事件被取消
EventBusMetrics - Record Class in cloud.opencode.base.event.monitor: Event Bus Metrics - Snapshot of event bus statistics 事件总线指标 - 事件总线统计快照
EventBusMetrics(long, long, long, long, int) - Constructor for record class cloud.opencode.base.event.monitor.EventBusMetrics: Creates an instance of a EventBusMetrics record class.
EventCaptor<E> - Class in cloud.opencode.base.event.testing: Event Captor - Test utility for capturing and asserting events 事件捕获器 - 用于捕获和断言事件的测试工具
EventCaptor() - Constructor for class cloud.opencode.base.event.testing.EventCaptor: Create a new event captor 创建新的事件捕获器
EventDispatcher - Interface in cloud.opencode.base.event.dispatcher: Event Dispatcher Interface 事件分发器接口
EventErrorCode - Enum Class in cloud.opencode.base.event.exception: Event Error Code Enumeration 事件错误码枚举
EventException - Exception Class in cloud.opencode.base.event.exception: Event Exception Base Class 事件异常基类
EventException(String) - Constructor for exception class cloud.opencode.base.event.exception.EventException: Create exception with message only 仅使用消息创建异常
EventException(String, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventException: Create exception with message and error code 使用消息和错误码创建异常
EventException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.exception.EventException: Create exception with message and cause 使用消息和原因创建异常
EventException(String, Throwable, Event, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventException: Create exception with all parameters 使用所有参数创建异常
EventExceptionHandler - Interface in cloud.opencode.base.event.handler: Event Exception Handler Interface 事件异常处理器接口
EventInterceptor - Interface in cloud.opencode.base.event.interceptor: Event Interceptor - Pre/post processing hook for event publishing 事件拦截器 - 事件发布的前/后处理钩子
EventListener<E> - Interface in cloud.opencode.base.event: Event Listener Interface 事件监听器接口
EventListenerException - Exception Class in cloud.opencode.base.event.exception: Event Listener Exception 事件监听器异常
EventListenerException(String) - Constructor for exception class cloud.opencode.base.event.exception.EventListenerException: Create listener exception with message 使用消息创建监听器异常
EventListenerException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.exception.EventListenerException: Create listener exception with message and cause 使用消息和原因创建监听器异常
EventListenerException(String, Throwable, Event, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventListenerException: Create listener exception with all parameters 使用所有参数创建监听器异常
EventPublishException - Exception Class in cloud.opencode.base.event.exception: Event Publish Exception 事件发布异常
EventPublishException(String) - Constructor for exception class cloud.opencode.base.event.exception.EventPublishException: Create publish exception with message 使用消息创建发布异常
EventPublishException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.exception.EventPublishException: Create publish exception with message and cause 使用消息和原因创建发布异常
EventPublishException(String, Throwable, Event, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventPublishException: Create publish exception with all parameters 使用所有参数创建发布异常
EventRateLimiter - Class in cloud.opencode.base.event.security: Event Rate Limiter 事件频率限制器
EventRateLimiter(int) - Constructor for class cloud.opencode.base.event.security.EventRateLimiter: Create rate limiter with default limit 使用默认限制创建频率限制器
EventRecord - Record Class in cloud.opencode.base.event.store: Event Record 事件记录
EventRecord(String, Event, String, Instant, String, Instant, long) - Constructor for record class cloud.opencode.base.event.store.EventRecord: Creates an instance of a EventRecord record class.
EventSecurityException - Exception Class in cloud.opencode.base.event.exception: Event Security Exception 事件安全异常
EventSecurityException(String) - Constructor for exception class cloud.opencode.base.event.exception.EventSecurityException: Create security exception with message 使用消息创建安全异常
EventSecurityException(String, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventSecurityException: Create security exception with message and error code 使用消息和错误码创建安全异常
EventSecurityException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.exception.EventSecurityException: Create security exception with message and cause 使用消息和原因创建安全异常
EventSecurityException(String, Throwable, Event, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventSecurityException: Create security exception with all parameters 使用所有参数创建安全异常
EventSerializationException(String) - Constructor for exception class cloud.opencode.base.event.serialization.EventSerializer.EventSerializationException
EventSerializationException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.serialization.EventSerializer.EventSerializationException
EventSerializer - Class in cloud.opencode.base.event.serialization: Event Serializer with Optional Serialization Module Delegation 支持可选序列化模块委托的事件序列化器
EventSerializer.EventSerializationException - Exception Class in cloud.opencode.base.event.serialization: Exception thrown when event serialization fails.
eventStore(EventStore) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Set the event store 设置事件存储
EventStore - Interface in cloud.opencode.base.event.store: Event Store Interface 事件存储接口
EventStoreException - Exception Class in cloud.opencode.base.event.exception: Event Store Exception 事件存储异常
EventStoreException(String) - Constructor for exception class cloud.opencode.base.event.exception.EventStoreException: Create store exception with message 使用消息创建存储异常
EventStoreException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.exception.EventStoreException: Create store exception with message and cause 使用消息和原因创建存储异常
EventStoreException(String, Throwable, Event, EventErrorCode) - Constructor for exception class cloud.opencode.base.event.exception.EventStoreException: Create store exception with all parameters 使用所有参数创建存储异常
eventType() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the eventType record component.
exception() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns the value of the exception record component.
exceptionHandler(EventExceptionHandler) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Set the exception handler 设置异常处理器
execute(T) - Method in class cloud.opencode.base.event.saga.Saga: Executes the saga synchronously.
executeAsync(T) - Method in class cloud.opencode.base.event.saga.Saga: Executes the saga asynchronously.

F

FAILED - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga failed (compensation may have failed too)
FailedEvent(Event, Throwable, String, int) - Constructor for record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Creates an instance of a FailedEvent record class.
failedStep() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the failedStep record component.
findAll() - Method in class cloud.opencode.base.event.store.InMemoryEventStore: Get all event records 获取所有事件记录
findById(String) - Method in interface cloud.opencode.base.event.store.EventStore: Find event record by event ID 根据事件ID查找事件记录
findById(String) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
findBySource(String) - Method in interface cloud.opencode.base.event.store.EventStore: Find event records by source 根据来源查找事件记录
findBySource(String) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
findByTimeRange(Instant, Instant) - Method in interface cloud.opencode.base.event.store.EventStore: Find event records within a time range 在时间范围内查找事件记录
findByTimeRange(Instant, Instant) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
findByType(Class) - Method in interface cloud.opencode.base.event.store.EventStore: Find all event records by event type 根据事件类型查找所有事件记录
findByType(Class) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
fromException(Throwable) - Static method in enum class cloud.opencode.base.event.exception.EventErrorCode: Get error code from exception 从异常获取错误码

G

getCapturedEvents() - Method in class cloud.opencode.base.event.testing.EventCaptor: Get all captured events 获取所有捕获的事件
getCode() - Method in enum class cloud.opencode.base.event.exception.EventErrorCode: Get error code number 获取错误码数字
getCurrentCount(Class) - Method in class cloud.opencode.base.event.security.EventRateLimiter: Get current count for an event type 获取事件类型的当前计数
getCurrentSequence() - Method in class cloud.opencode.base.event.store.InMemoryEventStore: Get the current sequence number 获取当前序列号
getData() - Method in class cloud.opencode.base.event.DataEvent: Get the data payload 获取数据载荷
getDataType() - Method in class cloud.opencode.base.event.DataEvent: Get the data type 获取数据类型
getDeadLetterQueueSize() - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Get dead letter queue size 获取死信队列大小
getDefault() - Static method in class cloud.opencode.base.event.OpenEvent: Get the default singleton instance 获取默认单例实例
getDefaultMaxPerSecond() - Method in class cloud.opencode.base.event.security.EventRateLimiter: Get the default max per second 获取默认每秒最大值
getDelay() - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Get retry delay 获取重试延迟
getDescription() - Method in enum class cloud.opencode.base.event.exception.EventErrorCode: Get error description in English 获取英文错误描述
getDescriptionCn() - Method in enum class cloud.opencode.base.event.exception.EventErrorCode: Get error description in Chinese 获取中文错误描述
getDuration() - Method in record class cloud.opencode.base.event.saga.SagaResult: Gets the execution duration.
getErrorMessage() - Method in record class cloud.opencode.base.event.saga.SagaResult: Gets the error message if any.
getEvent() - Method in exception class cloud.opencode.base.event.exception.EventException: Get the related event (if available) 获取相关事件（如果可用）
getEventBus() - Method in class cloud.opencode.base.event.security.SecureEventBus: Get the underlying event bus (CAUTION: bypasses ALL security checks) 获取底层事件总线（注意：绕过所有安全检查）
getEventErrorCode() - Method in exception class cloud.opencode.base.event.exception.EventException: Get the event error code 获取事件错误码
getEventStore() - Method in class cloud.opencode.base.event.OpenEvent: Get the event store 获取事件存储
getEventType() - Method in interface cloud.opencode.base.event.Subscription: Get the event type this subscription is for 获取此订阅的事件类型
getExecutor() - Method in class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Get the underlying executor service 获取底层执行器服务
getFirst() - Method in class cloud.opencode.base.event.testing.EventCaptor: Get the first captured event 获取第一个捕获的事件
getId() - Method in class cloud.opencode.base.event.Event: Get unique event ID 获取唯一事件ID
getLast() - Method in class cloud.opencode.base.event.testing.EventCaptor: Get the last captured event 获取最后一个捕获的事件
getLatch() - Method in class cloud.opencode.base.event.WaitableEvent: Get the countdown latch 获取倒计时锁存器
getMaxCapacity() - Method in class cloud.opencode.base.event.store.InMemoryEventStore: Get the maximum capacity 获取最大容量
getMaxRetries() - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Get max retries 获取最大重试次数
getMetrics() - Method in class cloud.opencode.base.event.OpenEvent: Get current event bus metrics snapshot 获取当前事件总线指标快照
getMissedIds() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Return the IDs of items that have missed their heartbeat (exceeded their expected interval).
getName() - Method in class cloud.opencode.base.event.saga.Saga: Gets the saga name.
getOriginalEvent() - Method in class cloud.opencode.base.event.DeadEvent: Get the original event that had no subscribers 获取没有订阅者的原始事件
getPayload() - Method in class cloud.opencode.base.event.security.SignedEvent: Get the payload data for signing 获取用于签名的负载数据
getSignature() - Method in class cloud.opencode.base.event.security.SignedEvent
getSignature() - Method in interface cloud.opencode.base.event.security.VerifiableEvent: Get the event signature 获取事件签名
getSource() - Method in class cloud.opencode.base.event.Event: Get event source 获取事件来源
getStepCount() - Method in class cloud.opencode.base.event.saga.Saga: Gets the number of steps.
getStepNames() - Method in class cloud.opencode.base.event.saga.Saga: Gets the step names.
getStickyEvent(Class) - Method in class cloud.opencode.base.event.OpenEvent: Get the last sticky event of the given type 获取指定类型的最后一个粘性事件
getTimestamp() - Method in class cloud.opencode.base.event.Event: Get event timestamp 获取事件时间戳
getWrappedEvent() - Method in class cloud.opencode.base.event.WaitableEvent: Get the wrapped event 获取被包装的事件
globalTimeout(Duration) - Method in class cloud.opencode.base.event.saga.Saga.Builder

H

handleException(Event, Throwable, String) - Method in interface cloud.opencode.base.event.handler.EventExceptionHandler: Handle an exception that occurred during event processing 处理事件处理过程中发生的异常
handleException(Event, Throwable, String) - Method in class cloud.opencode.base.event.handler.LoggingExceptionHandler: Handle exception by logging it 通过记录日志处理异常
handleException(Event, Throwable, String) - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Handle exception with retry logic 使用重试逻辑处理异常
hasCaptured() - Method in class cloud.opencode.base.event.testing.EventCaptor: Check if any events were captured 检查是否捕获了任何事件
hashCode() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns a hash code value for this object.
hashCode() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns a hash code value for this object.
hashCode() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns a hash code value for this object.
hashCode() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns a hash code value for this object.
hashCode() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns a hash code value for this object.
heartbeat(String) - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Record a heartbeat for the given item.
HeartbeatMonitor - Class in cloud.opencode.base.event.monitor: Generic heartbeat monitor that detects missed heartbeats.
HeartbeatMonitor.Builder - Class in cloud.opencode.base.event.monitor: Builder for HeartbeatMonitor.

I

id() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the id record component.
InMemoryEventStore - Class in cloud.opencode.base.event.store: In-Memory Event Store 内存事件存储
InMemoryEventStore() - Constructor for class cloud.opencode.base.event.store.InMemoryEventStore: Create in-memory event store with default capacity (10000) 使用默认容量(10000)创建内存事件存储
InMemoryEventStore(int) - Constructor for class cloud.opencode.base.event.store.InMemoryEventStore: Create in-memory event store with specified capacity 使用指定容量创建内存事件存储
interceptor(EventInterceptor) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Add an event interceptor 添加事件拦截器
INVALID_LISTENER_METHOD - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Invalid listener method - 无效的监听器方法
isActive() - Method in interface cloud.opencode.base.event.Subscription: Check if this subscription is still active 检查此订阅是否仍然活跃
isAsync() - Method in class cloud.opencode.base.event.dispatcher.AsyncDispatcher
isAsync() - Method in interface cloud.opencode.base.event.dispatcher.EventDispatcher: Check if this dispatcher supports async dispatching 检查此分发器是否支持异步分发
isAsync() - Method in class cloud.opencode.base.event.dispatcher.SyncDispatcher
isCancelled() - Method in class cloud.opencode.base.event.Event: Check if event is cancelled 检查事件是否已取消
isCancelled() - Method in class cloud.opencode.base.event.WaitableEvent
isCompensated() - Method in record class cloud.opencode.base.event.saga.SagaResult: Checks if the saga failed and was compensated.
isFailed() - Method in record class cloud.opencode.base.event.saga.SagaResult: Checks if the saga failed.
isSerializationModuleAvailable() - Static method in class cloud.opencode.base.event.serialization.EventSerializer: Checks if the Serialization module is available.
isSuccess() - Method in record class cloud.opencode.base.event.saga.SagaResult: Checks if the saga completed successfully.
isType(Class) - Method in record class cloud.opencode.base.event.store.EventRecord: Check if the event is of a specific type 检查事件是否为特定类型
isWithinTimeRange(Instant, Instant) - Method in record class cloud.opencode.base.event.store.EventRecord: Check if the event is within a time range 检查事件是否在时间范围内

L

LISTENER_ERROR - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Listener error - 监听器错误
listenerCount() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns the value of the listenerCount record component.
listenerName() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns the value of the listenerName record component.
LoggingExceptionHandler - Class in cloud.opencode.base.event.handler: Logging Exception Handler 日志异常处理器
LoggingExceptionHandler() - Constructor for class cloud.opencode.base.event.handler.LoggingExceptionHandler: Create logging handler with default ERROR level 使用默认ERROR级别创建日志处理器
LoggingExceptionHandler(System.Logger.Level) - Constructor for class cloud.opencode.base.event.handler.LoggingExceptionHandler: Create logging handler with specified level 使用指定级别创建日志处理器

M

maxRetries() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns the value of the maxRetries record component.

N

name() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns the value of the name record component.
name(String) - Method in class cloud.opencode.base.event.saga.Saga.Builder

O

of(Event, long) - Static method in record class cloud.opencode.base.event.store.EventRecord: Create event record from an event 从事件创建事件记录
of(String, Consumer) - Static method in record class cloud.opencode.base.event.saga.SagaStep: Creates a simple step with only an action.
of(String, Consumer, Consumer) - Static method in record class cloud.opencode.base.event.saga.SagaStep: Creates a step with action and compensation.
on(Class, EventListener) - Method in class cloud.opencode.base.event.OpenEvent: Register a lambda listener for an event type (legacy void return) 为事件类型注册Lambda监听器（兼容旧接口，无返回值）
on(Class, EventListener) - Method in class cloud.opencode.base.event.security.SecureEventBus: Register a lambda listener with security checks 使用安全检查注册Lambda监听器
on(Class, EventListener, boolean) - Method in class cloud.opencode.base.event.OpenEvent: Register a lambda listener with async option (legacy void return) 使用异步选项注册Lambda监听器（兼容旧接口，无返回值）
on(Class, EventListener, boolean, int) - Method in class cloud.opencode.base.event.OpenEvent: Register a lambda listener with async and priority options (legacy void return) 使用异步和优先级选项注册Lambda监听器（兼容旧接口，无返回值）
onEvent(E) - Method in interface cloud.opencode.base.event.EventListener: Handle an event 处理事件
onEvent(E) - Method in class cloud.opencode.base.event.testing.EventCaptor
onFailure(BiConsumer) - Method in class cloud.opencode.base.event.saga.Saga.Builder
onMissed(Consumer) - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor.Builder: Set the callback invoked when a heartbeat is missed.
onSuccess(Consumer) - Method in class cloud.opencode.base.event.saga.Saga.Builder
OpenEvent - Class in cloud.opencode.base.event: OpenEvent - Event Bus with dead event detection, interceptors, sticky events, and metrics 事件总线 - 支持死事件检测、拦截器、粘性事件和指标
OpenEvent.Builder - Class in cloud.opencode.base.event: Builder for OpenEvent OpenEvent构建器

P

PAUSED - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga is paused
PENDING - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga is pending execution
PERSIST_FAILED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Persist failed - 持久化失败
Priority - Annotation Interface in cloud.opencode.base.event.annotation: Priority Annotation 优先级注解
processDeadLetters(Consumer) - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Process dead letter queue 处理死信队列
publish(Event) - Method in class cloud.opencode.base.event.OpenEvent: Publish an event synchronously 同步发布事件
publish(Event) - Method in class cloud.opencode.base.event.security.SecureEventBus: Publish an event with security checks 使用安全检查发布事件
publish(T) - Method in class cloud.opencode.base.event.OpenEvent: Publish data as a DataEvent 将数据作为DataEvent发布
publish(T, String) - Method in class cloud.opencode.base.event.OpenEvent: Publish data as a DataEvent with source 将数据作为带来源的DataEvent发布
PUBLISH_FAILED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Publish failed - 发布失败
publishAndWait(Event, Duration) - Method in class cloud.opencode.base.event.OpenEvent: Publish and wait for processing to complete 发布并等待处理完成
publishAsync(Event) - Method in class cloud.opencode.base.event.OpenEvent: Publish an event asynchronously 异步发布事件
publishSticky(Event) - Method in class cloud.opencode.base.event.OpenEvent: Publish a sticky event (stored and replayed to future subscribers) 发布粘性事件（存储并重放给未来的订阅者）

R

RATE_LIMITED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Rate limited - 频率超限
register(Object) - Method in class cloud.opencode.base.event.OpenEvent: Register an object's @Subscribe methods as event listeners 将对象的@Subscribe方法注册为事件监听器
register(Object) - Method in class cloud.opencode.base.event.security.SecureEventBus: Register a subscriber with security checks 使用安全检查注册订阅者
REGISTRATION_FAILED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Registration failed - 注册失败
removeInterceptor(EventInterceptor) - Method in class cloud.opencode.base.event.OpenEvent: Remove an event interceptor 移除事件拦截器
removeStickyEvent(Class) - Method in class cloud.opencode.base.event.OpenEvent: Remove and return the sticky event of the given type 移除并返回指定类型的粘性事件
replay(Class, Consumer) - Method in interface cloud.opencode.base.event.store.EventStore: Replay events of a specific type 重放特定类型的事件
replay(Class, Consumer) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
REPLAY_FAILED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Replay failed - 重放失败
replayByTimeRange(Instant, Instant, Consumer) - Method in interface cloud.opencode.base.event.store.EventStore: Replay events within a time range 在时间范围内重放事件
replayByTimeRange(Instant, Instant, Consumer) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
reset() - Method in class cloud.opencode.base.event.security.EventRateLimiter: Reset all rate limits 重置所有频率限制
reset() - Method in class cloud.opencode.base.event.testing.EventCaptor: Reset the captor, clearing all captured events 重置捕获器，清除所有捕获的事件
reset(Class) - Method in class cloud.opencode.base.event.security.EventRateLimiter: Reset rate limit for a specific event type 重置特定事件类型的频率限制
resetMetrics() - Method in class cloud.opencode.base.event.OpenEvent: Reset all metrics counters 重置所有指标计数器
retries(int) - Method in class cloud.opencode.base.event.saga.Saga.StepBuilder
RetryExceptionHandler - Class in cloud.opencode.base.event.handler: Retry Exception Handler 重试异常处理器
RetryExceptionHandler() - Constructor for class cloud.opencode.base.event.handler.RetryExceptionHandler: Create retry handler with default settings 使用默认设置创建重试处理器
RetryExceptionHandler(int, Duration) - Constructor for class cloud.opencode.base.event.handler.RetryExceptionHandler: Create retry handler with custom settings 使用自定义设置创建重试处理器
RetryExceptionHandler.FailedEvent - Record Class in cloud.opencode.base.event.handler: Failed Event Record 失败事件记录
RUNNING - Enum constant in enum class cloud.opencode.base.event.saga.SagaStatus: Saga is currently running

S

Saga<T> - Class in cloud.opencode.base.event.saga: Saga - Distributed Transaction Orchestration Pattern Saga - 分布式事务编排模式
Saga.Builder<T> - Class in cloud.opencode.base.event.saga: Builder for Saga.
Saga.SagaTimeoutException - Exception Class in cloud.opencode.base.event.saga: Exception thrown when a saga step times out. saga 步骤超时时抛出的异常。
Saga.StepBuilder<T> - Class in cloud.opencode.base.event.saga: Builder for SagaStep.
sagaId() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the sagaId record component.
sagaName() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the sagaName record component.
SagaResult<T> - Record Class in cloud.opencode.base.event.saga: Saga Result - The result of a saga execution Saga 结果 - saga 执行的结果
SagaResult(String, String, SagaStatus, T, Instant, Instant, String, Throwable) - Constructor for record class cloud.opencode.base.event.saga.SagaResult: Creates an instance of a SagaResult record class.
SagaStatus - Enum Class in cloud.opencode.base.event.saga: Saga Status - The status of a saga execution Saga 状态 - saga 执行的状态
SagaStep<T> - Record Class in cloud.opencode.base.event.saga: Saga Step - A single step in a saga transaction Saga 步骤 - saga 事务中的单个步骤
SagaStep(String, Consumer, Consumer, Duration, int) - Constructor for record class cloud.opencode.base.event.saga.SagaStep: Creates an instance of a SagaStep record class.
SagaTimeoutException(String, Throwable) - Constructor for exception class cloud.opencode.base.event.saga.Saga.SagaTimeoutException
save(Event) - Method in interface cloud.opencode.base.event.store.EventStore: Save an event to the store 将事件保存到存储
save(Event) - Method in class cloud.opencode.base.event.store.InMemoryEventStore
SecureEventBus - Class in cloud.opencode.base.event.security: Secure Event Bus 安全事件总线
SecureEventBus() - Constructor for class cloud.opencode.base.event.security.SecureEventBus: Create secure event bus with default settings 使用默认设置创建安全事件总线
SecureEventBus(EventRateLimiter) - Constructor for class cloud.opencode.base.event.security.SecureEventBus: Create secure event bus with rate limiter 使用频率限制器创建安全事件总线
SecureEventBus(EventRateLimiter, String) - Constructor for class cloud.opencode.base.event.security.SecureEventBus: Create secure event bus with rate limiter and verification secret 使用频率限制器和验证密钥创建安全事件总线
SECURITY_VIOLATION - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Security violation - 安全违规
sequenceNumber() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the sequenceNumber record component.
serialize(T) - Static method in class cloud.opencode.base.event.serialization.EventSerializer: Serializes an event to bytes.
serializeToString(T) - Static method in class cloud.opencode.base.event.serialization.EventSerializer: Serializes an event to a Base64 string.
setEventStore(EventStore) - Method in class cloud.opencode.base.event.OpenEvent: Set the event store 设置事件存储
setExceptionHandler(EventExceptionHandler) - Method in class cloud.opencode.base.event.OpenEvent: Set the exception handler 设置异常处理器
setLimit(Class, int) - Method in class cloud.opencode.base.event.security.EventRateLimiter: Set rate limit for a specific event type 为特定事件类型设置频率限制
setRetryAction(Consumer) - Method in class cloud.opencode.base.event.handler.RetryExceptionHandler: Set the retry action 设置重试动作
shutdown() - Method in class cloud.opencode.base.event.dispatcher.AsyncDispatcher: Shutdown the dispatcher and release resources 关闭分发器并释放资源
shutdown() - Method in interface cloud.opencode.base.event.dispatcher.EventDispatcher: Shutdown the dispatcher and release resources 关闭分发器并释放资源
SignedEvent - Class in cloud.opencode.base.event.security: Signed Event Base Class 签名事件基类
SignedEvent(String) - Constructor for class cloud.opencode.base.event.security.SignedEvent: Create signed event with automatic signing 使用自动签名创建签名事件
SignedEvent(String, String) - Constructor for class cloud.opencode.base.event.security.SignedEvent: Create signed event with source and automatic signing 使用来源和自动签名创建签名事件
source() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the source record component.
start() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Start the periodic heartbeat checker.
startTime() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the startTime record component.
status() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns the value of the status record component.
step(String) - Method in class cloud.opencode.base.event.saga.Saga.Builder
stop() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Stop the periodic heartbeat checker.
STORE_ERROR - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Store error - 存储错误
storedAt() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the storedAt record component.
subscribe(Class, EventListener) - Method in class cloud.opencode.base.event.OpenEvent: Subscribe a listener and return a Subscription handle 订阅监听器并返回订阅句柄
subscribe(Class, EventListener, Predicate) - Method in class cloud.opencode.base.event.OpenEvent: Subscribe a listener with a filter predicate 使用过滤谓词订阅监听器
subscribe(Class, EventListener, Predicate, boolean, int) - Method in class cloud.opencode.base.event.OpenEvent: Subscribe a listener with full configuration 使用完整配置订阅监听器
Subscribe - Annotation Interface in cloud.opencode.base.event.annotation: Subscribe Annotation 订阅注解
Subscription - Interface in cloud.opencode.base.event: Subscription Handle - Represents an active event subscription 订阅句柄 - 表示一个活跃的事件订阅
syncDispatcher(EventDispatcher) - Method in class cloud.opencode.base.event.OpenEvent.Builder: Set the sync dispatcher 设置同步分发器
SyncDispatcher - Class in cloud.opencode.base.event.dispatcher: Synchronous Event Dispatcher 同步事件分发器
SyncDispatcher() - Constructor for class cloud.opencode.base.event.dispatcher.SyncDispatcher: Create sync dispatcher with default settings 使用默认设置创建同步分发器
SyncDispatcher(boolean) - Constructor for class cloud.opencode.base.event.dispatcher.SyncDispatcher: Create sync dispatcher with error handling configuration 使用错误处理配置创建同步分发器

T

timeout() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns the value of the timeout record component.
timeout(Duration) - Method in class cloud.opencode.base.event.saga.Saga.StepBuilder
TIMEOUT - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Timeout - 超时
timestamp() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns the value of the timestamp record component.
toString() - Method in class cloud.opencode.base.event.DataEvent
toString() - Method in class cloud.opencode.base.event.DeadEvent
toString() - Method in class cloud.opencode.base.event.Event
toString() - Method in record class cloud.opencode.base.event.handler.RetryExceptionHandler.FailedEvent: Returns a string representation of this record class.
toString() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns a string representation of this record class.
toString() - Method in record class cloud.opencode.base.event.saga.SagaResult: Returns a string representation of this record class.
toString() - Method in record class cloud.opencode.base.event.saga.SagaStep: Returns a string representation of this record class.
toString() - Method in record class cloud.opencode.base.event.store.EventRecord: Returns a string representation of this record class.
toString() - Method in class cloud.opencode.base.event.WaitableEvent
totalDeadEvents() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns the value of the totalDeadEvents record component.
totalDelivered() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns the value of the totalDelivered record component.
totalErrors() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns the value of the totalErrors record component.
totalPublished() - Method in record class cloud.opencode.base.event.monitor.EventBusMetrics: Returns the value of the totalPublished record component.

U

UNKNOWN - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Unknown error - 未知错误
unregister(Object) - Method in class cloud.opencode.base.event.OpenEvent: Unregister all listeners from a subscriber 从订阅者注销所有监听器
unregister(Object) - Method in class cloud.opencode.base.event.security.SecureEventBus: Unregister a subscriber 注销订阅者
unsubscribe() - Method in interface cloud.opencode.base.event.Subscription: Unsubscribe this listener from the event bus 从事件总线取消订阅此监听器
unwatch(String) - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Stop watching the given item.
Usage | 用法: - Section in class cloud.opencode.base.event.monitor.HeartbeatMonitor

V

value() - Element in annotation interface cloud.opencode.base.event.annotation.Priority: The priority value (higher = earlier execution) 优先级值（越高越先执行）
valueOf(String) - Static method in enum class cloud.opencode.base.event.exception.EventErrorCode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class cloud.opencode.base.event.saga.SagaStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class cloud.opencode.base.event.exception.EventErrorCode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class cloud.opencode.base.event.saga.SagaStatus: Returns an array containing the constants of this enum class, in the order they are declared.
VerifiableEvent - Interface in cloud.opencode.base.event.security: Verifiable Event Interface 可验证事件接口
VERIFICATION_FAILED - Enum constant in enum class cloud.opencode.base.event.exception.EventErrorCode: Verification failed - 验证失败
verify(String) - Method in class cloud.opencode.base.event.security.SignedEvent
verify(String) - Method in interface cloud.opencode.base.event.security.VerifiableEvent: Verify the event signature 验证事件签名

W

WaitableEvent - Class in cloud.opencode.base.event: Waitable Event Wrapper 可等待事件包装器
WaitableEvent(Event) - Constructor for class cloud.opencode.base.event.WaitableEvent: Create waitable event with new latch 创建带新锁存器的可等待事件
WaitableEvent(Event, CountDownLatch) - Constructor for class cloud.opencode.base.event.WaitableEvent: Create waitable event wrapper 创建可等待事件包装器
watch(String, Duration) - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Register an item to be watched for missed heartbeats.
watchedCount() - Method in class cloud.opencode.base.event.monitor.HeartbeatMonitor: Return the number of items currently being watched.

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form