middleware

type AuthenticationMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

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

type CacheEntry struct {
	Response  *MiddlewareResponse
	ExpiresAt time.Time
}

type CacheMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type CircuitBreakerMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type DynamicPromptMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

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

type Handler func(ctx context.Context, request *MiddlewareRequest) (*MiddlewareResponse, error)

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

type LoggingMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type Middleware interface {
	// Name returns the middleware name for identification
	Name() string

	// OnBefore is called before the main execution
	// It can modify the request or short-circuit the chain by returning an error
	OnBefore(ctx context.Context, request *MiddlewareRequest) (*MiddlewareRequest, error)

	// OnAfter is called after the main execution
	// It can modify the response or handle errors
	OnAfter(ctx context.Context, response *MiddlewareResponse) (*MiddlewareResponse, error)

	// OnError is called when an error occurs during execution
	// It can handle, wrap, or suppress the error
	OnError(ctx context.Context, err error) error
}

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

type MiddlewareFunc struct {
	*BaseMiddleware
	BeforeFunc func(ctx context.Context, request *MiddlewareRequest) (*MiddlewareRequest, error)
	AfterFunc  func(ctx context.Context, response *MiddlewareResponse) (*MiddlewareResponse, error)
	ErrorFunc  func(ctx context.Context, err error) error
}

type MiddlewareRequest struct {
	// Input is the original input to the agent/tool
	Input interface{} `json:"input"`

	// State is the current agent state
	State state.State `json:"-"`

	// Runtime provides access to the execution environment
	Runtime interface{} `json:"-"`

	// Metadata holds additional request information
	Metadata map[string]interface{} `json:"metadata"`

	// Headers contains request headers (for HTTP-like semantics)
	Headers map[string]string `json:"headers"`

	// Timestamp is when the request was created
	Timestamp time.Time `json:"timestamp"`
}

type MiddlewareResponse struct {
	// Output is the result from the agent/tool
	Output interface{} `json:"output"`

	// State is the updated agent state
	State state.State `json:"-"`

	// Metadata holds additional response information
	Metadata map[string]interface{} `json:"metadata"`

	// Headers contains response headers
	Headers map[string]string `json:"headers"`

	// Duration is the execution time
	Duration time.Duration `json:"duration"`

	// TokenUsage holds LLM token usage statistics
	TokenUsage *interfaces.TokenUsage `json:"token_usage,omitempty"`

	// Error holds any error that occurred
	Error error `json:"-"`
}

type RandomDelayMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type RateLimiterMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type RetryMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type TimingMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type ToolSelectorMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type TransformMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}

type ValidationMiddleware struct {
	*BaseMiddleware
	// contains filtered or unexported fields
}