metrics

package

v0.7.1 Latest Latest Go to latest Published: Feb 5, 2026 License: Apache-2.0 Imports: 12 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/clyso/chorus

Links

Documentation ¶

Index ¶

func AgentMiddleware(next http.Handler) http.Handler
func NewResponseWriter(w http.ResponseWriter) *responseWriter
func NewS3Service(enabled bool) *svc
func ProxyMiddleware() func(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 Service
type WorkerService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AgentMiddleware ¶

func AgentMiddleware(next http.Handler) http.Handler

func NewResponseWriter ¶

func NewResponseWriter(w http.ResponseWriter) *responseWriter

func NewS3Service ¶

func NewS3Service(enabled bool) *svc

func ProxyMiddleware ¶

func ProxyMiddleware() func(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 Service ¶ added in v0.7.0

type Service interface {
	Count(flow xctx.Flow, storage string, method string)
	Upload(flow xctx.Flow, storage, bucket string, bytes int)
	Download(flow xctx.Flow, storage, bucket string, bytes int)
}

type WorkerService ¶ added in v0.7.0

type WorkerService interface {
	WorkerInProgressBytesInc(ctx context.Context, bytes int64)
	WorkerInProgressBytesDec(ctx context.Context, bytes int64)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL