process

Documentation

Index

• func ByNamespaceAndNameIndexKey(namespace, name string) string
• func StartStopServer(ctx context.Context, srv *http.Server, shutdownTimeout time.Duration) error
• func StartStopTLSServer(ctx context.Context, srv *http.Server, shutdownTimeout time.Duration, ...) error
• type Generic
  • func NewGeneric(config *ctrl.Config, queue workqueue.RateLimitingInterface, workers uint, ...) (*Generic, error)
  • func (g *Generic) IsReady() bool
  • func (g *Generic) Run(ctx context.Context) error
• type Holder
• type ServerHolder

Functions

func ByNamespaceAndNameIndexKey

func ByNamespaceAndNameIndexKey(namespace, name string) string

func StartStopServer

func StartStopServer(ctx context.Context, srv *http.Server, shutdownTimeout time.Duration) error

func StartStopTLSServer

func StartStopTLSServer(ctx context.Context, srv *http.Server, shutdownTimeout time.Duration, certFile, keyFile string) error

Types

type Generic

type Generic struct {
	Controllers map[schema.GroupVersionKind]Holder
	Servers     map[schema.GroupVersionKind]ServerHolder
	Informers   map[schema.GroupVersionKind]cache.SharedIndexInformer
	// contains filtered or unexported fields
}

func NewGeneric

func NewGeneric(config *ctrl.Config, queue workqueue.RateLimitingInterface, workers uint, constructors ...ctrl.Constructor) (*Generic, error)

func (*Generic) IsReady

func (g *Generic) IsReady() bool

func (*Generic) Run

func (g *Generic) Run(ctx context.Context) error

type Holder

type Holder struct {
	AppName      string
	Cntrlr       ctrl.Interface
	ReadyForWork <-chan struct{}
	// contains filtered or unexported fields
}

type ServerHolder

type ServerHolder struct {
	AppName      string
	Server       ctrl.Server
	ReadyForWork <-chan struct{}
	// contains filtered or unexported fields
}