Documentation
¶
Index ¶
- Variables
- func DatabaseRestore(db badgerwrap.DB, filename string) error
- func GetKubernetesContext(masterURL string, kubeContextPreference string, privilegedAccess bool) (string, error)
- func MakeKubernetesClient(masterURL string, kubeContext string, privilegedAccess bool) (kubernetes.Interface, error)
- func PlayFile(outChan chan typed.KubeWatchResult, filename string) error
- type FileRecorder
- type KubePlaybackFile
- type KubeResourceSource
- type KubeWatcher
Constants ¶
This section is empty.
Variables ¶
View Source
var BuildConfigFromFlags = clientcmd.BuildConfigFromFlags
View Source
var ClientConfig = clientcmd.ClientConfig.ClientConfig
View Source
var RawConfig = clientcmd.ClientConfig.RawConfig
Functions ¶
func DatabaseRestore ¶
func DatabaseRestore(db badgerwrap.DB, filename string) error
DatabaseRestore restores the DB from a backup file created by webserver.backupHandler
func GetKubernetesContext ¶
func GetKubernetesContext(masterURL string, kubeContextPreference string, privilegedAccess bool) (string, error)
GetKubernetesContext takes optional user preferences and returns the Kubernetes context in use
func MakeKubernetesClient ¶
func MakeKubernetesClient(masterURL string, kubeContext string, privilegedAccess bool) (kubernetes.Interface, error)
MakeKubernetesClient takes masterURL and kubeContext (user preference should have already been resolved before calling this) and returns a K8s client
Types ¶
type FileRecorder ¶
type FileRecorder struct {
// contains filtered or unexported fields
}
func NewFileRecorder ¶
func NewFileRecorder(filename string, inChan chan typed.KubeWatchResult) *FileRecorder
func (*FileRecorder) Close ¶
func (fr *FileRecorder) Close() error
func (*FileRecorder) Start ¶
func (fr *FileRecorder) Start()
type KubePlaybackFile ¶
type KubePlaybackFile struct {
Data []typed.KubeWatchResult `json:"Data"`
}
type KubeResourceSource ¶
type KubeResourceSource interface {
Init() (chan typed.KubeWatchResult, error)
Stop()
}
type KubeWatcher ¶
type KubeWatcher interface {
Stop()
}
func NewKubeWatcherSource ¶
func NewKubeWatcherSource(kubeClient kubernetes.Interface, outChan chan typed.KubeWatchResult, resync time.Duration, includeCrds bool, crdRefreshInterval time.Duration, masterURL string, kubeContext string, enableGranularMetrics bool, exclusionRules map[string][]any) (KubeWatcher, error)
Todo: Add additional parameters for filtering
Source Files
Click to show internal directories.
Click to hide internal directories.