handler

package

v0.0.28 Latest Latest Go to latest Published: Nov 14, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func NewHandler(c config.Config, wg *sync.WaitGroup, ctx context.Context) (handler *Handler, err error)

func (handler *Handler) FullSync() error

func (handler *Handler) HandleError(err error, _ *kafka.Consumer)

func (handler *Handler) HandleMessage(topic string, msg []byte, t time.Time) error

type Publisher interface {
	Publish(topic string, msg string) error
}

type TableEditMessage struct {
	Method string   `json:"method"` // "put" or "delete"
	Tables []string `json:"tables"`
}