wrangler

Documentation

Index

• func IPAllocateLock(subnet string) func()
• func IsIPAllocating(subnet string) bool
• 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)

Functions

func IPAllocateLock

func IPAllocateLock(subnet string) func()

IPAllocateLock locks by subnet name and returns unlock function

func IsIPAllocating

func IsIPAllocating(subnet string) bool

IsIPAllocating checks whether the subnet is locked

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

	// 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)