server

Documentation

Index

• Constants
• func GetRunGroup() (func() error, func(error))
• func InitHttpServer(ctx context.Context, cfg *config.Config)
• type Completion
• type HTTPError
  • func NewHTTPError(code int, msg string) *HTTPError
  • func (e *HTTPError) Error() string
• type HandleFunc
• type HttpServer
  • func (s *HttpServer) Start() error
  • func (s *HttpServer) Stop(err error)
• type TrailingDelayQueue
  • func NewTrailingDelayQueue(handle HandleFunc, delay time.Duration) *TrailingDelayQueue
  • func (q *TrailingDelayQueue) Get(uid string) *Completion
  • func (q *TrailingDelayQueue) Shutdown()
  • func (q *TrailingDelayQueue) Submit(item interface{}) string

Constants

const RequestHistorySize = 100

Functions

func GetRunGroup

func GetRunGroup() (func() error, func(error))

func InitHttpServer

func InitHttpServer(ctx context.Context, cfg *config.Config)

Types

type Completion

type Completion struct {
	Ret     interface{}
	Status  int
	Message string
}

type HTTPError

type HTTPError struct {
	Code    int
	Message string
}

func NewHTTPError

func NewHTTPError(code int, msg string) *HTTPError

func (*HTTPError) Error

func (e *HTTPError) Error() string

type HandleFunc

type HandleFunc func(interface{}) (interface{}, *HTTPError)

type HttpServer

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

func (*HttpServer) Start

func (s *HttpServer) Start() error

func (*HttpServer) Stop

func (s *HttpServer) Stop(err error)

type TrailingDelayQueue

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

func NewTrailingDelayQueue

func NewTrailingDelayQueue(handle HandleFunc, delay time.Duration) *TrailingDelayQueue

func (*TrailingDelayQueue) Get

func (q *TrailingDelayQueue) Get(uid string) *Completion

func (*TrailingDelayQueue) Shutdown

func (q *TrailingDelayQueue) Shutdown()

func (*TrailingDelayQueue) Submit

func (q *TrailingDelayQueue) Submit(item interface{}) string