v1

Documentation

Index

• Variables
• func NewTranslatorEventLoop(emitter TranslatorSnapshotEmitter, syncer TranslatorSyncer) eventloop.EventLoop
• func NewTranslatorSimpleEventLoop(emitter TranslatorSimpleEmitter, syncers ...TranslatorSyncer) eventloop.SimpleEventLoop
• type TranslatorEmitter
  • func NewTranslatorEmitter(...) TranslatorEmitter
  • func NewTranslatorEmitterWithEmit(...) 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) GetResourcesList(resource resources.Resource) (resources.ResourceList, error)
  • func (s TranslatorSnapshot) Hash(hasher hash.Hash64) (uint64, error)
  • func (s TranslatorSnapshot) HashFields() []zap.Field
  • func (s *TranslatorSnapshot) RemoveFromResourceList(resource resources.Resource) error
  • func (s *TranslatorSnapshot) RemoveMatches(predicate core.Predicate)
  • func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer
  • func (s *TranslatorSnapshot) UpsertToResourceList(resource resources.Resource) error
• type TranslatorSnapshotEmitter
• 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

Variables

var TranslatorGvkToHashableResource = map[schema.GroupVersionKind]func() resources.HashableResource{
	github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressGVK: github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.NewClusterIngressHashableResource,
}

Functions

func NewTranslatorEventLoop

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

func NewTranslatorSimpleEventLoop

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

Types

type TranslatorEmitter

type TranslatorEmitter interface {
	TranslatorSnapshotEmitter
	Register() error
	ClusterIngress() github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient
}

func NewTranslatorEmitter

func NewTranslatorEmitter(clusterIngressClient github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient) TranslatorEmitter

func NewTranslatorEmitterWithEmit

func NewTranslatorEmitterWithEmit(clusterIngressClient github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient, 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 {
	Clusteringresses github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressList
}

func (TranslatorSnapshot) Clone

func (s TranslatorSnapshot) Clone() TranslatorSnapshot

func (*TranslatorSnapshot) GetResourcesList

func (s *TranslatorSnapshot) GetResourcesList(resource resources.Resource) (resources.ResourceList, error)

func (TranslatorSnapshot) Hash

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

func (TranslatorSnapshot) HashFields

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

func (*TranslatorSnapshot) RemoveFromResourceList

func (s *TranslatorSnapshot) RemoveFromResourceList(resource resources.Resource) error

func (*TranslatorSnapshot) RemoveMatches

func (s *TranslatorSnapshot) RemoveMatches(predicate core.Predicate)

func (TranslatorSnapshot) Stringer

func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer

func (*TranslatorSnapshot) UpsertToResourceList

func (s *TranslatorSnapshot) UpsertToResourceList(resource resources.Resource) error

type TranslatorSnapshotEmitter

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

type TranslatorSnapshotStringer

type TranslatorSnapshotStringer struct {
	Version          uint64
	Clusteringresses []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