drain

package

v1.1.0 Latest Latest Go to latest Published: Apr 22, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Package drain provides graceful node draining and workload eviction for the nstance-operator.

View Source

const (
	// ConditionTypeServerDeleted indicates the instance was deleted server-side.
	ConditionTypeServerDeleted = "ServerDeleted"
)

This section is empty.

This section is empty.

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

Coordinator manages drain coordination across all shards

func NewCoordinator(c client.Client, logger logr.Logger, connections map[string]*grpc.ClientConn, restConfig *rest.Config) (*Coordinator, error)

NewCoordinator creates a new drain coordinator

func (c *Coordinator) Start(ctx context.Context) error

Start begins watching instance events from all shards

func (c *Coordinator) Stop()

Stop gracefully stops the coordinator