core

Documentation

Index

• Variables
• 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
  • func NewApp(taskServer *TaskServer, consumer *Consumer) *App
  • func (a *App) Start() error
• type Consumer
  • func NewConsumer(logger *zap.Logger, reader *kafka.Reader, writer *kafka.Writer, ...) *Consumer
• type TaskMessage
  • func (m *TaskMessage) ToKafkaHeaders() []kafka.Header
  • func (m *TaskMessage) ToKafkaMessageValue() ([]byte, error)
• type TaskServer
  • func NewTaskServer(cfg *config.Config, logger *zap.Logger, writer *kafka.Writer) (*TaskServer, error)

Variables

var ProviderSet = wire.NewSet(
	NewApp,
	NewLogger,
	NewTaskServer,
	NewTaskClient,
	NewConsumer,
	NewKafkaWriter,
	NewKafkaReader,
)

Functions

func NewKafkaReader

func NewKafkaReader(cfg *config.Config, logger *zap.Logger) (*kafka.Reader, func())

func NewKafkaWriter

func NewKafkaWriter(cfg *config.Config, logger *zap.Logger) (*kafka.Writer, func())

func NewLogger

func NewLogger() (*zap.Logger, func(), error)

func NewTaskClient

func NewTaskClient(cfg *config.Config, logger *zap.Logger) (*asynq.Client, func())

Types

type App

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

func NewApp

func NewApp(
	taskServer *TaskServer,
	consumer *Consumer,
) *App

func (*App) Start

func (a *App) Start() error

type Consumer

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

func NewConsumer

func NewConsumer(
	logger *zap.Logger,
	reader *kafka.Reader,
	writer *kafka.Writer,
	client *asynq.Client,
) *Consumer

type TaskMessage

type TaskMessage struct {
	Topic   string
	Body    string
	Headers map[string]string
}

func (*TaskMessage) ToKafkaHeaders

func (m *TaskMessage) ToKafkaHeaders() []kafka.Header

func (*TaskMessage) ToKafkaMessageValue

func (m *TaskMessage) ToKafkaMessageValue() ([]byte, error)

type TaskServer

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

func NewTaskServer

func NewTaskServer(
	cfg *config.Config,
	logger *zap.Logger,
	writer *kafka.Writer,
) (*TaskServer, error)