persist

Documentation

Overview

Package persist asynchronously writes changes in the map (name->idx) to file.

Index

• func Marshalling(agentLabel string, idxMap idxvpp.NameToIdx, loadedFromFile idxvpp.NameToIdxRW) error
• type NameToIdxPersist
  • func NewNameToIdxPersist(fileName string, config *nametoidx.Config, namespace string, ...) *NameToIdxPersist
  • func (persist *NameToIdxPersist) Close() error
  • func (persist *NameToIdxPersist) Init() error
  • func (persist *NameToIdxPersist) Sync() error

Functions

func Marshalling

func Marshalling(agentLabel string, idxMap idxvpp.NameToIdx, loadedFromFile idxvpp.NameToIdxRW) error

Marshalling loads the config and starts watching for changes.

Types

type NameToIdxPersist

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

NameToIdxPersist is a watcher for changes in index to name mapping that persists changes in name to idx mapping.

func NewNameToIdxPersist

func NewNameToIdxPersist(fileName string, config *nametoidx.Config, namespace string,
	registrations chan idxvpp.NameToIdxDto) *NameToIdxPersist

NewNameToIdxPersist creates new instance of watcher of index to name mapping that persists changes in name to idx mapping.

func (*NameToIdxPersist) Close

func (persist *NameToIdxPersist) Close() error

Close triggers explicit synchronization and closes the underlying mapping.

func (*NameToIdxPersist) Init

func (persist *NameToIdxPersist) Init() error

Init starts go routine that watches chan idxvpp.NameToIdxDto

func (*NameToIdxPersist) Sync

func (persist *NameToIdxPersist) Sync() error

Sync triggers immediate synchronization between the underlying registry and the persistent storage. The function doesn't return until the operation has fully finished.