observer

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// EntityNumberPoll is a poll interval for StatefulSet tests
	EntityNumberPoll = 5 * time.Second

	// EntityNumberTimeout entity timeout
	EntityNumberTimeout = 1800 * time.Second
)
View Source 
const (
	// MetricsPoll is a poll interval for StatefulSet tests
	MetricsPoll = 5 * time.Second

	// MetricsTimeout is metrics timeout
	MetricsTimeout = 1800 * time.Second
)
View Source 
const (
	// BatchSize sets the number of events to be added at once
	BatchSize = 10
	// WatchTimeout to override timeout set in kubeapi-server settings, Default: 24 hours
	WatchTimeout int64 = 60 * 60 * 24

	// LIST Type
	LIST Type = "LIST"
	// EVENT Type
	EVENT Type = "EVENT"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ContainerMetricsObserver 

type ContainerMetricsObserver struct {
	// contains filtered or unexported fields
}

ContainerMetricsObserver is used to manage container metrics observer

func (*ContainerMetricsObserver) GetName 

func (cmo *ContainerMetricsObserver) GetName() string

GetName returns name of container metrics observer

func (*ContainerMetricsObserver) Interrupt 

func (cmo *ContainerMetricsObserver) Interrupt()

Interrupt interrupts a container metrics observer

func (*ContainerMetricsObserver) Interrupted 

func (cmo *ContainerMetricsObserver) Interrupted() bool

Interrupted checks whether container metrics observer is interrupted

func (*ContainerMetricsObserver) MakeChannel 

func (cmo *ContainerMetricsObserver) MakeChannel()

MakeChannel makes a new channel

func (*ContainerMetricsObserver) StartWatching 

func (cmo *ContainerMetricsObserver) StartWatching(_ context.Context, runner *Runner)

StartWatching starts watching container metrics

func (*ContainerMetricsObserver) StopWatching 

func (cmo *ContainerMetricsObserver) StopWatching()

StopWatching stops watching container metrics

type EntityNumberObserver 

type EntityNumberObserver struct {
	// contains filtered or unexported fields
}

EntityNumberObserver is used to manage entity numbers

func (*EntityNumberObserver) GetName 

func (eno *EntityNumberObserver) GetName() string

GetName returns entity number observer name

func (*EntityNumberObserver) Interrupt 

func (eno *EntityNumberObserver) Interrupt()

Interrupt interrupts an entity number observer

func (*EntityNumberObserver) Interrupted 

func (eno *EntityNumberObserver) Interrupted() bool

Interrupted checks whether entity number observer is interrupted

func (*EntityNumberObserver) MakeChannel 

func (eno *EntityNumberObserver) MakeChannel()

MakeChannel makes a new channel

func (*EntityNumberObserver) StartWatching 

func (eno *EntityNumberObserver) StartWatching(_ context.Context, runner *Runner)

StartWatching watches all entities - pods and pvcs

func (*EntityNumberObserver) StopWatching 

func (eno *EntityNumberObserver) StopWatching()

StopWatching terminates watching entities

type Interface 

type Interface interface {
	StartWatching(context.Context, *Runner)
	StopWatching()
	GetName() string
	MakeChannel()
}

Interface contains common function definitions

type PodListObserver 

type PodListObserver struct {
	// contains filtered or unexported fields
}

PodListObserver is used to manage Pod list observer

func (*PodListObserver) GetName 

func (po *PodListObserver) GetName() string

GetName returns name of Pod list observer

func (*PodListObserver) MakeChannel 

func (po *PodListObserver) MakeChannel()

MakeChannel creates a new channel

func (*PodListObserver) StartWatching 

func (po *PodListObserver) StartWatching(ctx context.Context, runner *Runner)

StartWatching watches pods

func (*PodListObserver) StopWatching 

func (po *PodListObserver) StopWatching()

StopWatching stops watching pods

type PodObserver 

type PodObserver struct {
	// contains filtered or unexported fields
}

PodObserver is used to manage pod observer

func (*PodObserver) GetName 

func (po *PodObserver) GetName() string

GetName returns name of Pod observer

func (*PodObserver) MakeChannel 

func (po *PodObserver) MakeChannel()

MakeChannel creates a new channel

func (*PodObserver) StartWatching 

func (po *PodObserver) StartWatching(_ context.Context, runner *Runner)

StartWatching starts watching pod

func (*PodObserver) StopWatching 

func (po *PodObserver) StopWatching()

StopWatching stops watching pod

type PvcListObserver 

type PvcListObserver struct {
	// contains filtered or unexported fields
}

PvcListObserver is used to manage PVC list observer

func (*PvcListObserver) GetName 

func (*PvcListObserver) GetName() string

GetName returns PVC list observer name

func (*PvcListObserver) MakeChannel 

func (obs *PvcListObserver) MakeChannel()

MakeChannel creates a new channel

func (*PvcListObserver) StartWatching 

func (obs *PvcListObserver) StartWatching(ctx context.Context, runner *Runner)

StartWatching starts watching a list of PVCs

func (*PvcListObserver) StopWatching 

func (obs *PvcListObserver) StopWatching()

StopWatching stops watching a list of PVCs

type PvcObserver 

type PvcObserver struct {
	// contains filtered or unexported fields
}

PvcObserver is used to manage PVC Observer

func (*PvcObserver) GetName 

func (*PvcObserver) GetName() string

GetName returns name of PVC observer

func (*PvcObserver) MakeChannel 

func (obs *PvcObserver) MakeChannel()

MakeChannel creates a new channel

func (*PvcObserver) StartWatching 

func (obs *PvcObserver) StartWatching(_ context.Context, runner *Runner)

StartWatching starts watching a PVC

func (*PvcObserver) StopWatching 

func (obs *PvcObserver) StopWatching()

StopWatching stops watching a PVC

type Runner 

type Runner struct {
	WaitGroup       sync.WaitGroup
	Observers       []Interface
	Clients         *k8sclient.Clients
	Database        store.Store
	TestCase        *store.TestCase
	PvcShare        sync.Map
	DriverNamespace string
	ShouldClean     bool
}

Runner contains configuration to run the testcases

func NewObserverRunner 

func NewObserverRunner(observers []Interface, clients *k8sclient.Clients,
	db store.Store, testCase *store.TestCase, driverNs string, shouldClean bool,
) *Runner

NewObserverRunner returns a Runner instance

func (*Runner) Start 

func (runner *Runner) Start(ctx context.Context) error

Start starts watching all the runners

func (*Runner) Stop 

func (runner *Runner) Stop() error

Stop stops watching all the runners and deletes PVCs

type Type 

type Type string

Type represents LIST or EVENT

type VaListObserver 

type VaListObserver struct {
	// contains filtered or unexported fields
}

VaListObserver is used to manage volume attachment observer

func (*VaListObserver) GetName 

func (vao *VaListObserver) GetName() string

GetName returns name of VA observer

func (*VaListObserver) MakeChannel 

func (vao *VaListObserver) MakeChannel()

MakeChannel creates a new channel

func (*VaListObserver) StartWatching 

func (vao *VaListObserver) StartWatching(ctx context.Context, runner *Runner)

StartWatching starts watching a volume attachment and related events

func (*VaListObserver) StopWatching 

func (vao *VaListObserver) StopWatching()

StopWatching stops watching a volume attachment

type VaObserver 

type VaObserver struct {
	// contains filtered or unexported fields
}

VaObserver is used to manage volume attachment observer

func (*VaObserver) GetName 

func (vao *VaObserver) GetName() string

GetName returns name of VA observer

func (*VaObserver) MakeChannel 

func (vao *VaObserver) MakeChannel()

MakeChannel creates a new channel

func (*VaObserver) StartWatching 

func (vao *VaObserver) StartWatching(_ context.Context, runner *Runner)

StartWatching starts watching a volume attachment and related events

func (*VaObserver) StopWatching 

func (vao *VaObserver) StopWatching()

StopWatching stops watching a volume attachment

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.