server

Documentation

Index

• type DiagnoseAPIConfig
• type DiagnoseService
  • func NewService() *DiagnoseService
  • func (s *DiagnoseService) Done(ctx *gin.Context)
  • func (s *DiagnoseService) Heahlty(ctx *gin.Context)
  • func (s *DiagnoseService) Mock(c *gin.Context)
  • func (s *DiagnoseService) RegisterEndpoint(ctx *gin.Context)
  • func (s *DiagnoseService) SubmitReport(ctx *gin.Context)
• type HTTPServerBean
  • func NewHTTPServerBean(port int) *HTTPServerBean
  • func (s *HTTPServerBean) Init(e framework.ConfBeanRegistry) error
  • func (s *HTTPServerBean) Run(ctx context.Context) error
  • func (s *HTTPServerBean) ServerName() string
  • func (s *HTTPServerBean) Start(ctx context.Context, e framework.ConfBeanRegistry) error
  • func (s *HTTPServerBean) Validate(errs *errorcode.Errs)
  • func (s *HTTPServerBean) WaitClient(ctx context.Context) string
  • func (s *HTTPServerBean) WaitClose(ctx context.Context)
  • func (s *HTTPServerBean) WaitReport(ctx context.Context) []*diagnose.MetricItem

Types

type DiagnoseAPIConfig

type DiagnoseAPIConfig struct {
	HTTPPort     int32 `yaml:"HTTPPort,omitempty"`
	Debug        bool
	ReadTimeout  int
	WriteTimeout int
	IdleTimeout  int
}

type DiagnoseService

type DiagnoseService struct {
	PeerDone       bool
	CanStartClient bool
	RecReportDone  bool
	PeerEndpoint   string
	Report         []*diagnose.MetricItem
}

func NewService

func NewService() *DiagnoseService

func (*DiagnoseService) Done

func (s *DiagnoseService) Done(ctx *gin.Context)

func (*DiagnoseService) Heahlty

func (s *DiagnoseService) Heahlty(ctx *gin.Context)

func (*DiagnoseService) Mock

func (s *DiagnoseService) Mock(c *gin.Context)

func (*DiagnoseService) RegisterEndpoint

func (s *DiagnoseService) RegisterEndpoint(ctx *gin.Context)

func (*DiagnoseService) SubmitReport

func (s *DiagnoseService) SubmitReport(ctx *gin.Context)

type HTTPServerBean

type HTTPServerBean struct {
	Service *DiagnoseService
	// contains filtered or unexported fields
}

func NewHTTPServerBean

func NewHTTPServerBean(port int) *HTTPServerBean

func (*HTTPServerBean) Init

func (s *HTTPServerBean) Init(e framework.ConfBeanRegistry) error

func (*HTTPServerBean) Run

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

func (*HTTPServerBean) ServerName

func (s *HTTPServerBean) ServerName() string

func (*HTTPServerBean) Start

func (s *HTTPServerBean) Start(ctx context.Context, e framework.ConfBeanRegistry) error

func (*HTTPServerBean) Validate

func (s *HTTPServerBean) Validate(errs *errorcode.Errs)

func (*HTTPServerBean) WaitClient

func (s *HTTPServerBean) WaitClient(ctx context.Context) string

func (*HTTPServerBean) WaitClose

func (s *HTTPServerBean) WaitClose(ctx context.Context)

func (*HTTPServerBean) WaitReport

func (s *HTTPServerBean) WaitReport(ctx context.Context) []*diagnose.MetricItem