thttp

type AdapterConfig struct {
	MaxBodyBytes        int64
	GenerateExecutionID bool
	Methods             []string
}

type AdapterOption func(*AdapterConfig)

type FormFile struct {
	Filename    string
	ContentType string
	Bytes       []byte
}

type HTTPDecoder interface {
	FromHTTPRequest(r *http.Request) error
}

type HTTPRoute struct {
	Method string
	Path   string
}

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

type ListParams struct {
	Search string `json:"search" query:"search"`
	Limit  int    `json:"limit" query:"limit"`
	Page   int    `json:"page" query:"page"`
	Sort   string `json:"sort" query:"sort"`
}

type Option func(*Transport)

type PathID[T comparable] struct {
	ID T `json:"id"`
}

type Query[T any] struct {
	Data T
}

type RawHTTPHandler struct {
	Method  string
	Path    string
	Handler http.HandlerFunc
}

type SSERoute struct {
	Path        string
	Channel     string
	Broadcaster StreamBroadcaster
}

type StreamBroadcaster interface {
	Subscribe(channel string) (<-chan []byte, func())
	Publish(channel string, payload []byte) (delivered int, dropped int)
}

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