offsets

Documentation

Index

• type DefaultOffsetManager
  • func (manager *DefaultOffsetManager) Construct(options OffsetManagerOptions) (err error)
  • func (manager *DefaultOffsetManager) Get(ctx context.Context, group string, topic string) (offsets Offsets, err error)
  • func (manager *DefaultOffsetManager) Name() string
  • func (manager *DefaultOffsetManager) Set(ctx context.Context, group string, offsets Offsets) (err error)
  • func (manager *DefaultOffsetManager) Shutdown(_ context.Context)
• type DefaultOffsetManagerConfig
• type Offset
• type OffsetManager
• type OffsetManagerOptions
• type Offsets

Types

type DefaultOffsetManager

type DefaultOffsetManager struct {
	// contains filtered or unexported fields
}

func (*DefaultOffsetManager) Construct

func (manager *DefaultOffsetManager) Construct(options OffsetManagerOptions) (err error)

func (*DefaultOffsetManager) Get

func (manager *DefaultOffsetManager) Get(ctx context.Context, group string, topic string) (offsets Offsets, err error)

func (*DefaultOffsetManager) Name

func (manager *DefaultOffsetManager) Name() string

func (*DefaultOffsetManager) Set

func (manager *DefaultOffsetManager) Set(ctx context.Context, group string, offsets Offsets) (err error)

func (*DefaultOffsetManager) Shutdown

func (manager *DefaultOffsetManager) Shutdown(_ context.Context)

type DefaultOffsetManagerConfig

type DefaultOffsetManagerConfig struct {
	configs.Generic
}

type Offset

type Offset struct {
	Topic       string
	Partition   int32
	At          int64
	LeaderEpoch int32
	Metadata    string
}

type OffsetManager

type OffsetManager interface {
	Name() string
	Construct(options OffsetManagerOptions) (err error)
	Get(ctx context.Context, group string, topic string) (offsets Offsets, err error)
	Set(ctx context.Context, group string, offsets Offsets) (err error)
	Shutdown(ctx context.Context)
}

type OffsetManagerOptions

type OffsetManagerOptions struct {
	Id      string
	Version versions.Version
	Log     logs.Logger
	Config  configures.Config
}

type Offsets

type Offsets []Offset