partition

Documentation

Index

• type Partition
  • func NewPartition(l *zerolog.Logger, repo repository.TenantEngineRepository) (*Partition, error)
  • func (p *Partition) GetControllerPartitionId() string
  • func (p *Partition) GetInternalTenantForController(ctx context.Context) (*dbsqlc.Tenant, error)
  • func (p *Partition) GetSchedulerPartitionId() string
  • func (p *Partition) GetWorkerPartitionId() string
  • func (p *Partition) ListTenantsForController(ctx context.Context, majorVersion dbsqlc.TenantMajorEngineVersion) ([]*dbsqlc.Tenant, error)
  • func (p *Partition) ListTenantsForScheduler(ctx context.Context, majorVersion dbsqlc.TenantMajorEngineVersion) ([]*dbsqlc.Tenant, error)
  • func (p *Partition) ListTenantsForWorkerPartition(ctx context.Context, majorVersion dbsqlc.TenantMajorEngineVersion) ([]*dbsqlc.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)

Types

type Partition

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

func NewPartition

func NewPartition(l *zerolog.Logger, repo repository.TenantEngineRepository) (*Partition, error)

func (*Partition) GetControllerPartitionId

func (p *Partition) GetControllerPartitionId() string

func (*Partition) GetInternalTenantForController

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

func (*Partition) GetSchedulerPartitionId

func (p *Partition) GetSchedulerPartitionId() string

func (*Partition) GetWorkerPartitionId

func (p *Partition) GetWorkerPartitionId() string

func (*Partition) ListTenantsForController

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

func (*Partition) ListTenantsForScheduler

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

func (*Partition) ListTenantsForWorkerPartition

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

func (*Partition) Shutdown

func (p *Partition) Shutdown() error

func (*Partition) StartControllerPartition

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

func (*Partition) StartSchedulerPartition

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

func (*Partition) StartTenantWorkerPartition

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