task

Documentation

Index

• type OrderConsumer
  • func NewOrderConsumer(kafkaClient *mq.KafkaClient, orderSrv service.OrderService) *OrderConsumer
  • func (c *OrderConsumer) Run(ctx context.Context) error
• type OrderEvent
• type TaskManager
  • func NewTaskManager(kafkaClientOrder *mq.KafkaClient, orderSrv service.OrderService) *TaskManager
  • func (tm *TaskManager) Start(ctx context.Context) error

Types

type OrderConsumer

type OrderConsumer struct {
	KafkaClient *mq.KafkaClient
	OrderSrv    service.OrderService
}

func NewOrderConsumer

func NewOrderConsumer(kafkaClient *mq.KafkaClient, orderSrv service.OrderService) *OrderConsumer

func (*OrderConsumer) Run

func (c *OrderConsumer) Run(ctx context.Context) error

type OrderEvent

type OrderEvent struct {
	OrderID string `json:"orderID"`
	Status  string `json:"status"`
}

type TaskManager

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

func NewTaskManager

func NewTaskManager(
	kafkaClientOrder *mq.KafkaClient,
	orderSrv service.OrderService,
) *TaskManager

func (*TaskManager) Start

func (tm *TaskManager) Start(ctx context.Context) error