sgservicecontroller

Documentation

Index

• type Option
  • func WithEventRecorder(ev record.EventRecorder) Option
  • func WithStatefulSetSelector(opts metav1.ListOptions) Option
• type SgController
  • func NewSGServiceController(name string, kubeClient kubernetes.Interface, opts ...Option) *SgController
  • func (sgc *SgController) HandleStatefulSetWatchEvent(ctx context.Context, ev watch.Event) error
  • func (sgc *SgController) Run(ctx context.Context, wg *sync.WaitGroup) error

Types

type Option

type Option func(sgc *SgController)

Options to pass when creating a new sgcontroller

func WithEventRecorder

func WithEventRecorder(ev record.EventRecorder) Option

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

func WithStatefulSetSelector

func WithStatefulSetSelector(opts metav1.ListOptions) Option

type SgController

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

func NewSGServiceController

func NewSGServiceController(name string, kubeClient kubernetes.Interface, opts ...Option) *SgController

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

func (*SgController) HandleStatefulSetWatchEvent

func (sgc *SgController) HandleStatefulSetWatchEvent(ctx context.Context, ev watch.Event) error

func (*SgController) Run

func (sgc *SgController) Run(ctx context.Context, wg *sync.WaitGroup) error

Start monitoring the Kubernetes API for changes to the StatefulSet objects