stats

type NoopObserver struct{}

type Observer interface {
	ValidationObserver

	// RecordRequest is called after every HTTP request completes.
	// method is uppercase (GET, POST, …), path is the route pattern (e.g.
	// "/users/{id}", not the concrete URL), statusCode is the HTTP status
	// written, duration is the total handler time including encode/decode.
	RecordRequest(method, path string, statusCode int, duration time.Duration)

	// RecordSubscribe is called after every MQTT message is fully processed
	// by a SubscribeHandler. topic is the concrete incoming topic (not a
	// template), success is false when decode or the application handler
	// failed, duration is total processing time.
	RecordSubscribe(topic string, success bool, duration time.Duration)

	// RecordPublish is called after every Publish call completes.
	// topic is the resolved publish topic (after BuildTopic if vars were
	// provided), success is false when encode failed, the broker returned an
	// error, or the context was cancelled. duration covers encode + broker
	// acknowledgement wait.
	// Note: RecordPublish is not called when BuildTopic itself fails (the
	// message never reached the encode/publish stage).
	RecordPublish(topic string, success bool, duration time.Duration)
}

type PipelineObserver interface {
	// RecordApply is called after every forge.Function*.Apply completes.
	// name is the function name, version is its version string, success is false
	// when any validation or computation step returned an error, duration is the
	// total Apply time (input validation + computation + output validation).
	RecordApply(name, version string, success bool, duration time.Duration)
}

type SecurityObserver interface {
	// RecordSecurityRejection is called when a security check rejects a request
	// or message. location is the route path (HTTP) or topic (MQTT). scheme is
	// the first declared security scheme name for the operation.
	RecordSecurityRejection(location, scheme string)
}

type ValidationObserver interface {
	// RecordValidationError is called for each field that fails codec
	// validation. location identifies the data source (e.g. "body", "query",
	// "payload", "config"), constraintName is the constraint identifier (e.g.
	// "minLen(3)", "non-negative-int", "email", "type-mismatch", "required"),
	// field is the field or parameter name from the structured error.
	RecordValidationError(location, constraintName, field string)
}