server

Documentation

Index

• Variables
• func NewGRPCServer(bc *palaceconf.Bootstrap) *grpc.Server
• func NewHTTPServer(bc *palaceconf.Bootstrap, authService *authorization.Service) *http.Server
• type Server
  • func RegisterService(c *palaceconf.Bootstrap, data *data.Data, alertService *service.AlertService, ...) *Server
  • func (s *Server) GetHTTPServer() *http.Server
  • func (s *Server) GetRPCServer() *grpc.Server
  • func (s *Server) GetServers() []transport.Server
• type StrategyWatch
  • func (s *StrategyWatch) Start(_ context.Context) error
  • func (s *StrategyWatch) Stop(_ context.Context) error

Variables

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

ProviderSetServer is server providers.

Functions

func NewGRPCServer

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

NewGRPCServer new a gRPC server.

func NewHTTPServer

func NewHTTPServer(bc *palaceconf.Bootstrap, authService *authorization.Service) *http.Server

NewHTTPServer new an HTTP server.

Types

type Server

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

Server 服务

func RegisterService

func RegisterService(
	c *palaceconf.Bootstrap,
	data *data.Data,
	alertService *service.AlertService,
	serverService *service.ServerService,
	rpcSrv *grpc.Server,
	httpSrv *http.Server,
	healthService *service.HealthService,
	userService *user.Service,
	authorizationService *authorization.Service,
	resourceService *resource.Service,
	teamService *team.Service,
	teamRoleService *team.RoleService,
	datasourceService *datasource.Service,
	menuService *menu.Service,
	metricService *datasource.MetricService,
	dictService *dict.Service,
	strategyService *strategy.Service,
	strategyTemplateService *strategy.TemplateService,
	dashboardService *realtime.DashboardService,
	alarmService *realtime.AlarmService,
	alarmPageSelfService *realtime.AlarmPageSelfService,
	alarmGroupService *alarm.GroupService,
	subscriberService *subscriber.Service,
	hookService *hook.Service,
	inviteService *invite.Service,
	messageService *user.MessageService,
	historyService *history.Service,
	fileService *file.Service,
	systemService *system.Service,
) *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 注册服务

type StrategyWatch

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

StrategyWatch 策略任务执行器

func (*StrategyWatch) Start

func (s *StrategyWatch) Start(_ context.Context) error

Start 启动策略任务执行器

func (*StrategyWatch) Stop

func (s *StrategyWatch) Stop(_ context.Context) error

Stop 停止策略任务执行器