http

type AuthConfig struct {
	Type     string `json:"type" schema:"type:string,description:Auth type (none, bearer, basic),default:none"`
	Token    string `json:"token,omitempty" schema:"type:string,description:Bearer token,category:security"`
	Username string `json:"username,omitempty" schema:"type:string,description:Basic auth username,category:security"`
	Password string `json:"password,omitempty" schema:"type:string,description:Basic auth password,category:security"`
}

type Config struct {
	// URL is the endpoint to poll. Required. Must be absolute and
	// use the http or https scheme.
	URL string `json:"url" schema:"type:string,description:Endpoint URL to poll,required:true,category:basic"`

	// Method is the HTTP method (GET or POST). Default GET.
	Method string `json:"method,omitempty" schema:"type:string,description:HTTP method (GET or POST),default:GET,category:basic"`

	// Body is the optional request body sent with POST requests.
	// Ignored for GET.
	Body string `json:"body,omitempty" schema:"type:string,description:Request body (POST only),category:basic"`

	// Interval is the duration between consecutive polls.
	// Default 30s. Minimum 100ms to prevent runaway clients.
	Interval string `json:"interval,omitempty" schema:"type:string,description:Delay between polls,default:30s,category:basic"`

	// Timeout is the per-attempt HTTP request timeout. Retries get
	// a fresh clock — total cycle time is bounded by
	// MaxAttempts * (Timeout + MaxBackoff). Default 10s.
	Timeout string `` /* 137-byte string literal not displayed */

	// Headers is a map of additional headers to send with every
	// request. Overrides any default headers but does not override
	// the Authorization header set by Auth.
	Headers map[string]string `json:"headers,omitempty" schema:"type:object,description:Additional request headers,category:advanced"`

	// Auth configures the Authorization header.
	Auth *AuthConfig `json:"auth,omitempty" schema:"type:object,description:Authentication configuration,category:security"`

	// Retry configures retry/backoff behavior.
	Retry *RetryConfig `json:"retry,omitempty" schema:"type:object,description:Retry / backoff configuration,category:reliability"`

	// Decoder configures how response bodies are interpreted.
	Decoder *DecoderConfig `json:"decoder,omitempty" schema:"type:object,description:Response decoder configuration,category:basic"`

	// Ports configures input / output ports. Required: at least
	// one NATS or JetStream output port.
	Ports *component.PortConfig `json:"ports" schema:"type:ports,description:Port configuration,category:basic"`
}

type DecoderConfig struct {
	// Mode selects the decoder: "json" (single object per poll) or
	// "jsonl" (line-delimited; one publish per line). Default
	// "json".
	Mode string `json:"mode,omitempty" schema:"type:string,description:Decoder mode (json or jsonl),default:json"`
}

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

type InputDeps struct {
	Name            string
	Config          Config
	NATSClient      *natsclient.Client
	MetricsRegistry *metric.MetricsRegistry
	Logger          *slog.Logger
}

type RetryConfig struct {
	// MaxAttempts is the total number of attempts (1 = no retry).
	// Default 3.
	MaxAttempts int `json:"max_attempts,omitempty" schema:"type:int,description:Total attempts (1 = no retry),default:3"`

	// InitialBackoff is the first delay before retry. Default 1s.
	InitialBackoff string `json:"initial_backoff,omitempty" schema:"type:string,description:First retry delay,default:1s"`

	// MaxBackoff caps the exponential growth. Default 30s.
	MaxBackoff string `json:"max_backoff,omitempty" schema:"type:string,description:Max retry delay,default:30s"`

	// Multiplier grows the backoff exponentially. Default 2.0.
	Multiplier float64 `json:"multiplier,omitempty" schema:"type:float,description:Backoff multiplier,default:2.0"`
}