client

type Client[T meta.Resource] struct {
	// contains filtered or unexported fields
}

type Options[T meta.Resource] struct {
	EventCh        <-chan *informer.Event[T]
	CancelWatch    context.CancelFunc
	Stream         sender.Interface
	Namespace      string
	KubeClient     client.Client
	ProcessSecrets func(context.Context, *T, string, client.Client) error
	// Filter, when set, drops any event for which it returns false before it is
	// enqueued or streamed. Used to forward only the resources that belong to the
	// connecting app.
	Filter func(T) bool
}