srv

Documentation

Index

• Variables
• func ParserCfg() (*config.Options, error)
• func ProvideOpts(c goleveldb.Option) []goleveldb.Option
• func RegisterGoleveldb(options *config.Options) error
• func RegisterLogStoreGoleveldb(options *config.Options) error
• func RegisterMemGoleveldb(options *config.Options) error
• func RegisterReplicaMasterSlaveRespCmdSrv(options *config.Options) error
• func RegisterStandaloneRespCmdSrv(options *config.Options) error
• func RegisterXdisStorager(options *config.Options) error
• func RegisterXdisTikv(options *config.Options) error
• func SetupCmdRoutes(h *server.Hertz, s *Server)
• func SetupProbeRoutes(h *server.Hertz)
• type Server
  • func NewServer(contextContext context.Context, options *config.Options) (*Server, error)
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) SetupRoutes(h *server.Hertz)
  • func (s *Server) Stop()

Variables

var (
	ConfigOpts *config.Options
)

Functions

func ParserCfg

func ParserCfg() (*config.Options, error)

ParserCfg config paser

func ProvideOpts

func ProvideOpts(
	c goleveldb.Option,
) []goleveldb.Option

func RegisterGoleveldb

func RegisterGoleveldb(options *config.Options) error

RegisterGoleveldb register kv store engine goleveldb

func RegisterLogStoreGoleveldb

func RegisterLogStoreGoleveldb(options *config.Options) error

RegisterLogStoreGoleveldb register log store engine goleveldb

func RegisterMemGoleveldb

func RegisterMemGoleveldb(options *config.Options) error

RegisterMemGoleveldb regisiter kv store engine memory goleveldb

func RegisterReplicaMasterSlaveRespCmdSrv

func RegisterReplicaMasterSlaveRespCmdSrv(options *config.Options) error

func RegisterStandaloneRespCmdSrv

func RegisterStandaloneRespCmdSrv(options *config.Options) error

func RegisterXdisStorager

func RegisterXdisStorager(options *config.Options) error

RegisterXdisStorager register storager xdis-storager

func RegisterXdisTikv

func RegisterXdisTikv(options *config.Options) error

RegisterXdisTikv register storager xdis-tikv

func SetupCmdRoutes

func SetupCmdRoutes(h *server.Hertz, s *Server)

func SetupProbeRoutes

func SetupProbeRoutes(h *server.Hertz)

Types

type Server

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

func NewServer

func NewServer(contextContext context.Context, options *config.Options) (*Server, error)

NewServer server init

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run reviews server

func (*Server) SetupRoutes

func (s *Server) SetupRoutes(h *server.Hertz)

func (*Server) Stop

func (s *Server) Stop()