Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SubscriptionOffset ¶
type SubscriptionOffset struct {
// contains filtered or unexported fields
}
func NewSubscriptionOffset ¶
func NewSubscriptionOffset(id vanus.ID, maxUACKNumber int, initOffsets info.ListOffsetInfo) *SubscriptionOffset
func (*SubscriptionOffset) Close ¶
func (offset *SubscriptionOffset) Close()
func (*SubscriptionOffset) EventCommit ¶
func (offset *SubscriptionOffset) EventCommit(info info.OffsetInfo)
func (*SubscriptionOffset) EventReceive ¶
func (offset *SubscriptionOffset) EventReceive(info info.OffsetInfo)
func (*SubscriptionOffset) GetCommit ¶
func (offset *SubscriptionOffset) GetCommit() info.ListOffsetInfo
Source Files
Click to show internal directories.
Click to hide internal directories.