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 {
	// contains filtered or unexported fields
}

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. Optional kv pairs (slog attrs, typically "source", "netbox") are attached to every line so the web GUI's log window can label the originating subsystem.

func NewSlogReporter(kv ...any) SlogReporter

func (r 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)