wrangler

Documentation

Index

• type Context
  • func NewContextOrDie(restCfg *rest.Config) *Context
  • func (c *Context) OnLeader(f func(ctx context.Context) error)
  • func (c *Context) Run(ctx context.Context)
  • func (c *Context) StartHandler(ctx context.Context, worker int) error
  • func (c *Context) SupportDiscoveryV1() bool
  • func (c *Context) SupportIngressV1() bool
  • func (c *Context) WaitForCacheSyncOrDie(ctx context.Context)

Types

type Context

type Context struct {
	RESTConfig        *rest.Config
	Kubernetes        kubernetes.Interface
	ControllerFactory controller.SharedControllerFactory

	FlatNetwork flv1.Interface
	Core        corecontroller.Interface
	Apps        appsv1.Interface
	Networking  networkingv1.Interface
	Batch       batchv1.Interface
	Discovery   discoveryv1.Interface
	Recorder    record.EventRecorder

	// ClientSet for NetworkAttachmentDefinitions
	NDClientSet *ndClientSet.Clientset
	// contains filtered or unexported fields
}

func NewContextOrDie

func NewContextOrDie(
	restCfg *rest.Config,
) *Context

func (*Context) OnLeader

func (c *Context) OnLeader(f func(ctx context.Context) error)

func (*Context) Run

func (c *Context) Run(ctx context.Context)

Run starts the leader-election process and block.

func (*Context) StartHandler

func (c *Context) StartHandler(ctx context.Context, worker int) error

func (*Context) SupportDiscoveryV1

func (c *Context) SupportDiscoveryV1() bool

func (*Context) SupportIngressV1

func (c *Context) SupportIngressV1() bool

func (*Context) WaitForCacheSyncOrDie

func (c *Context) WaitForCacheSyncOrDie(ctx context.Context)