offsets

Documentation

Index

• type Config
• type Manager
  • func NewManager(config *Config) Manager
• type MockManager
  • func (m *MockManager) Close() error
  • func (m *MockManager) GetOffsetLatest(topic string, partition int32) (offset int64, err error)
  • func (m *MockManager) GetOffsetOldest(topic string, partition int32) (offset int64, err error)
  • func (m *MockManager) OffsetValid(topic string, partition int32, offset int64) (isValid bool, err error)

Types

type Config

type Config struct {
	Config           *sarama.Config
	BootstrapServers []string
	Logger           log.Logger
}

type Manager

type Manager interface {
	OffsetValid(topic string, partition int32, offset int64) (isValid bool, err error)
	GetOffsetLatest(topic string, partition int32) (offset int64, err error)
	GetOffsetOldest(topic string, partition int32) (offset int64, err error)
	Close() error
}

func NewManager

func NewManager(config *Config) Manager

type MockManager

type MockManager struct {
	Topics *admin.Topics
}

func (*MockManager) Close

func (m *MockManager) Close() error

func (*MockManager) GetOffsetLatest

func (m *MockManager) GetOffsetLatest(topic string, partition int32) (offset int64, err error)

func (*MockManager) GetOffsetOldest

func (m *MockManager) GetOffsetOldest(topic string, partition int32) (offset int64, err error)

func (*MockManager) OffsetValid

func (m *MockManager) OffsetValid(topic string, partition int32, offset int64) (isValid bool, err error)