cache

Documentation

Index

• type ContivTelemetryCache
  • func (ctc *ContivTelemetryCache) ClearCache()
  • func (ctc *ContivTelemetryCache) Init() error
  • func (ctc *ContivTelemetryCache) ReinitializeCache()
  • func (ctc *ContivTelemetryCache) Resync(resyncEv datasync.ResyncEvent) error
  • func (ctc *ContivTelemetryCache) Update(dataChngEv datasync.ChangeEvent) error
• type Deps
• type NodeDTO

Types

type ContivTelemetryCache

type ContivTelemetryCache struct {
	Deps

	Synced           bool
	VppCache         api.VppCache
	K8sCache         api.K8sCache
	Processor        api.ContivTelemetryProcessor
	Report           api.Report
	ControllerReport api.ContivTelemetryControllerReport
	// contains filtered or unexported fields
}

ContivTelemetryCache is used for a in-memory storage of K8s State data The cache processes K8s State data updates and RESYNC events through Update() and Resync() APIs, respectively. The cache allows to get notified about changes via convenient callbacks.

func (*ContivTelemetryCache) ClearCache

func (ctc *ContivTelemetryCache) ClearCache()

ClearCache with clear all Contiv Telemetry cache data except for the data discovered from etcd updates.

func (*ContivTelemetryCache) Init

func (ctc *ContivTelemetryCache) Init() error

Init initializes policy cache.

func (*ContivTelemetryCache) ReinitializeCache

func (ctc *ContivTelemetryCache) ReinitializeCache()

ReinitializeCache completely re-initializes the Contiv Telemetry cache, clearing all data, including discovered vpp and k8s nodes and discovered k8s pods.

func (*ContivTelemetryCache) Resync

func (ctc *ContivTelemetryCache) Resync(resyncEv datasync.ResyncEvent) error

Resync sends the resync event passed as an argument to the ctc telemetryCache thread, where it processed in the function below (resync)

func (*ContivTelemetryCache) Update

func (ctc *ContivTelemetryCache) Update(dataChngEv datasync.ChangeEvent) error

Update sends the update event passed as an argument to the ctc telemetryCache // thread, where it processed in the function below (update). )

type Deps

type Deps struct {
	Log logging.Logger
}

Deps lists dependencies of PolicyCache.

type NodeDTO

type NodeDTO struct {
	NodeName string
	NodeInfo interface{}
	// contains filtered or unexported fields
}

NodeDTO is the Data Transfer Object (DTO) for sending data received from Contiv node Agent to the cache thread.