Documentation ¶
Index ¶
- func ValidateKubeConfig(logger log.Logger, kubeConfig string, fs afero.Fs) (string, error)
- type ConfigWatcher
- type ConfigWatcherOption
- type DefaultFileWatcher
- type FileWatcher
- type Options
- type Runner
- type RunnerOption
- func WithBrowserPath(browserPath string) RunnerOption
- func WithBuildInfo(buildInfo config.BuildInfo) RunnerOption
- func WithClientBurst(burst int) RunnerOption
- func WithClientQPS(qps float32) RunnerOption
- func WithClientUserAgent(userAgent string) RunnerOption
- func WithClusterClient(client cluster.ClientInterface) RunnerOption
- func WithContext(context string) RunnerOption
- func WithDynamicSharedInformerFactory(factory dynamicinformer.DynamicSharedInformerFactory) RunnerOption
- func WithFrontendURL(frontendURL string) RunnerOption
- func WithKubeConfig(kubeConfig string) RunnerOption
- func WithListener(listener net.Listener) RunnerOption
- func WithMemStats() RunnerOption
- func WithNamespace(namespace string) RunnerOption
- func WithNamespaces(namespaces []string) RunnerOption
- func WithOpenCensus() RunnerOption
- func WithoutClusterOverview() RunnerOption
- type WatcherConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConfigWatcher ¶ added in v0.10.1
type ConfigWatcher struct { FileWatcher FileWatcher // contains filtered or unexported fields }
ConfigWatcher watches kubernetes configurations.
func NewConfigWatcher ¶ added in v0.10.1
func NewConfigWatcher(wc WatcherConfig, options ...ConfigWatcherOption) (*ConfigWatcher, error)
NewConfigWatcher creates an instance of ConfigWatcher.
func (*ConfigWatcher) Add ¶ added in v0.10.1
func (cw *ConfigWatcher) Add(ctx context.Context, names ...string) error
Add adds file names to be watched.
func (*ConfigWatcher) Watch ¶ added in v0.10.1
func (cw *ConfigWatcher) Watch(ctx context.Context)
Watch runs the config watcher loop
type ConfigWatcherOption ¶ added in v0.10.1
type ConfigWatcherOption func(cw *ConfigWatcher)
ConfigWatcherOption is an option for configuration ConfigWatcher.
func ConfigWatcherFileWatcher ¶ added in v0.10.1
func ConfigWatcherFileWatcher(fw FileWatcher) ConfigWatcherOption
ConfigWatcherFileWatcher sets the file watcher for ConfigWatcher.
type DefaultFileWatcher ¶ added in v0.10.1
type DefaultFileWatcher struct {
// contains filtered or unexported fields
}
DefaultFileWatcher wraps fsnotify.Watcher so it can adhere to the FileWatcher API.
func NewDefaultFileWatcher ¶ added in v0.10.1
func NewDefaultFileWatcher() (*DefaultFileWatcher, error)
NewDefaultFileWatcher creates an instance of DefaultFileWatcher.
func (*DefaultFileWatcher) Add ¶ added in v0.10.1
func (d *DefaultFileWatcher) Add(name string) error
Add adds a file name to be watched.
func (DefaultFileWatcher) Errors ¶ added in v0.10.1
func (d DefaultFileWatcher) Errors() chan error
Errors returns a channel of errors.
func (*DefaultFileWatcher) Events ¶ added in v0.10.1
func (d *DefaultFileWatcher) Events() chan fsnotify.Event
Events returns a channel of fsnotify events.
type FileWatcher ¶ added in v0.10.1
type FileWatcher interface { // Add adds a file to watch. Add(name string) error // Events returns a channel with fsnotify events. Events() chan fsnotify.Event // Errors returns errors. Errors() chan error }
FileWatcher watches files.
type Options ¶
type Options struct { EnableOpenCensus bool EnableMemStats bool DisableClusterOverview bool KubeConfig string Namespace string Namespaces []string FrontendURL string BrowserPath string Context string ClientQPS float32 ClientBurst int UserAgent string BuildInfo config.BuildInfo Listener net.Listener // contains filtered or unexported fields }
type Runner ¶ added in v0.13.0
type Runner struct {
// contains filtered or unexported fields
}
type RunnerOption ¶ added in v0.18.0
type RunnerOption struct {
// contains filtered or unexported fields
}
func WithBrowserPath ¶ added in v0.18.0
func WithBrowserPath(browserPath string) RunnerOption
func WithBuildInfo ¶ added in v0.18.0
func WithBuildInfo(buildInfo config.BuildInfo) RunnerOption
func WithClientBurst ¶ added in v0.18.0
func WithClientBurst(burst int) RunnerOption
func WithClientQPS ¶ added in v0.18.0
func WithClientQPS(qps float32) RunnerOption
func WithClientUserAgent ¶ added in v0.18.0
func WithClientUserAgent(userAgent string) RunnerOption
func WithClusterClient ¶ added in v0.18.0
func WithClusterClient(client cluster.ClientInterface) RunnerOption
func WithContext ¶ added in v0.18.0
func WithContext(context string) RunnerOption
func WithDynamicSharedInformerFactory ¶ added in v0.18.0
func WithDynamicSharedInformerFactory(factory dynamicinformer.DynamicSharedInformerFactory) RunnerOption
func WithFrontendURL ¶ added in v0.18.0
func WithFrontendURL(frontendURL string) RunnerOption
func WithKubeConfig ¶ added in v0.18.0
func WithKubeConfig(kubeConfig string) RunnerOption
func WithListener ¶ added in v0.18.0
func WithListener(listener net.Listener) RunnerOption
func WithMemStats ¶ added in v0.18.0
func WithMemStats() RunnerOption
func WithNamespace ¶ added in v0.18.0
func WithNamespace(namespace string) RunnerOption
func WithNamespaces ¶ added in v0.18.0
func WithNamespaces(namespaces []string) RunnerOption
func WithOpenCensus ¶ added in v0.18.0
func WithOpenCensus() RunnerOption
func WithoutClusterOverview ¶ added in v0.18.0
func WithoutClusterOverview() RunnerOption
Click to show internal directories.
Click to hide internal directories.