schema

Documentation

Index

• type Tracker
  • func NewTracker(ch chan *discovery.TabletHealth, user *string) *Tracker
  • func (t *Tracker) AddNewKeyspace(conn queryservice.QueryService, target *querypb.Target) error
  • func (t *Tracker) GetColumns(ks string, tbl string) []vindexes.Column
  • func (t *Tracker) LoadKeyspace(conn queryservice.QueryService, target *querypb.Target) error
  • func (t *Tracker) RegisterSignalReceiver(f func())
  • func (t *Tracker) Start()
  • func (t *Tracker) Stop()
  • func (t *Tracker) Tables(ks string) map[string][]vindexes.Column

Types

type Tracker

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

Tracker contains the required fields to perform schema tracking.

func NewTracker

func NewTracker(ch chan *discovery.TabletHealth, user *string) *Tracker

NewTracker creates the tracker object.

func (*Tracker) AddNewKeyspace

func (t *Tracker) AddNewKeyspace(conn queryservice.QueryService, target *querypb.Target) error

AddNewKeyspace adds keyspace to the tracker.

func (*Tracker) GetColumns

func (t *Tracker) GetColumns(ks string, tbl string) []vindexes.Column

GetColumns returns the column list for table in the given keyspace.

func (*Tracker) LoadKeyspace

func (t *Tracker) LoadKeyspace(conn queryservice.QueryService, target *querypb.Target) error

LoadKeyspace loads the keyspace schema.

func (*Tracker) RegisterSignalReceiver

func (t *Tracker) RegisterSignalReceiver(f func())

RegisterSignalReceiver allows a function to register to be called when new schema is available

func (*Tracker) Start

func (t *Tracker) Start()

Start starts the schema tracking.

func (*Tracker) Stop

func (t *Tracker) Stop()

Stop stops the schema tracking

func (*Tracker) Tables

func (t *Tracker) Tables(ks string) map[string][]vindexes.Column

Tables returns a map with the columns for all known tables in the keyspace