server

Documentation

Index

• func MockGetClient(t *testing.T, svrConn string) (*xrpc.Client, func())
• func MockWaitLeaderEggs(servers []*Server, leadernums int)
• type NodeRPC
  • func (n *NodeRPC) AddIdleNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error
  • func (n *NodeRPC) AddNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error
  • func (n *NodeRPC) GetNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error
  • func (n *NodeRPC) RemoveIdleNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error
  • func (n *NodeRPC) RemoveNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error
• type RPCS
• type Server
  • func MockServers(log *xlog.Log, port int, count int) ([]*Server, func())
  • func NewServer(conf *config.Config, log *xlog.Log) *Server
  • func (s *Server) Address() string
  • func (s *Server) GetNodeRPC() *NodeRPC
  • func (s *Server) GetServerRPC() *ServerRPC
  • func (s *Server) GetState() raft.State
  • func (s *Server) GetUserRPC() *UserRPC
  • func (s *Server) Init()
  • func (s *Server) Shutdown()
  • func (s *Server) Start()
  • func (s *Server) Wait()
• type ServerRPC
  • func (s *ServerRPC) Ping(req *model.ServerRPCRequest, rsp *model.ServerRPCResponse) error
  • func (s *ServerRPC) Status(req *model.ServerRPCRequest, rsp *model.ServerRPCResponse) error
• type UserRPC
  • func (u *UserRPC) ChangePasword(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error
  • func (u *UserRPC) CreateNormalUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error
  • func (u *UserRPC) CreateSuperUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error
  • func (u *UserRPC) CreateUserWithPrivileges(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error
  • func (u *UserRPC) DropUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error
  • func (u *UserRPC) GetUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

Functions

func MockGetClient

func MockGetClient(t *testing.T, svrConn string) (*xrpc.Client, func())

xrpc client

func MockWaitLeaderEggs

func MockWaitLeaderEggs(servers []*Server, leadernums int)

wait the leader eggs when leadernums >0 if leadernums == 0, we just want to sleep for a heartbeat broadcast

Types

type NodeRPC

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

func (*NodeRPC) AddIdleNodes

func (n *NodeRPC) AddIdleNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error

func (*NodeRPC) AddNodes

func (n *NodeRPC) AddNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error

func (*NodeRPC) GetNodes

func (n *NodeRPC) GetNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error

func (*NodeRPC) RemoveIdleNodes

func (n *NodeRPC) RemoveIdleNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error

func (*NodeRPC) RemoveNodes

func (n *NodeRPC) RemoveNodes(req *model.NodeRPCRequest, rsp *model.NodeRPCResponse) error

type RPCS

type RPCS struct {
	NodeRPC   *NodeRPC
	ServerRPC *ServerRPC
	UserRPC   *UserRPC
	HARPC     *raft.HARPC
	RaftRPC   *raft.RaftRPC
	MysqldRPC *mysqld.MysqldRPC
	BackupRPC *mysqld.BackupRPC
	MysqlRPC  *mysql.MysqlRPC
}

type Server

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

func MockServers

func MockServers(log *xlog.Log, port int, count int) ([]*Server, func())

func NewServer

func NewServer(conf *config.Config, log *xlog.Log) *Server

func (*Server) Address

func (s *Server) Address() string

func (*Server) GetNodeRPC

func (s *Server) GetNodeRPC() *NodeRPC

func (*Server) GetServerRPC

func (s *Server) GetServerRPC() *ServerRPC

func (*Server) GetState

func (s *Server) GetState() raft.State

func (*Server) GetUserRPC

func (s *Server) GetUserRPC() *UserRPC

func (*Server) Init

func (s *Server) Init()

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) Start

func (s *Server) Start()

start rpc-raft and event&&state-loop

func (*Server) Wait

func (s *Server) Wait()

waits for os signal

type ServerRPC

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

func (*ServerRPC) Ping

func (s *ServerRPC) Ping(req *model.ServerRPCRequest, rsp *model.ServerRPCResponse) error

check the server connection whether OK

func (*ServerRPC) Status

func (s *ServerRPC) Status(req *model.ServerRPCRequest, rsp *model.ServerRPCResponse) error

type UserRPC

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

func (*UserRPC) ChangePasword

func (u *UserRPC) ChangePasword(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

change password

func (*UserRPC) CreateNormalUser

func (u *UserRPC) CreateNormalUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

CreateNormalUser used to create a normal user.

func (*UserRPC) CreateSuperUser

func (u *UserRPC) CreateSuperUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

CreateSuperUser used to create a admin user with all grants.

func (*UserRPC) CreateUserWithPrivileges

func (u *UserRPC) CreateUserWithPrivileges(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

CreateUserWithPrivileges creates user with privileges. This is used to create normal user.

func (*UserRPC) DropUser

func (u *UserRPC) DropUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

drop user

func (*UserRPC) GetUser

func (u *UserRPC) GetUser(req *model.MysqlUserRPCRequest, rsp *model.MysqlUserRPCResponse) error

GetUser get mysql user list