server

package

v0.3.0 Latest Latest Go to latest Published: Mar 24, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Details

View Source

const RequestHistorySize = 100

This section is empty.

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

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

func LoggingMiddleware(next http.Handler) http.Handler

LoggingMiddleware logs request/response details

type Completion struct {
	Ret     any
	Status  int
	Message string
}

type HandleFunc func(any) (any, *httperr.Error)

type Hashable interface {
	Hash() (string, error)
}

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

func (s *HttpServer) Start() error

func (s *HttpServer) Stop(err error)

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

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

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

func (q *TrailingDelayQueue) Shutdown()

func (q *TrailingDelayQueue) Submit(item Hashable) (string, error)