nfshacontroller

Documentation

Index

• type NfshaController
  • func NewNFSHAController(name string, kubeClient kubernetes.Interface, opts ...Option) *NfshaController
  • func (nfsc *NfshaController) HandlePodWatchEvent(ctx context.Context, ev watch.Event) error
  • func (nfsc *NfshaController) Run(ctx context.Context, wg *sync.WaitGroup) error
• type Option
  • func WithEventRecorder(ev record.EventRecorder) Option

Types

type NfshaController

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

func NewNFSHAController

func NewNFSHAController(name string, kubeClient kubernetes.Interface, opts ...Option) *NfshaController

Create a new nfscontroller with the given Name, Kubernetes client and opts Can be customized by adding Option(s).

func (*NfshaController) HandlePodWatchEvent

func (nfsc *NfshaController) HandlePodWatchEvent(ctx context.Context, ev watch.Event) error

func (*NfshaController) Run

func (nfsc *NfshaController) Run(ctx context.Context, wg *sync.WaitGroup) error

Start monitoring the Kubernetes API for changes to the Pod objects

type Option

type Option func(nfsc *NfshaController)

Options to pass when creating a new nfscontroller

func WithEventRecorder

func WithEventRecorder(ev record.EventRecorder) Option

Set an EventRecorder that will be notified of any events that occur