v1

Documentation

Index

• func NewTranslatorEventLoop(emitter TranslatorEmitter, syncer TranslatorSyncer) eventloop.EventLoop
• func NewTranslatorSimpleEventLoop(emitter TranslatorSimpleEmitter, syncers ...TranslatorSyncer) eventloop.SimpleEventLoop
• type TranslatorEmitter
  • func NewTranslatorEmitter(secretClient gloo_solo_io.SecretClient, ...) TranslatorEmitter
  • func NewTranslatorEmitterWithEmit(secretClient gloo_solo_io.SecretClient, ...) TranslatorEmitter
• type TranslatorSimpleEmitter
  • func NewTranslatorSimpleEmitter(aggregatedWatch clients.ResourceWatch) TranslatorSimpleEmitter
  • func NewTranslatorSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) TranslatorSimpleEmitter
• type TranslatorSnapshot
  • func (s TranslatorSnapshot) Clone() TranslatorSnapshot
  • func (s TranslatorSnapshot) Hash() uint64
  • func (s TranslatorSnapshot) HashFields() []zap.Field
  • func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer
• type TranslatorSnapshotStringer
  • func (ss TranslatorSnapshotStringer) String() string
• type TranslatorSyncDecider
• type TranslatorSyncDeciderWithContext
• type TranslatorSyncer
• type TranslatorSyncers
  • func (s TranslatorSyncers) Sync(ctx context.Context, snapshot *TranslatorSnapshot) error

Functions

func NewTranslatorEventLoop

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

func NewTranslatorSimpleEventLoop

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

Types

type TranslatorEmitter

type TranslatorEmitter interface {
	Register() error
	Secret() gloo_solo_io.SecretClient
	Ingress() github_com_solo_io_gloo_projects_knative_pkg_api_external_knative.IngressClient
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *TranslatorSnapshot, <-chan error, error)
}

func NewTranslatorEmitter

func NewTranslatorEmitter(secretClient gloo_solo_io.SecretClient, ingressClient github_com_solo_io_gloo_projects_knative_pkg_api_external_knative.IngressClient) TranslatorEmitter

func NewTranslatorEmitterWithEmit

func NewTranslatorEmitterWithEmit(secretClient gloo_solo_io.SecretClient, ingressClient github_com_solo_io_gloo_projects_knative_pkg_api_external_knative.IngressClient, emit <-chan struct{}) TranslatorEmitter

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

type TranslatorSnapshot struct {
	Secrets   gloo_solo_io.SecretList
	Ingresses github_com_solo_io_gloo_projects_knative_pkg_api_external_knative.IngressList
}

func (TranslatorSnapshot) Clone

func (s TranslatorSnapshot) Clone() TranslatorSnapshot

func (TranslatorSnapshot) Hash

func (s TranslatorSnapshot) Hash() uint64

func (TranslatorSnapshot) HashFields

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

func (TranslatorSnapshot) Stringer

func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer

type TranslatorSnapshotStringer

type TranslatorSnapshotStringer struct {
	Version   uint64
	Secrets   []string
	Ingresses []string
}

func (TranslatorSnapshotStringer) String

func (ss TranslatorSnapshotStringer) String() string

type TranslatorSyncDecider

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