server

Documentation

Index

• type Server
  • func NewServer(config conf.Config) (*Server, error)
  • func (s *Server) GetAPIServer() *api.Server
  • func (s *Server) GetCluster() cluster.Cluster
  • func (s *Server) GetCommandExecutor() *command.Executor
  • func (s *Server) GetConfig() conf.Config
  • func (s *Server) GetDDLClient() remoting.Broadcaster
  • func (s *Server) GetFailureInjector() failinject.Injector
  • func (s *Server) GetMetaController() *meta.Controller
  • func (s *Server) GetPullEngine() *pull.Engine
  • func (s *Server) GetPushEngine() *push.Engine
  • func (s *Server) GetRemotingServer() remoting.Server
  • func (s *Server) GetSharder() *sharder.Sharder
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Types

type Server

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

func NewServer

func NewServer(config conf.Config) (*Server, error)

func (*Server) GetAPIServer

func (s *Server) GetAPIServer() *api.Server

func (*Server) GetCluster

func (s *Server) GetCluster() cluster.Cluster

func (*Server) GetCommandExecutor

func (s *Server) GetCommandExecutor() *command.Executor

func (*Server) GetConfig

func (s *Server) GetConfig() conf.Config

func (*Server) GetDDLClient

func (s *Server) GetDDLClient() remoting.Broadcaster

func (*Server) GetFailureInjector

func (s *Server) GetFailureInjector() failinject.Injector

func (*Server) GetMetaController

func (s *Server) GetMetaController() *meta.Controller

func (*Server) GetPullEngine

func (s *Server) GetPullEngine() *pull.Engine

func (*Server) GetPushEngine

func (s *Server) GetPushEngine() *push.Engine

func (*Server) GetRemotingServer

func (s *Server) GetRemotingServer() remoting.Server

func (*Server) GetSharder

func (s *Server) GetSharder() *sharder.Sharder

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error