api

Documentation

Index

• Variables
• type AdminServer
  • func NewAdminServer(cfg *AdminServerConfig) *AdminServer
  • func (s *AdminServer) QuitNotify() <-chan struct{}
  • func (s *AdminServer) RegisterMiddleware()
  • func (s *AdminServer) RegisterURL()
  • func (s *AdminServer) SetApplierHandler(applierServer *applier.ApplierServer)
  • func (s *AdminServer) Start()
  • func (s *AdminServer) Stop()
• type AdminServerConfig
• type ApplierHandler
  • func (h *ApplierHandler) GetApplyProgress(ctx echo.Context) error
  • func (h *ApplierHandler) GetFailedTrxList(ctx echo.Context) error
  • func (h *ApplierHandler) GetWorkMode(ctx echo.Context) error
  • func (h *ApplierHandler) HealthCheck(ctx echo.Context) error
  • func (h *ApplierHandler) RetryFailedTrx(ctx echo.Context) error
  • func (h *ApplierHandler) SkipFailedTrx(ctx echo.Context) error
• type DebugHandler
  • func (h *DebugHandler) Profile(ctx echo.Context) error
• type Resp
  • func NewResp() *Resp
  • func (r *Resp) SetData(data interface{}) *Resp
  • func (r *Resp) SetError(msg string) *Resp

Variables

var (
	ErrStatusIllegal  = errors.New("api: status value is illegal")
	ErrArgsIllegal    = errors.New("api: args is illegal")
	ErrStatusNotReady = errors.New("api: status is not ready")
)

Types

type AdminServer

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

func NewAdminServer

func NewAdminServer(cfg *AdminServerConfig) *AdminServer

func (*AdminServer) QuitNotify

func (s *AdminServer) QuitNotify() <-chan struct{}

func (*AdminServer) RegisterMiddleware

func (s *AdminServer) RegisterMiddleware()

func (*AdminServer) RegisterURL

func (s *AdminServer) RegisterURL()

func (*AdminServer) SetApplierHandler

func (s *AdminServer) SetApplierHandler(applierServer *applier.ApplierServer)

func (*AdminServer) Start

func (s *AdminServer) Start()

func (*AdminServer) Stop

func (s *AdminServer) Stop()

type AdminServerConfig

type AdminServerConfig struct {
	Addr string
}

type ApplierHandler

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

func (*ApplierHandler) GetApplyProgress

func (h *ApplierHandler) GetApplyProgress(ctx echo.Context) error

func (*ApplierHandler) GetFailedTrxList

func (h *ApplierHandler) GetFailedTrxList(ctx echo.Context) error

func (*ApplierHandler) GetWorkMode

func (h *ApplierHandler) GetWorkMode(ctx echo.Context) error

func (*ApplierHandler) HealthCheck

func (h *ApplierHandler) HealthCheck(ctx echo.Context) error

func (*ApplierHandler) RetryFailedTrx

func (h *ApplierHandler) RetryFailedTrx(ctx echo.Context) error

func (*ApplierHandler) SkipFailedTrx

func (h *ApplierHandler) SkipFailedTrx(ctx echo.Context) error

type DebugHandler

type DebugHandler struct {
}

func (*DebugHandler) Profile

func (h *DebugHandler) Profile(ctx echo.Context) error

type Resp

type Resp struct {
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

func NewResp

func NewResp() *Resp

func (*Resp) SetData

func (r *Resp) SetData(data interface{}) *Resp

func (*Resp) SetError

func (r *Resp) SetError(msg string) *Resp