Documentation
¶
Overview ¶
Package nodecontroller implemenets controller and provides logic for multiplexing node management
Index ¶
- func Uint64ToBytes(val uint64) []byte
- type Controller
- type NewOption
- func WithConfig(n *nodesv1.Node) NewOption
- func WithExchange(e *events.Exchange) NewOption
- func WithLeaseRenewalInterval(d time.Duration) NewOption
- func WithLogger(l logger.Logger) NewOption
- func WithName(s string) NewOption
- func WithNetworkManager(m networking.Manager) NewOption
- func WithTokenStore(s store.Store) NewOption
- func WithVolumeAttacher(a volume.Attacher) NewOption
- func WithWorkPool(p *queue.WorkPool) NewOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Uint64ToBytes ¶ added in v0.0.18
Uint64ToBytes converts the given uint64 value to slice of bytes.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func (*Controller) Reconcile ¶
func (c *Controller) Reconcile(ctx context.Context) error
Reconcile ensures that desired tasks matches with tasks in the runtime environment. It removes any tasks that are not desired (missing from the server) and adds those missing from runtime. It is preferrably run early during startup of the controller.
func (*Controller) Report ¶ added in v0.0.18
func (c *Controller) Report(report *typesv1.ConditionReport)
type NewOption ¶
type NewOption func(c *Controller)
func WithConfig ¶
func WithExchange ¶ added in v0.0.12
func WithLeaseRenewalInterval ¶ added in v0.0.12
func WithLogger ¶
func WithNetworkManager ¶ added in v0.0.15
func WithNetworkManager(m networking.Manager) NewOption
func WithTokenStore ¶ added in v0.0.18
func WithVolumeAttacher ¶
func WithWorkPool ¶ added in v0.0.18
Source Files
Click to show internal directories.
Click to hide internal directories.