Versions in this module Expand all Collapse all v0 v0.9.0 Sep 7, 2023 v0.8.0 Apr 17, 2023 Changes in this version + type SubscriptionOffset struct + func NewSubscriptionOffset(id vanus.ID, maxUACKNumber int, initOffsets info.ListOffsetInfo) *SubscriptionOffset + func (offset *SubscriptionOffset) Close() + func (offset *SubscriptionOffset) EventCommit(info info.OffsetInfo) + func (offset *SubscriptionOffset) EventReceive(info info.OffsetInfo) + func (offset *SubscriptionOffset) GetCommit() info.ListOffsetInfo
Go to main page