server

Documentation

Index

• Variables
• func ExtractNodeCommonNameFromCert(c *gin.Context)
• func ExtractNodeCommonNameFromHeader(c *gin.Context)
• func Health(c *gin.Context)
• func LoggerHandler(c *gin.Context)
• func NoMethodHandler(c *gin.Context)
• func NoRouteHandler(c *gin.Context)
• func RequestIDHandler(c *gin.Context)
• type ActiveServer
  • func NewActiveServer(config *config.CloudConfig) (*ActiveServer, error)
  • func (s *ActiveServer) Close()
  • func (s *ActiveServer) GetRoute() *gin.Engine
  • func (s *ActiveServer) InitRoute()
  • func (s *ActiveServer) Run()
  • func (s *ActiveServer) SetAPI(api *api.API)
• type AdminServer
  • func NewAdminServer(config *config.CloudConfig) (*AdminServer, error)
  • func (s *AdminServer) Close()
  • func (s *AdminServer) GetRoute() *gin.Engine
  • func (s *AdminServer) InitRoute()
  • func (s *AdminServer) Run()
  • func (s *AdminServer) SetAPI(api *api.API)
• type HandlerMessage
• type MisServer
  • func NewMisServer(config *config.CloudConfig) (*MisServer, error)
  • func (s *MisServer) Close()
  • func (s *MisServer) GetRoute() *gin.Engine
  • func (s *MisServer) InitRoute()
  • func (s *MisServer) Run()
  • func (s *MisServer) SetAPI(api *api.API)
• type SyncServer
  • func NewSyncServer(cfg *config.CloudConfig) (*SyncServer, error)
  • func (s *SyncServer) Close()
  • func (s *SyncServer) InitMsgRouter()
  • func (s *SyncServer) Run()
  • func (s *SyncServer) SetSyncAPI(a api.SyncAPI)

Variables

var (
	HeaderCommonName = "common-name"
)

Functions

func ExtractNodeCommonNameFromCert

func ExtractNodeCommonNameFromCert(c *gin.Context)

func ExtractNodeCommonNameFromHeader

func ExtractNodeCommonNameFromHeader(c *gin.Context)

func Health

func Health(c *gin.Context)

func LoggerHandler

func LoggerHandler(c *gin.Context)

func NoMethodHandler

func NoMethodHandler(c *gin.Context)

func NoRouteHandler

func NoRouteHandler(c *gin.Context)

func RequestIDHandler

func RequestIDHandler(c *gin.Context)

Types

type ActiveServer

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

func NewActiveServer

func NewActiveServer(config *config.CloudConfig) (*ActiveServer, error)

NewActiveServer new active server

func (*ActiveServer) Close

func (s *ActiveServer) Close()

Close close server

func (*ActiveServer) GetRoute

func (s *ActiveServer) GetRoute() *gin.Engine

GetRoute get router

func (*ActiveServer) InitRoute

func (s *ActiveServer) InitRoute()

func (*ActiveServer) Run

func (s *ActiveServer) Run()

Run run server

func (*ActiveServer) SetAPI

func (s *ActiveServer) SetAPI(api *api.API)

type AdminServer

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

AdminServer admin server

func NewAdminServer

func NewAdminServer(config *config.CloudConfig) (*AdminServer, error)

NewAdminServer create admin server

func (*AdminServer) Close

func (s *AdminServer) Close()

Close close server

func (*AdminServer) GetRoute

func (s *AdminServer) GetRoute() *gin.Engine

GetRoute get router

func (*AdminServer) InitRoute

func (s *AdminServer) InitRoute()

InitRoute init router

func (*AdminServer) Run

func (s *AdminServer) Run()

func (*AdminServer) SetAPI

func (s *AdminServer) SetAPI(api *api.API)

type HandlerMessage

type HandlerMessage func(msg specV1.Message) (*specV1.Message, error)

type MisServer

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

MisServer mis server

func NewMisServer

func NewMisServer(config *config.CloudConfig) (*MisServer, error)

NewMisServer create Mis server

func (*MisServer) Close

func (s *MisServer) Close()

Close close server

func (*MisServer) GetRoute

func (s *MisServer) GetRoute() *gin.Engine

func (*MisServer) InitRoute

func (s *MisServer) InitRoute()

func (*MisServer) Run

func (s *MisServer) Run()

Run run server

func (*MisServer) SetAPI

func (s *MisServer) SetAPI(api *api.API)

type SyncServer

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

func NewSyncServer

func NewSyncServer(cfg *config.CloudConfig) (*SyncServer, error)

func (*SyncServer) Close

func (s *SyncServer) Close()

func (*SyncServer) InitMsgRouter

func (s *SyncServer) InitMsgRouter()

func (*SyncServer) Run

func (s *SyncServer) Run()

func (*SyncServer) SetSyncAPI

func (s *SyncServer) SetSyncAPI(a api.SyncAPI)