metrics

Documentation

Index

• Constants
• Variables
• type Config
  • func DefaultConfig() Config
  • func (c Config) Validate() []error
• type Server
  • func New(config Config, rpcServer *grpc.Server) (*Server, error)
  • func (s *Server) Handler() http.Handler
  • func (s *Server) ListenAndServe(h http.Handler) error
  • func (s *Server) Shutdown(ctx context.Context) error

Constants

const DefaultNetwork = "tcp"

Variables

var (
	DownloadCount = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: constants.MetricsNamespace,
		Subsystem: constants.CDNMetricsName,
		Name:      "download_total",
		Help:      "Counter of the number of the downloading.",
	})

	DownloadFailureCount = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: constants.MetricsNamespace,
		Subsystem: constants.CDNMetricsName,
		Name:      "download_failure_total",
		Help:      "Counter of the number of failed of the downloading.",
	})

	DownloadTraffic = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: constants.MetricsNamespace,
		Subsystem: constants.CDNMetricsName,
		Name:      "download_traffic",
		Help:      "Counter of the number of download traffic.",
	})

	ConcurrentDownloadGauge = promauto.NewGauge(prometheus.GaugeOpts{
		Namespace: constants.MetricsNamespace,
		Subsystem: constants.CDNMetricsName,
		Name:      "concurrent_download_total",
		Help:      "Gauger of the number of concurrent of the downloading.",
	})
)

Variables declared for metrics.

Types

type Config

type Config struct {
	Net  string `yaml:"net" mapstructure:"net"`
	Addr string `yaml:"addr" mapstructure:"addr"`
}

func DefaultConfig

func DefaultConfig() Config

func (Config) Validate

func (c Config) Validate() []error

type Server

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

func New

func New(config Config, rpcServer *grpc.Server) (*Server, error)

func (*Server) Handler

func (s *Server) Handler() http.Handler

Handler returns an http handler for the blob server.

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(h http.Handler) error

ListenAndServe is a blocking call which runs s.

func (*Server) Shutdown

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