Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var VerbosityLevelOptions = map[VerbosityLevel][]string{ InfoVerbosityLevel: {"", "i", "info"}, DebugVerbosityLevel: {"d", "debug"}, TraceVerbosityLevel: {"t", "trace"}, }
Functions ¶
func InjectForwardPool ¶
func InjectForwardPool(r *http.Request, fwd *ForwardPool) *http.Request
func NewCommand ¶
Types ¶
type ForwardConnection ¶
type ForwardConnection struct {
Conn httpstream.Connection
StartTime time.Time
Namespace string
ServiceName string
ServicePort string
PodUID string
PodName string
PodPort int
}
type ForwardPool ¶
type ForwardPool struct {
Client *kubernetes.Clientset
Config *rest.Config
Logger *slog.Logger
// contains filtered or unexported fields
}
func ExtractForwardPool ¶
func ExtractForwardPool(r *http.Request) *ForwardPool
func (*ForwardPool) Close ¶
func (fwd *ForwardPool) Close()
func (*ForwardPool) ConnectionFor ¶
func (fwd *ForwardPool) ConnectionFor(ctx context.Context, hostport string) (*ForwardConnection, error)
ConnectionFor finds an existing connection to a pod, or creates it if one didn't already exist.
type Options ¶
type Options struct {
genericiooptions.IOStreams
Listen string
Control bool
Verbosity VerbosityLevel
Namespaces []string
AllNamespaces bool
ExplicitNamespace bool
}
type VerbosityLevel ¶
type VerbosityLevel enumflag.Flag
const ( InfoVerbosityLevel VerbosityLevel = iota DebugVerbosityLevel TraceVerbosityLevel )
Source Files
Click to show internal directories.
Click to hide internal directories.