admin

type Client ¶

type Client interface {
	CreateTable(ctx context.Context, tableName string, partitionCount int) error

	DropTable(ctx context.Context, tableName string) error

	ListTables(ctx context.Context) ([]*TableInfo, error)
}

Client provides the administration API to a specific cluster. Remember only the superusers configured to the cluster have the admin priviledges.

func NewClient(cfg Config) Client

type Config ¶

type Config struct {
	MetaServers []string `json:"meta_servers"`
}

type RemoteCmdClient ¶

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

RemoteCmdClient is a client to call remote command to a PegasusServer.

func NewRemoteCmdClient(addr string, nodeType session.NodeType) *RemoteCmdClient

func (c *RemoteCmdClient) Call(ctx context.Context, command string, arguments []string) (cmdResult string, err error)

type RemoteCommand ¶

type RemoteCommand struct {
	Command   string
	Arguments []string
}

RemoteCommand can be called concurrently by multiple sessions.

func (c *RemoteCommand) Call(ctx context.Context, session session.NodeSession) (cmdResult string, err error)

type TableInfo ¶

type TableInfo struct {
	Name string

	// Envs is a set of attributes binding to this table.
	Envs map[string]string
}

TableInfo is the table information.