plugins

type ClusterGeneratorPlugin interface {
	TranslatorPlugin
	GeneratedClusters(params *ClusterGeneratorPluginParams) ([]*envoyapi.Cluster, error)
}

type ClusterGeneratorPluginParams struct{}

type Dependencies struct {
	SecretRefs []string
	FileRefs   []string
}

type EndpointDiscoveryPlugin interface {
	UpstreamPlugin
	SetupEndpointDiscovery() (endpointdiscovery.Interface, error)
}

type EnvoyNameForUpstream func(upstreamName string) string

type FunctionPlugin interface {
	UpstreamPlugin
	// if the FunctionSpec does not belong to this plugin, return nil, nil
	// if the FunctionSpec belongs to this plugin but is not valid, return nil, err
	// if the FunctionSpec belongs to this plugin and is valid, return *Struct, nil
	ParseFunctionSpec(params *FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
}

type FunctionPluginParams struct {
	UpstreamType string
	ServiceType  string
}

type HttpFilterPlugin interface {
	TranslatorPlugin
	HttpFilters(params *HttpFilterPluginParams) []StagedHttpFilter
}

type HttpFilterPluginParams struct {
	Listener *v1.Listener
}

type ListenerFilterPlugin interface {
	TranslatorPlugin
	ListenerFilters(params *ListenerFilterPluginParams, in *v1.Listener) ([]StagedListenerFilter, error)
}

type ListenerFilterPluginParams struct {
	EnvoyNameForUpstream EnvoyNameForUpstream
	Config               *v1.Config
}

type PluginWithDependencies interface {
	TranslatorPlugin
	GetDependencies(cfg *v1.Config) *Dependencies
}

type RoutePlugin interface {
	TranslatorPlugin
	ProcessRoute(params *RoutePluginParams, in *v1.Route, out *envoyroute.Route) error
}

type RoutePluginParams struct {
	EnvoyNameForUpstream EnvoyNameForUpstream
	// some route plugins need to know about the upstream(s) they route to
	Upstreams []*v1.Upstream
}

type Stage int

type StagedHttpFilter struct {
	HttpFilter *envoyhttp.HttpFilter
	Stage      Stage
}

type StagedListenerFilter struct {
	ListenerFilter envoylistener.Filter
	Stage          Stage
}

type TranslatorPlugin interface {
	Init(options bootstrap.Options) error
}

type UpstreamPlugin interface {
	TranslatorPlugin
	ProcessUpstream(params *UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
}

type UpstreamPluginParams struct {
	EnvoyNameForUpstream EnvoyNameForUpstream
	Secrets              secretwatcher.SecretMap
	Files                filewatcher.Files
}

type XdsCallbacks []server.Callbacks

type XdsPlugin interface {
	Callbacks() server.Callbacks
}