kubernetes

Documentation

Index

• func New(cfg config.Server, irMessage *message.IRMessage, ...) (manager.Manager, error)
• func NewJaegerController(cfg config.Server, mgr manager.Manager, jaegerIR *message.IRMessage, ...) error
• type EnqueueHandler
  • func (e *EnqueueHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)
• type GenerationChanger
  • func (p GenerationChanger) Update(e event.UpdateEvent) bool

Functions

func New

func New(cfg config.Server, irMessage *message.IRMessage, statusIRMaps *message.StatusIRMaps) (manager.Manager, error)

func NewJaegerController

func NewJaegerController(cfg config.Server, mgr manager.Manager, jaegerIR *message.IRMessage, statusIRMaps *message.StatusIRMaps) error

Types

type EnqueueHandler

type EnqueueHandler struct {
	*handler.EnqueueRequestForObject
}

EnqueueHandler With custom enqueueHandler, we don't handle delete cases, at least not for now

func (*EnqueueHandler) Delete

func (e *EnqueueHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

type GenerationChanger

type GenerationChanger struct {
	predicate.GenerationChangedPredicate
}

func (GenerationChanger) Update

func (p GenerationChanger) Update(e event.UpdateEvent) bool