server

Documentation

Index

• Variables
• func NewGRPCServer(bc *rabbitconf.Bootstrap) *grpc.Server
• func NewHTTPServer(bc *rabbitconf.Bootstrap) *http.Server
• type HeartbeatServer
  • func (h *HeartbeatServer) Start(ctx context.Context) error
  • func (h *HeartbeatServer) Stop(_ context.Context) error
• type Server
  • func RegisterService(bc *rabbitconf.Bootstrap, data *data.Data, rpcSrv *grpc.Server, ...) *Server
  • func (s *Server) GetHTTPServer() *http.Server
  • func (s *Server) GetRPCServer() *grpc.Server
  • func (s *Server) GetServers() []transport.Server

Variables

var ProviderSetServer = wire.NewSet(NewGRPCServer, NewHTTPServer, RegisterService)

ProviderSetServer is server providers.

Functions

func NewGRPCServer

func NewGRPCServer(bc *rabbitconf.Bootstrap) *grpc.Server

NewGRPCServer new a gRPC server.

func NewHTTPServer

func NewHTTPServer(bc *rabbitconf.Bootstrap) *http.Server

NewHTTPServer new an HTTP server.

Types

type HeartbeatServer

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

HeartbeatServer 心跳包服务

func (*HeartbeatServer) Start

func (h *HeartbeatServer) Start(ctx context.Context) error

Start 启动心跳包服务

func (*HeartbeatServer) Stop

func (h *HeartbeatServer) Stop(_ context.Context) error

Stop 停止心跳包服务

type Server

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

Server 服务

func RegisterService

func RegisterService(
	bc *rabbitconf.Bootstrap,
	data *data.Data,
	rpcSrv *grpc.Server,
	httpSrv *http.Server,
	configService *service.ConfigService,
	hookService *service.HookService,
	healthService *service.HealthService,
) *Server

RegisterService 注册服务

func (*Server) GetHTTPServer

func (s *Server) GetHTTPServer() *http.Server

GetHTTPServer 获取http server

func (*Server) GetRPCServer

func (s *Server) GetRPCServer() *grpc.Server

GetRPCServer 获取rpc server

func (*Server) GetServers

func (s *Server) GetServers() []transport.Server

GetServers 注册服务