server

package

v0.1.0 Latest Latest Go to latest Published: Jun 28, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sealdb/neoha

Links

Open Source Insights

Documentation ¶

Index ¶

func MockGetClient(t *testing.T, svrConn string) (*nrpc.Client, func())
func MockInitGTID(servers []*Server)
func MockPrepareTryToLeader(s *Server, replMode model.MysqlReplMode)
func MockWaitServerLeaderEggs(servers []*Server, leadernums int, replMode model.MysqlReplMode)
type NodeRPC
type RPCS
type Server
- func MockServers(log *nlog.Log, port int, count int, replMode model.MysqlReplMode) ([]*Server, func())
- func NewServer(conf *config.Config, log *nlog.Log, state ServerState) *Server
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 ServerState
type UserRPC

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func MockGetClient ¶

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

nrpc client

func MockInitGTID ¶

func MockInitGTID(servers []*Server)

func MockPrepareTryToLeader ¶

func MockPrepareTryToLeader(s *Server, replMode model.MysqlReplMode)

MockPrepareTryToLeader refreshes the mysql mock and ping state on a server before neohactl raft trytoleader (former leader may be MYSQL_DEAD after MGR leader loop).

func MockWaitServerLeaderEggs ¶

func MockWaitServerLeaderEggs(servers []*Server, leadernums int, replMode model.MysqlReplMode)

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 *nlog.Log, port int, count int, replMode model.MysqlReplMode) ([]*Server, func())

func NewServer ¶

func NewServer(conf *config.Config, log *nlog.Log, state ServerState) *Server

func (*Server) Address ¶

func (s *Server) Address() string

func (*Server) GetElection ¶

func (s *Server) GetElection() *election.Election

func (*Server) GetNodeRPC ¶

func (s *Server) GetNodeRPC() *NodeRPC

func (*Server) GetServerRPC ¶

func (s *Server) GetServerRPC() *ServerRPC

func (*Server) GetUserRPC ¶

func (s *Server) GetUserRPC() *UserRPC

func (*Server) Init ¶

func (s *Server) Init()

func (*Server) MySQLAdmin ¶

func (s *Server) MySQLAdmin() string

MySQLAdmin returns the mysql admin user.

func (*Server) MySQLPasswd ¶

func (s *Server) MySQLPasswd() string

MySQLPasswd returns the mysql admin password.

func (*Server) PeerAddress ¶

func (s *Server) PeerAddress() string

PeerAddress returns the peer address.

func (*Server) Shutdown ¶

func (s *Server) Shutdown()

func (*Server) Start ¶

func (s *Server) Start()

Start server

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 ServerState ¶

type ServerState int

ServerState used for server state.

const (
	ServerLeader ServerState = 1 << iota
	ServerFollower
	ServerIdle
	ServerLearner
	ServerUnknown
)

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL