Versions in this module Expand all Collapse all v1 v1.0.0 Jul 6, 2024 Changes in this version + var ProviderSet = wire.NewSet(NewApp, NewLogger, NewTaskServer, NewTaskClient, NewConsumer, NewKafkaWriter, ...) + func NewKafkaReader(cfg *config.Config, logger *zap.Logger) (*kafka.Reader, func()) + func NewKafkaWriter(cfg *config.Config, logger *zap.Logger) (*kafka.Writer, func()) + func NewLogger() (*zap.Logger, func(), error) + func NewTaskClient(cfg *config.Config, logger *zap.Logger) (*asynq.Client, func()) + type App struct + func NewApp(taskServer *TaskServer, consumer *Consumer) *App + func (a *App) Start() error + type Consumer struct + func NewConsumer(logger *zap.Logger, reader *kafka.Reader, writer *kafka.Writer, ...) *Consumer + type TaskMessage struct + Body string + Headers map[string]string + Topic string + func (m *TaskMessage) ToKafkaHeaders() []kafka.Header + func (m *TaskMessage) ToKafkaMessageValue() ([]byte, error) + type TaskServer struct + func NewTaskServer(cfg *config.Config, logger *zap.Logger, writer *kafka.Writer) (*TaskServer, error)
Go to main page