meta

Documentation

Index

• func Proc(ctx context.Context, tstmt spqrparser.Statement, mgr EntityMgr, ...) error
• func ProcessKill(ctx context.Context, stmt *spqrparser.Kill, mngr EntityMgr, pool client.Pool, ...) error
• func ProcessShow(ctx context.Context, stmt *spqrparser.Show, mngr EntityMgr, ...) error
• type EntityMgr

Functions

func Proc

func Proc(ctx context.Context, tstmt spqrparser.Statement, mgr EntityMgr, ci connectiterator.ConnectIterator, cli *clientinteractor.PSQLInteractor, writer workloadlog.WorkloadLog) error

Proc processes various coordinator commands based on the provided statement.

Parameters: - ctx (context.Context): The context for the function. - tstmt (spqrparser.Statement): The statement to be processed. - mgr (EntityMgr): The entity manager. - ci (connectiterator.ConnectIterator): The connect iterator. - cli (*clientinteractor.PSQLInteractor): The PSQL interactor. - writer (workloadlog.WorkloadLog): The workload log writer.

Returns: - error: An error if the operation fails, otherwise nil.

func ProcessKill

func ProcessKill(ctx context.Context, stmt *spqrparser.Kill, mngr EntityMgr, pool client.Pool, cli *clientinteractor.PSQLInteractor) error

ProcessKill processes the kill command based on the statement provided.

Parameters: - ctx (context.Context): The context for the operation. - stmt (*spqrparser.Kill): The kill statement to process. - mngr (EntityMgr): The entity manager for managing entities. - pool (client.Pool): The pool of clients. - cli (*clientinteractor.PSQLInteractor): The PSQL interactor for client interactions.

Returns: - error: An error if the operation encounters any issues.

func ProcessShow

func ProcessShow(ctx context.Context, stmt *spqrparser.Show, mngr EntityMgr, ci connectiterator.ConnectIterator, cli *clientinteractor.PSQLInteractor) error

ProcessShow processes the SHOW statement and returns an error if any issue occurs.

Parameters: - ctx (context.Context): The context for the operation. - stmt (*spqrparser.Show): The SHOW statement to process. - mngr (EntityMgr): The entity manager for managing entities. - ci (connectiterator.ConnectIterator): The connect iterator for connection interactions. - cli (*clientinteractor.PSQLInteractor): The PSQL interactor for client interactions.

Returns: - error: An error if the operation encounters any issues.

Types

type EntityMgr

type EntityMgr interface {
	kr.KeyRangeMgr
	topology.RouterMgr
	datashards.ShardsMgr
	distributions.DistributionMgr
	tasks.TaskMgr

	ShareKeyRange(id string) error

	QDB() qdb.QDB
	Cache() *cache.SchemaCache
}