Documentation ¶
Index ¶
- type DependMgr
- func (this *DependMgr) Add(topic string, frontTopic string, opts ...Option) *DependMgr
- func (this *DependMgr) GetFrontTopicOffset(topic string) (r int64)
- func (this *DependMgr) GetTopicOffset(topic string) (r int64)
- func (this *DependMgr) MarkTopicOffset(topic string, partition int32, offset int64)
- func (this *DependMgr) MarkTopicOffsetForAllPartition(topic string, offset int64)
- func (this *DependMgr) Start()
- func (this *DependMgr) Stop()
- func (this *DependMgr) Wait(topic string, offset int64) (isTimeout bool)
- type Option
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DependMgr ¶
type DependMgr struct {
// contains filtered or unexported fields
}
func (*DependMgr) GetFrontTopicOffset ¶
func (*DependMgr) GetTopicOffset ¶ added in v0.2.11
func (*DependMgr) MarkTopicOffset ¶
func (*DependMgr) MarkTopicOffsetForAllPartition ¶ added in v0.2.11
type Option ¶ added in v0.2.8
type Option func(o *Options)
func WithCheckInterval ¶ added in v0.2.8
func WithDelayOffset ¶ added in v0.2.8
func WithTimeout ¶ added in v0.2.8
Click to show internal directories.
Click to hide internal directories.