metrics

Documentation

Index

• func AgentMiddleware(next http.Handler) http.Handler
• func NewResponseWriter(w http.ResponseWriter) *responseWriter
• func ProxyMiddleware(next http.Handler) http.Handler
• func Server(ctx context.Context, port int, version dom.AppInfo) (start func(context.Context) error, stop func(context.Context) error)
• func WorkerMiddleware() asynq.MiddlewareFunc
• type Config
• type S3Service
  • func NewS3Service(enabled bool) S3Service

Functions

func AgentMiddleware

func AgentMiddleware(next http.Handler) http.Handler

func NewResponseWriter

func NewResponseWriter(w http.ResponseWriter) *responseWriter

func ProxyMiddleware

func ProxyMiddleware(next http.Handler) http.Handler

func Server

func Server(ctx context.Context, port int, version dom.AppInfo) (start func(context.Context) error, stop func(context.Context) error)

func WorkerMiddleware

func WorkerMiddleware() asynq.MiddlewareFunc

Types

type Config

type Config struct {
	Enabled bool `yaml:"enabled"`
	Port    int  `yaml:"port"`
}

type S3Service

type S3Service interface {
	Count(flow xctx.Flow, storage string, method s3.Method)
	Upload(flow xctx.Flow, storage, bucket string, bytes int)
	Download(flow xctx.Flow, storage, bucket string, bytes int)

	RcloneCalcMemUsageInc(bytes int64)
	RcloneCalcMemUsageDec(bytes int64)
	RcloneCalcFileSizeInc(bytes int64)
	RcloneCalcFileSizeDec(bytes int64)
	RcloneCalcFileNumInc()
	RcloneCalcFileNumDec()
}

func NewS3Service

func NewS3Service(enabled bool) S3Service