fake

Documentation

Overview

Package fake implements the reflector interfaces for testing purposes.

Index

• type FallbackReflector
  • func NewFallbackReflector(opts *options.ReflectorOpts) *FallbackReflector
  • func (r *FallbackReflector) Handle(_ context.Context, _ types.NamespacedName) error
  • func (r *FallbackReflector) Keys(local, remote string) []types.NamespacedName
  • func (r *FallbackReflector) List() ([]interface{}, error)
  • func (r *FallbackReflector) Ready() bool
  • func (r *FallbackReflector) SetReady()
• type NamespacedReflector
  • func NewNamespacedReflector(opts *options.NamespacedOpts) *NamespacedReflector
  • func (r *NamespacedReflector) Handle(_ context.Context, _ string) error
  • func (r *NamespacedReflector) List() ([]interface{}, error)
  • func (r *NamespacedReflector) Ready() bool
  • func (r *NamespacedReflector) SetReady()
• type Reflector
  • func NewReflector(isLeaderRestricted bool) *Reflector
  • func (r *Reflector) IsLeaderRestricted() bool
  • func (r *Reflector) Resync() error
  • func (r *Reflector) Start(_ context.Context, opts *options.ReflectorOpts)
  • func (r *Reflector) StartNamespace(opts *options.NamespacedOpts)
  • func (r *Reflector) StopNamespace(local, remote string)
  • func (r *Reflector) String() string

Types

type FallbackReflector

type FallbackReflector struct {
	Opts    options.ReflectorOpts
	Handled int
	// contains filtered or unexported fields
}

FallbackReflector implements a fake FallbackReflector for testing purposes.

func NewFallbackReflector

func NewFallbackReflector(opts *options.ReflectorOpts) *FallbackReflector

NewFallbackReflector returns a new fake FallbackReflector.

func (*FallbackReflector) Handle

func (r *FallbackReflector) Handle(_ context.Context, _ types.NamespacedName) error

Handle increments the Handled counter.

func (*FallbackReflector) Keys

func (r *FallbackReflector) Keys(local, remote string) []types.NamespacedName

Keys returns a key with the namespace equal to the local namespace and the name equal to the remote one.

func (*FallbackReflector) List

func (r *FallbackReflector) List() ([]interface{}, error)

List returns an empty list.

func (*FallbackReflector) Ready

func (r *FallbackReflector) Ready() bool

Ready returns whether the NamespacedReflector is completely initialized.

func (*FallbackReflector) SetReady

func (r *FallbackReflector) SetReady()

SetReady marks the NamespacedReflector as completely initialized.

type NamespacedReflector

type NamespacedReflector struct {
	Opts    options.NamespacedOpts
	Handled int
	// contains filtered or unexported fields
}

NamespacedReflector implements a fake NamespacedReflector for testing purposes.

func NewNamespacedReflector

func NewNamespacedReflector(opts *options.NamespacedOpts) *NamespacedReflector

NewNamespacedReflector returns a new fake NamespacedReflector.

func (*NamespacedReflector) Handle

func (r *NamespacedReflector) Handle(_ context.Context, _ string) error

Handle increments the Handled counter.

func (*NamespacedReflector) List

func (r *NamespacedReflector) List() ([]interface{}, error)

List returns the list of handled namespaces.

func (*NamespacedReflector) Ready

func (r *NamespacedReflector) Ready() bool

Ready returns whether the NamespacedReflector is completely initialized.

func (*NamespacedReflector) SetReady

func (r *NamespacedReflector) SetReady()

SetReady marks the NamespacedReflector as completely initialized.

type Reflector

type Reflector struct {
	Started          bool
	Opts             *options.ReflectorOpts
	NamespaceStarted map[string]*options.NamespacedOpts
	NamespaceStopped map[string]string
	NamespaceReady   map[string]func() bool
	// contains filtered or unexported fields
}

Reflector implements a fake Reflector for testing purposes.

func NewReflector

func NewReflector(isLeaderRestricted bool) *Reflector

NewReflector returns a new fake Reflector.

func (*Reflector) IsLeaderRestricted

func (r *Reflector) IsLeaderRestricted() bool

IsLeaderRestricted returns whether the reflector is restricted to the leader.

func (*Reflector) Resync

func (r *Reflector) Resync() error

Resync triggers a resync of the reflector.

func (*Reflector) Start

func (r *Reflector) Start(_ context.Context, opts *options.ReflectorOpts)

Start marks the reflector as started.

func (*Reflector) StartNamespace

func (r *Reflector) StartNamespace(opts *options.NamespacedOpts)

StartNamespace marks the given namespace as started, and stores the given options.

func (*Reflector) StopNamespace

func (r *Reflector) StopNamespace(local, remote string)

StopNamespace marks the given namespace as stopped, and stores the remote namespace name.

func (*Reflector) String

func (r *Reflector) String() string