producer

type MetricsForProducer ¶

type MetricsForProducer interface {
	TotalProducedInc()
}

MetricsForProducer provides a method to increase total produced counter

type Producer ¶

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

func New(
	log *slog.Logger,
	taskSaver TaskSaver,
	taskPublisher TaskPublisher,
	stateProvider StateProvider,
	metrics MetricsForProducer,
) *Producer

func (producer *Producer) Produce(ctx context.Context) (int, error)

type StateProvider ¶

type StateProvider interface {
	State(ctx context.Context, id int) (string, error)
}

StateProvider returns task state for a provided task id

type TaskPublisher ¶

type TaskPublisher interface {
	Publish(ctx context.Context, taskId int, taskType int, taskValue int) error
}

TaskPublisher publishes a message with taskId, taskType and taskValue

type TaskSaver ¶

type TaskSaver interface {
	SaveTask(ctx context.Context, taskType int, taskValue int) (int, error)
}

TaskSaver creates a task record with provided task type and task value, returns id