server

Documentation

Index

• type Handler
  • func NewHandler(r ReindexCtl) *Handler
  • func (r *Handler) Reindex(c *gin.Context)
• type HealthzOK
• type Index
• type ReindexCtl
• type ReindexErr
• type ReindexOK
• type ReindexReq
• type Server
  • func New(port string, ctl ReindexCtl) *Server
  • func (s *Server) Run(ctx context.Context) error

Types

type Handler

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

func NewHandler

func NewHandler(r ReindexCtl) *Handler

func (*Handler) Reindex

func (r *Handler) Reindex(c *gin.Context)

type HealthzOK

type HealthzOK struct {
	Msg string `json:"msg"`
}

type Index

type Index struct {
	Index string `json:"index"`
}

type ReindexCtl

type ReindexCtl interface {
	PublishReindexTask(ctx context.Context, src, dest string) (string, error)
}

type ReindexErr

type ReindexErr struct {
	Msg string `json:"msg"`
}

type ReindexOK

type ReindexOK struct {
	ID string `json:"id"`
}

type ReindexReq

type ReindexReq struct {
	Source Index `json:"source"`
	Dest   Index `json:"dest"`
}

type Server

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

func New

func New(port string, ctl ReindexCtl) *Server

func (*Server) Run

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