snapshot

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2024 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Logger log.Logger = &log.LoggerFuncs{
	DebugFunc: func(s string, i ...interface{}) {
		klog.V(4).Infof(s, i...)
	},
	InfoFunc: func(s string, i ...interface{}) {
		klog.V(2).Infof(s, i...)
	},
	WarnFunc: func(s string, i ...interface{}) {
		klog.Warningf(s, i...)
	},
	ErrorFunc: func(s string, i ...interface{}) {
		klog.Errorf(s, i...)
	},
}

Functions

func DebugSnapshot

func DebugSnapshot(snapshot *cache.Snapshot) string

Types

type EmptyNodeID

type EmptyNodeID struct{}

EmptyNodeID satisfies cachev3.NodeHash but always return empty string

func (EmptyNodeID) ID

func (e EmptyNodeID) ID(node *corev3.Node) string

type Snapshotter

type Snapshotter struct {
	ResyncPeriod time.Duration
	// contains filtered or unexported fields
}

func New

func New(client kubernetes.Interface) *Snapshotter

func (*Snapshotter) MuxCache

func (s *Snapshotter) MuxCache() *cache.MuxCache

func (*Snapshotter) Start

func (s *Snapshotter) Start(stopCtx context.Context) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL