migrations

Documentation

Index

• func AdditionalInitialDescriptors(ctx context.Context, db db) (int, error)
• type Manager
  • func NewManager(stopper *stop.Stopper, db *client.DB, executor *sql.Executor, clock *hlc.Clock, ...) *Manager
  • func (m *Manager) EnsureMigrations(ctx context.Context) error

Functions

func AdditionalInitialDescriptors

func AdditionalInitialDescriptors(ctx context.Context, db db) (int, error)

AdditionalInitialDescriptors returns the number of system descriptors that have been added by migrations. This is needed for certain tests, which check the number of ranges at node startup.

NOTE: This value may be out-of-date if another node is actively running migrations, and so should only be used in test code where the migration lifecycle is tightly controlled.

Types

type Manager

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

Manager encapsulates the necessary functionality for handling migrations of data in the cluster.

func NewManager

func NewManager(
	stopper *stop.Stopper,
	db *client.DB,
	executor *sql.Executor,
	clock *hlc.Clock,
	memMetrics *sql.MemoryMetrics,
	clientID string,
) *Manager

NewManager initializes and returns a new Manager object.

func (*Manager) EnsureMigrations

func (m *Manager) EnsureMigrations(ctx context.Context) error

EnsureMigrations should be run during node startup to ensure that all required migrations have been run (and running all those that are definitely safe to run).