lifecycle

package

v0.2.0 Latest Latest Go to latest Published: Mar 18, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Cluster is a controller-runtime cluster that can be stopped by cancelling its root context.

func NewCluster(address string, baseRestConfig *rest.Config) (*Cluster, error)

func (c *Cluster) GetCache() (cache.Cache, error)

func (c *Cluster) GetClient() (ctrlruntimeclient.Client, error)

func (c *Cluster) GetCluster() cluster.Cluster

func (c *Cluster) Running() bool

func (c *Cluster) Start(ctx context.Context, log *zap.SugaredLogger) error

Start starts a goroutine for the underlying cluster object; make sure to use a long-lived context here.

func (c *Cluster) Stop(log *zap.SugaredLogger) error

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

Controller is a controller-runtime controller that can be stopped by cancelling its root context.

func NewController(upstream controller.Controller) (Controller, error)

func (c *Controller) Running() bool

func (c *Controller) Start(ctx context.Context, log *zap.SugaredLogger) error

Start starts the wrapped controller.

func (c *Controller) Stop(log *zap.SugaredLogger, cause error) error