v1

package
v1.12.0-beta28 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 2022 License: Apache-2.0 Imports: 22 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTranslatorEventLoop

func NewTranslatorEventLoop(emitter TranslatorSnapshotEmitter, syncer TranslatorSyncer) eventloop.EventLoop

func NewTranslatorSimpleEventLoop

func NewTranslatorSimpleEventLoop(emitter TranslatorSimpleEmitter, syncers ...TranslatorSyncer) eventloop.SimpleEventLoop

Types

type TranslatorSimpleEmitter

type TranslatorSimpleEmitter interface {
	Snapshots(ctx context.Context) (<-chan *TranslatorSnapshot, <-chan error, error)
}

func NewTranslatorSimpleEmitter

func NewTranslatorSimpleEmitter(aggregatedWatch clients.ResourceWatch) TranslatorSimpleEmitter

func NewTranslatorSimpleEmitterWithEmit

func NewTranslatorSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) TranslatorSimpleEmitter

type TranslatorSnapshot

func (TranslatorSnapshot) Clone

func (TranslatorSnapshot) Hash

func (s TranslatorSnapshot) Hash(hasher hash.Hash64) (uint64, error)

func (TranslatorSnapshot) HashFields

func (s TranslatorSnapshot) HashFields() []zap.Field

func (TranslatorSnapshot) Stringer

type TranslatorSnapshotEmitter added in v0.18.44

type TranslatorSnapshotEmitter interface {
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *TranslatorSnapshot, <-chan error, error)
}

type TranslatorSnapshotStringer

type TranslatorSnapshotStringer struct {
	Version   uint64
	Ingresses []string
}

func (TranslatorSnapshotStringer) String

func (ss TranslatorSnapshotStringer) String() string

type TranslatorSyncDecider deprecated

type TranslatorSyncDecider interface {
	TranslatorSyncer
	ShouldSync(old, new *TranslatorSnapshot) bool
}

Deprecated: use TranslatorSyncDeciderWithContext

type TranslatorSyncDeciderWithContext

type TranslatorSyncDeciderWithContext interface {
	TranslatorSyncer
	ShouldSync(ctx context.Context, old, new *TranslatorSnapshot) bool
}

type TranslatorSyncer

type TranslatorSyncer interface {
	Sync(context.Context, *TranslatorSnapshot) error
}

type TranslatorSyncers

type TranslatorSyncers []TranslatorSyncer

func (TranslatorSyncers) Sync

func (s TranslatorSyncers) Sync(ctx context.Context, snapshot *TranslatorSnapshot) error

Jump to

Keyboard shortcuts

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