ingress

Documentation

Overview

Package ingress exposes the interface the controller needs to operate on Ingress resources.

Index

• type Fake
  • func NewFake(ingresses []*v1.Ingress) *Fake
  • func (f *Fake) Get(id types.Id) (*v1.Ingress, error)
  • func (f *Fake) HasSynced() bool
  • func (f *Fake) List() ([]*v1.Ingress, error)
  • func (f *Fake) Patch(ctx context.Context, id types.Id, diff []byte) error
  • func (f *Fake) Run(ctx context.Context, queue workqueue.RateLimitingInterface)
• type Interface
  • func New(clientset *kubernetes.Clientset) Interface

Types

type Fake

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

func NewFake

func NewFake(ingresses []*v1.Ingress) *Fake

func (*Fake) Get

func (f *Fake) Get(id types.Id) (*v1.Ingress, error)

func (*Fake) HasSynced

func (f *Fake) HasSynced() bool

func (*Fake) List

func (f *Fake) List() ([]*v1.Ingress, error)

func (*Fake) Patch

func (f *Fake) Patch(ctx context.Context, id types.Id, diff []byte) error

func (*Fake) Run

func (f *Fake) Run(ctx context.Context, queue workqueue.RateLimitingInterface)

type Interface

type Interface interface {
	// Get fetches the resource identified by id.
	Get(id typesutils.Id) (*v1.Ingress, error)
	// HasSynced is true after first batch of Ingress resources
	// defined in the cluster has been synchronized with
	// the local storage.
	HasSynced() bool
	// List returns all Ingress resources.
	List() ([]*v1.Ingress, error)
	// Patch patches `patchBytes` changes to the ingress resource with the given id.
	Patch(ctx context.Context, id typesutils.Id, patchBytes []byte) error
	// Run initializes the object exposing the Ingress API.
	Run(ctx context.Context, queue workqueue.RateLimitingInterface)
}

Interface defines the interface the controller needs to operate on Ingress resources.

func New

func New(clientset *kubernetes.Clientset) Interface