tasker

type AttemptInf interface {
	FindPrevAttempts(ctx context.Context, taskId string) ([]TaskAttempt, error)
	CreateNewAttempt(ctx context.Context, att TaskAttempt) error
	UpdateAttemptStatus(ctx context.Context, att TaskAttempt, status TaskStatus, msg string) error
}

type CleanupFunc func()

type CommitterInf interface {
	CommitMessages(ctx context.Context, msgs ...kafka.Message) error
}

type ErrorFn func(ctx context.Context, kMsg kafka.Message) error

type ExecutionInf interface {
	Execute(ctx context.Context, taskId string, attemptId int, prevAttempts []TaskAttempt, taskDetails any) (bool, string, error)
}

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

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

type MultiTaskerConfig struct {
	Reader          *kafka.Reader
	PartFn          TaskIdPartIdTaskDetailsFn
	ProcessFn       ProcessFn
	ErrorHandler    ErrorFn
	NumTasksPerPart int
}

type NoopCommitter struct {
}

type ProcessFn func(ctx context.Context, kMsg kafka.Message) (bool, error)

type SimpleCommitter struct {
	Reader *kafka.Reader
}

type TaskAttempt struct {
	TaskId    string     `json:"taskId,omitempty"`
	AttemptId int        `json:"attemptId,omitempty"`
	TimeMs    int64      `json:"timeMs,omitempty"`
	Status    TaskStatus `json:"status,omitempty"`
	Msg       string     `json:"msg,omitempty"`
}

type TaskIdPartIdTaskDetailsFn func(ctx context.Context, kMsg kafka.Message) (string, string, any)

type TaskStatus int