console

Documentation

Index

• type Console
  • func NewLocalInstanceConsole(mgr meta.EntityMgr, rrouter rulerouter.RuleRouter, stchan chan struct{}, ...) (Console, error)
• type LocalInstanceConsole
  • func (l *LocalInstanceConsole) Mgr() meta.EntityMgr
  • func (l *LocalInstanceConsole) ProcessQuery(ctx context.Context, q string, cl client.Client) error
  • func (l *LocalInstanceConsole) Qlog() qlog.Qlog
  • func (l *LocalInstanceConsole) Serve(ctx context.Context, cl client.Client) error
  • func (l *LocalInstanceConsole) Shutdown() error
• type TopoCntl

Types

type Console

type Console interface {
	Serve(ctx context.Context, cl client.Client) error
	ProcessQuery(ctx context.Context, q string, cl client.Client) error
	Qlog() qlog.Qlog
	Shutdown() error
	Mgr() meta.EntityMgr
}

func NewLocalInstanceConsole

func NewLocalInstanceConsole(mgr meta.EntityMgr, rrouter rulerouter.RuleRouter, stchan chan struct{}, writer workloadlog.WorkloadLog) (Console, error)

type LocalInstanceConsole

type LocalInstanceConsole struct {
	InstanceMgr meta.EntityMgr
	RRouter     rulerouter.RuleRouter
	// contains filtered or unexported fields
}

func (*LocalInstanceConsole) Mgr

func (l *LocalInstanceConsole) Mgr() meta.EntityMgr

func (*LocalInstanceConsole) ProcessQuery

func (l *LocalInstanceConsole) ProcessQuery(ctx context.Context, q string, cl client.Client) error

func (*LocalInstanceConsole) Qlog

func (l *LocalInstanceConsole) Qlog() qlog.Qlog

func (*LocalInstanceConsole) Serve

func (l *LocalInstanceConsole) Serve(ctx context.Context, cl client.Client) error

TODO : unit tests

func (*LocalInstanceConsole) Shutdown

func (l *LocalInstanceConsole) Shutdown() error

type TopoCntl

type TopoCntl interface {
	kr.KeyRangeMgr
	datashards.ShardsMgr
}