partition

package

v0.112.13 Latest Latest Go to latest Published: Oct 20, 2026 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewPartition(l *zerolog.Logger, repo v1.TenantRepository) (*Partition, error)

func (p *Partition) AddCleanupMethods(cleanup *cleanup.Cleanup)

func (p *Partition) GetControllerPartitionId() string

func (p *Partition) GetInternalTenantForController(ctx context.Context) (*sqlcv1.Tenant, error)

func (p *Partition) GetSchedulerPartitionId() string

func (p *Partition) GetWorkerPartitionId() string

func (p *Partition) ListTenantsForController(ctx context.Context) ([]uuid.UUID, error)

func (p *Partition) ListTenantsForScheduler(ctx context.Context) ([]*sqlcv1.Tenant, error)

func (p *Partition) ListTenantsForWorkerPartition(ctx context.Context) ([]*sqlcv1.Tenant, error)

func (p *Partition) StartControllerPartition(ctx context.Context) (func() error, error)

func (p *Partition) StartSchedulerPartition(ctx context.Context) (func() error, error)

func (p *Partition) StartTenantWorkerPartition(ctx context.Context) (func() error, error)