Versions in this module Expand all Collapse all v1 v1.7.0 Sep 19, 2018 Changes in this version + type ConcurrentList struct + type Manager struct + func NewManager(minOffset int64, markOffset MarkOffset, partition int32, ...) *Manager + func (m *Manager) Close() error + func (m *Manager) MarkOffset(offset int64) + func (m *Manager) Start() + type MarkOffset func(offset int64)