jobevent

type ConsoleReporter ¶

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

ConsoleReporter writes human-readable text - the default when a CLI is run interactively (no --job), preserving roughly today's plain-print behavior for Info, with a visible prefix for Warning/Error.

func NewConsoleReporter(w io.Writer) *ConsoleReporter

func (r *ConsoleReporter) Emit(level Level, format string, args ...any)

func (r *ConsoleReporter) EmitErr(err error)

type Level ¶

type Level string

const (
	Info    Level = "info"
	Warning Level = "warning"
	Error   Level = "error"
)

type Reporter ¶

type Reporter interface {
	Emit(level Level, format string, args ...any)
	// EmitErr emits err at Error level. A nil err is a no-op. Callers should
	// prefer this over Emit(Error, err.Error()), which mis-renders any '%'
	// in the error message since err.Error() is passed as a format string.
	EmitErr(err error)
}

type SlogReporter ¶

type SlogReporter struct{}

SlogReporter emits via log/slog - for callers already running in-process (not as a predefined-command subprocess), e.g. web.ApiNetboxWebhook calling internal/netbox.FactumSyncNetbox directly, which has no meaningful "stdout" to write JSON lines to.

func NewSlogReporter() SlogReporter

func (SlogReporter) Emit(level Level, format string, args ...any)

func (r SlogReporter) EmitErr(err error)

type StdoutReporter ¶

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

StdoutReporter writes one JSON object per line - {"level":..., "message":...} - decoded by the agent (internal/worker/hub_agent.go's streamOutput) and relayed as a structured event instead of a plain log line. Used when a CLI is invoked with --job.

func NewStdoutReporter(w io.Writer) *StdoutReporter

func (r *StdoutReporter) Emit(level Level, format string, args ...any)

func (r *StdoutReporter) EmitErr(err error)