plugin

type BaseCommit func(http.ResponseWriter, *base.ResponseState)

type Binding struct {
	Plugin      Plugin
	Descriptor  Descriptor
	Priority    int
	Scope       Scope
	Provenance  ResourceProvenance
	InstanceKey InstanceKey
	// contains filtered or unexported fields
}

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

type CompressionOfferPlugin interface {
	RegisterCompressionOffers(*http.Request, *compression.State) []compression.Offer
	WrapCompression(
		http.ResponseWriter,
		*http.Request,
		*compression.State,
		compression.Decision,
	) (http.ResponseWriter, error)
}

type CompressionSet uint8

type ConsumerBindingResolver func(*http.Request) (ConsumerResolution, error)

type ConsumerCacheKey struct {
	ConsumerID     string
	ConsumerDigest [32]byte
	GroupID        string
	GroupDigest    [32]byte
	RouteID        string
	ServiceID      string
}

type ConsumerIdentity struct {
	Username   string
	GroupID    string
	AuthSource string
}

type ConsumerResolution struct {
	Bindings          []Binding
	OverrideFactories []string
	Request           *http.Request
	CacheKey          ConsumerCacheKey
	Identity          ConsumerIdentity
	Resolved          bool
}

type Definition struct {
	Factory             string
	Domain              Domain
	Phases              []Phase
	Scopes              []Scope
	InstanceScope       InstanceScope
	PreAuthentication   bool
	PreferRoute         bool
	ConditionalTerminal bool
}

type Descriptor struct {
	Factory        string
	Implementation string
	Phases         []Phase
	Priority       int
	Scopes         []Scope
	InstanceScope  InstanceScope
	// contains filtered or unexported fields
}

type Domain uint8

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

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

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

type FinalResponseCommitter interface {
	CommitFinalResponse(http.ResponseWriter, *http.Request, *base.ResponseState, BaseCommit)
}

type FinalizerKind uint8

type GenerationOwnerKind uint8

type InstanceIdentityInput struct {
	PluginConfig      any    `json:"plugin_config"`
	Filter            any    `json:"filter,omitempty"`
	ErrorResponse     any    `json:"error_response,omitempty"`
	CompositePosition string `json:"composite_position,omitempty"`
}

type InstanceKey struct {
	Factory      string
	Generation   uint64
	Scope        Scope
	Owner        ResourceProvenance
	ConfigDigest [32]byte
}

type InstanceScope string

type LogBinding struct {
	Factory    string
	Plugin     Plugin
	Priority   int
	Scope      Scope
	Provenance ResourceProvenance
	Policy     base.LogCapturePolicy
	// contains filtered or unexported fields
}

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

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

type PanicError struct {
	Factory string
	Phase   Phase
	Value   any
	Stack   []byte
}

type Phase string

type Plugin interface {
	Init() error
	PostInit() error
	Handler(next http.Handler) http.Handler
	Config() any
	GetSchema() string
	GetMetadataSchema() string
	GetPriority() int
	GetName() string
}

type PostResolutionHook func(*http.Request, EffectiveBindingSet) (*http.Request, error)

type ProtocolKind string

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

type RequestStage uint8

type ResolvedResponsePhases struct {
	Owners            []ResponseOwnerKind
	CompressionOffers CompressionSet
	ExclusiveProtocol ProtocolKind
}

type ResourceKind string

type ResourceProvenance struct {
	Kind ResourceKind
	ID   string
}

type ResponseBinding struct {
	Plugin     Plugin
	Descriptor Descriptor
	Scope      Scope
	Provenance ResourceProvenance
	Phases     ResponsePhaseMask
	// contains filtered or unexported fields
}

type ResponseCapability struct {
	HeaderFilter           bool
	BufferedBodyFilter     bool
	StreamingBodyFilter    bool
	StreamingResponseOwner bool
	CompressionOffer       bool
	ExclusiveProtocol      ProtocolKind
	SeparateSubsystem      bool
}

type ResponseCapabilityDescriber interface {
	DescribeResponseCapability() (ResponseCapability, error)
}

type ResponseCapabilityPlugin interface {
	ResponseCapability() ResponseCapability
}

type ResponseOwnerKind uint8

type ResponsePhaseMask uint8

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

type ResponsePlanInput struct {
	StaticBindings []Binding
	RouteTerminals []RouteTerminalCandidate
	BufferedConfig base.BufferedResponseConfig
}

type RouteTerminalCandidate struct {
	Identity   string
	Scope      Scope
	Priority   int
	Provenance ResourceProvenance
	Protocol   ProtocolKind
	Terminal   base.ExclusiveProtocolTerminal
}

type SchemaWitness struct {
	Factory     string
	Config      string
	Metadata    string
	HasConsumer bool
}

type Scope uint8

type ScopedSecretAccess = base.ScopedSecretAccess

type ScopedSecretMaterializer = base.ScopedSecretMaterializer

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

type TerminalDescriptor struct {
	Owner      TerminalOwner
	Provenance ResourceProvenance
}

type TerminalOwner uint8