gluetidb

Documentation

Index

• type Glue
  • func New() Glue
  • func (Glue) CreateSession(store kv.Storage) (glue.Session, error)
  • func (Glue) GetDomain(store kv.Storage) (*domain.Domain, error)
  • func (g Glue) GetVersion() string
  • func (g Glue) Open(path string, option pd.SecurityOption) (kv.Storage, error)
  • func (Glue) OwnsStorage() bool
  • func (g Glue) Record(name string, value uint64)
  • func (g Glue) StartProgress(ctx context.Context, cmdName string, total int64, redirectLog bool) glue.Progress
  • func (g Glue) UseOneShotSession(store kv.Storage, closeDomain bool, fn func(glue.Session) error) error
• type MockGlue
  • func (m *MockGlue) CreateSession(store kv.Storage) (glue.Session, error)
  • func (*MockGlue) GetDomain(store kv.Storage) (*domain.Domain, error)
  • func (*MockGlue) GetVersion() string
  • func (*MockGlue) Open(path string, option pd.SecurityOption) (kv.Storage, error)
  • func (*MockGlue) OwnsStorage() bool
  • func (*MockGlue) Record(name string, value uint64)
  • func (m *MockGlue) SetSession(se session.Session)
  • func (*MockGlue) StartProgress(ctx context.Context, cmdName string, total int64, redirectLog bool) glue.Progress
  • func (m *MockGlue) UseOneShotSession(store kv.Storage, closeDomain bool, fn func(glue.Session) error) error

Types

type Glue

type Glue struct {
	glue.StdIOGlue
	// contains filtered or unexported fields
}

Glue is an implementation of glue.Glue using a new TiDB session.

func New

func New() Glue

New makes a new tidb glue.

func (Glue) CreateSession

func (Glue) CreateSession(store kv.Storage) (glue.Session, error)

CreateSession implements glue.Glue.

func (Glue) GetDomain

func (Glue) GetDomain(store kv.Storage) (*domain.Domain, error)

GetDomain implements glue.Glue.

func (Glue) GetVersion

func (g Glue) GetVersion() string

GetVersion implements glue.Glue.

func (Glue) Open

func (g Glue) Open(path string, option pd.SecurityOption) (kv.Storage, error)

Open implements glue.Glue.

func (Glue) OwnsStorage

func (Glue) OwnsStorage() bool

OwnsStorage implements glue.Glue.

func (Glue) Record

func (g Glue) Record(name string, value uint64)

Record implements glue.Glue.

func (Glue) StartProgress

func (g Glue) StartProgress(ctx context.Context, cmdName string, total int64, redirectLog bool) glue.Progress

StartProgress implements glue.Glue.

func (Glue) UseOneShotSession

func (g Glue) UseOneShotSession(store kv.Storage, closeDomain bool, fn func(glue.Session) error) error

UseOneShotSession implements glue.Glue.

type MockGlue

type MockGlue struct {
	GlobalVars map[string]string
	// contains filtered or unexported fields
}

MockGlue only used for test

func (*MockGlue) CreateSession

func (m *MockGlue) CreateSession(store kv.Storage) (glue.Session, error)

CreateSession implements glue.Glue.

func (*MockGlue) GetDomain

func (*MockGlue) GetDomain(store kv.Storage) (*domain.Domain, error)

GetDomain implements glue.Glue.

func (*MockGlue) GetVersion

func (*MockGlue) GetVersion() string

GetVersion implements glue.Glue.

func (*MockGlue) Open

func (*MockGlue) Open(path string, option pd.SecurityOption) (kv.Storage, error)

Open implements glue.Glue.

func (*MockGlue) OwnsStorage

func (*MockGlue) OwnsStorage() bool

OwnsStorage implements glue.Glue.

func (*MockGlue) Record

func (*MockGlue) Record(name string, value uint64)

Record implements glue.Glue.

func (*MockGlue) SetSession

func (m *MockGlue) SetSession(se session.Session)

func (*MockGlue) StartProgress

func (*MockGlue) StartProgress(ctx context.Context, cmdName string, total int64, redirectLog bool) glue.Progress

StartProgress implements glue.Glue.

func (*MockGlue) UseOneShotSession

func (m *MockGlue) UseOneShotSession(store kv.Storage, closeDomain bool, fn func(glue.Session) error) error

UseOneShotSession implements glue.Glue.