Categorygithub.com/shipperizer/kilo-franzcore
package
1.2.2
Repository: https://github.com/shipperizer/kilo-franz.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
3
Files
149 SLOC

# Functions

NewReader creates a new Reader object.
NewWriter creates a new object.

# Structs

Reader is an abstraction object on top of kakfa.Reader it holds the creation config as attribute and a pointer to the reader itself it implements RefreshableInterface so that can be used by AutoRefreshX.
Writer is an abstraction object on top of kakfa.Writer it holds the creation config as attribute and a pointer to the writer itself it implements RefreshableInterface so that can be used by AutoRefreshX.

# Interfaces

ReaderConfigInterface is the core.Reader config interface, embeds config.ConfigInterface.
RefreshableInterface is implemented by core.Writer and core.Reader so that they can be refreshed by AutoRefreshX.
WriterConfigInterface is the core.Writer config interface, embeds config.ConfigInterface.