partition

package

v0.74.5 Latest Latest Go to latest Published: Jan 6, 2026 License: MIT Imports: 9 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) 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, majorVersion sqlcv1.TenantMajorEngineVersion) ([]*sqlcv1.Tenant, error)

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

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

func (p *Partition) Shutdown() 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)