offsets

package
Version: v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 16, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL