glue

package
v1.1.0-beta.0...-6d74071 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2024 License: Apache-2.0, Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const OnlyOneTask int = -1

Variables

This section is empty.

Functions

func PrintList 

func PrintList[T any](ops ConsoleOperations, title string, items []T, maxItemsDisplay int)

Types

type BatchCreateTableSession 

type BatchCreateTableSession interface {
	CreateTables(ctx context.Context, tables map[string][]*model.TableInfo,
		cs ...ddl.CreateTableOption) error
}

BatchCreateTableSession is an interface to batch create table parallelly

type ConsoleGlue 

type ConsoleGlue interface {
	// Out returns the output port of the console.
	Out() io.Writer
	// In returns the input of the console.
	// Usually is should be an *os.File.
	In() io.Reader
}

ConsoleGlue is the glue between BR and some type of console, which is the port for interact with the user. Generally, this is a abstraction of an UNIX terminal.

type ConsoleOperations 

type ConsoleOperations struct {
	ConsoleGlue
}

ConsoleOperations are some operations based on ConsoleGlue.

func GetConsole 

func GetConsole(g Glue) ConsoleOperations

func (ConsoleOperations) CreateTable 

func (ops ConsoleOperations) CreateTable() *Table

func (ConsoleOperations) GetWidth 

func (ops ConsoleOperations) GetWidth() int

func (ConsoleOperations) IsInteractive 

func (ops ConsoleOperations) IsInteractive() bool

func (ConsoleOperations) OutputIsTTY 

func (ops ConsoleOperations) OutputIsTTY() bool

func (ConsoleOperations) Print 

func (ops ConsoleOperations) Print(args ...any)

func (ConsoleOperations) Printf 

func (ops ConsoleOperations) Printf(format string, args ...any)

func (ConsoleOperations) Println 

func (ops ConsoleOperations) Println(args ...any)

func (ConsoleOperations) PromptBool 

func (ops ConsoleOperations) PromptBool(p string) bool

PromptBool prompts a boolean from the user.

func (ConsoleOperations) RootFrame 

func (ops ConsoleOperations) RootFrame() Frame

func (ConsoleOperations) Scanln 

func (ops ConsoleOperations) Scanln(args ...any) (int, error)

func (ConsoleOperations) ShowTask 

func (ops ConsoleOperations) ShowTask(message string, extraFields ...ExtraField) func()

ShowTask prints a task start information, and mark as finished when the returned function called. This is for TUI presenting.

func (ConsoleOperations) StartProgressBar 

func (ops ConsoleOperations) StartProgressBar(title string, total int, extraFields ...ExtraField) ProgressWaiter

StartProgressBar starts a progress bar with the console operations. Note: This function has overlapped function with `glue.StartProgress`, however this supports display extra fields 

after success, and implement by `mpb` (instead of `pb`).

Note': Maybe replace the old `StartProgress` with `mpb` too.

type ExtraField 

type ExtraField func() [2]string

An extra field appending to the task. return type is a {key: string, value: string} tuple.

func WithCallbackExtraField 

func WithCallbackExtraField(key string, value func() string) ExtraField

WithCallbackExtraField adds an extra field with the callback.

func WithConstExtraField 

func WithConstExtraField(key string, value any) ExtraField

WithConstExtraField adds an extra field with constant values.

func WithTimeCost 

func WithTimeCost() ExtraField

WithTimeCost adds the task information of time costing for `ShowTask`.

type Frame 

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

Frame is an fix-width place for printing. It is the abstraction of some subarea of the terminal, you might imagine it as a panel in the tmux, but with infinity height. For example, printing a frame with the width of 10 chars, and 4 chars offset left, would be like: 

v~~~~~~~~~~v Here is the "width of a frame".

+--+----------+--+ | Hello, wor | | ld. | +--+----------+--+ ^~~^ Here is the "offset of a frame".

func (Frame) OffsetLeft 

func (f Frame) OffsetLeft(offset int) (Frame, bool)

func (Frame) OffsetLeftWithMinWidth 

func (f Frame) OffsetLeftWithMinWidth(offset, minWidth int) (Frame, bool)

func (Frame) Print 

func (f Frame) Print(s PrettyString)

func (Frame) WithWidth 

func (f Frame) WithWidth(width int) Frame

type Glue 

type Glue interface {
	GetDomain(store kv.Storage) (*domain.Domain, error)
	CreateSession(store kv.Storage) (Session, error)
	Open(path string, option pd.SecurityOption) (kv.Storage, error)

	// OwnsStorage returns whether the storage returned by Open() is owned
	// If this method returns false, the connection manager will never close the storage.
	OwnsStorage() bool

	StartProgress(ctx context.Context, cmdName string, total int64, redirectLog bool) Progress

	// Record records some information useful for log-less summary.
	Record(name string, value uint64)

	// GetVersion gets BR package version to run backup/restore job
	GetVersion() string

	// UseOneShotSession temporary creates session from store when run backup job.
	// because we don't have to own domain/session during the whole backup.
	// we can close domain as soon as possible.
	// and we must reuse the exists session and don't close it in SQL backup job.
	UseOneShotSession(store kv.Storage, closeDomain bool, fn func(se Session) error) error

	// GetClient returns the client type of the glue
	GetClient() GlueClient
}

Glue is an abstraction of TiDB function calls used in BR.

type GlueClient 

type GlueClient int
const (
	ClientCLP GlueClient = iota
	ClientSql
)

type NoOPConsoleGlue 

type NoOPConsoleGlue struct{}

NoOPConsoleGlue is the glue for "embedded" BR, say, BRIE via SQL. This Glue simply drop all console operations.

func (NoOPConsoleGlue) In 

func (NoOPConsoleGlue) In() io.Reader

func (NoOPConsoleGlue) Out 

func (NoOPConsoleGlue) Out() io.Writer

type PrettyString 

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

PrettyString is a string with ANSI escape sequence which would change its color. this wrapper can help to do some operations over those string.

func NewPrettyString 

func NewPrettyString(s string) PrettyString

NewPrettyString wraps a string with ANSI escape seuqnces with PrettyString.

func (PrettyString) Len 

func (ps PrettyString) Len() int

Len returns the length of the string with removal of all ANSI sequences. ("The raw length") . Example: "\e[38;5;226mhello, world\e[0m".Len() => 12 Note: The length of golden string "hello, world" is 12.

func (PrettyString) Pretty 

func (ps PrettyString) Pretty() string

Pretty returns the pretty form of the string: with keeping all ANSI escape sequences. Example: "\e[38;5;226mhello, world\e[0m".Pretty() => "\e[38;5;226mhello, world\e[0m"

func (PrettyString) Raw 

func (ps PrettyString) Raw() string

Raw returns the raw form of the pretty string: with removal of all ANSI escape sequences. Example: "\e[38;5;226mhello, world\e[0m".Raw() => "hello, world"

func (PrettyString) SplitAt 

func (ps PrettyString) SplitAt(n int) (left, right PrettyString)

SplitAt splits a pretty string at the place and ignoring all formats. Example: "\e[38;5;226mhello, world\e[0m".SplitAt(5) => ["\e[38;5;226mhello", ", world\e[0m"]

type Progress 

type Progress interface {
	// Inc increases the progress. This method must be goroutine-safe, and can
	// be called from any goroutine.
	Inc()
	// IncBy increases the progress by cnt. This method must be goroutine-safe, and can
	// be called from any goroutine.
	IncBy(cnt int64)
	// GetCurrent reports the progress.
	GetCurrent() int64
	// Close marks the progress as 100% complete and that Inc() can no longer be
	// called.
	Close()
}

Progress is an interface recording the current execution progress.

type ProgressWaiter 

type ProgressWaiter interface {
	Progress
	Wait(context.Context) error
}

ProgressWaiter is the extended `Progress“: which provides a `wait` method to allow caller wait until all unit in the progress finished.

type Session 

type Session interface {
	Execute(ctx context.Context, sql string) error
	ExecuteInternal(ctx context.Context, sql string, args ...any) error
	CreateDatabase(ctx context.Context, schema *model.DBInfo) error
	CreateTable(ctx context.Context, dbName pmodel.CIStr, table *model.TableInfo,
		cs ...ddl.CreateTableOption) error
	CreatePlacementPolicy(ctx context.Context, policy *model.PolicyInfo) error
	Close()
	GetGlobalVariable(name string) (string, error)
	GetSessionCtx() sessionctx.Context
}

Session is an abstraction of the session.Session interface.

type StdIOGlue 

type StdIOGlue struct{}

StdIOGlue is the console glue for CLI applications, like the BR CLI.

func (StdIOGlue) In 

func (s StdIOGlue) In() io.Reader

func (StdIOGlue) Out 

func (s StdIOGlue) Out() io.Writer

type Table 

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

func (*Table) Add 

func (t *Table) Add(key, value string)

func (*Table) Print 

func (t *Table) Print()

Print prints the table. The format would be like: 

 Key1: <Value>
Other: <Value>

LongKey: <Value> The format may change if the terminal size is small.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.