listener

package

v0.0.1 Latest Latest Go to latest Published: Aug 25, 2025 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(c context.Context, cfg config.KafkaConfig, di *dipkg.DI) *Listener

func (listener *Listener) Close() error

func (listener *Listener) Listen() error

func (listener *Listener) RegisterHandler(name string, handler events.Handler)

RegisterHandler adds a handler to a topic/event name