metrics

Documentation

Index

• Constants
• type Client
• type CollectorClient
  • func New(envSettings config.ProxyEnvSettings, apiClient apiclient.ClientInterface) *CollectorClient
  • func (c *CollectorClient) SendMetric(name string, metricType string, value float64, ...) error
  • func (c *CollectorClient) StopBatchProcess()
• type Handler
  • func NewHandler(client Client) *Handler
  • func (h *Handler) HandleRequest(req *http.Request, ctx *goproxy.ProxyCtx) (*http.Request, *http.Response)
  • func (h *Handler) HandleResponse(rsp *http.Response, ctx *goproxy.ProxyCtx) *http.Response

Constants

const MaxPayloadSize = 1_000_000 // 1MB in bytes

Types

type Client

type Client interface {
	SendMetric(name string, metricType string, value float64, additionalTags map[string]string) error
}

MetricsClient defines the interface for a metrics collector client.

type CollectorClient

type CollectorClient struct {
	APIClient     apiclient.ClientInterface
	APIEndpoint   string
	DefaultTags   map[string]string
	JobID         string
	MetricsBuffer []map[string]interface{}
	BufferMutex   sync.Mutex
	MaxBufferSize int
	FlushTicker   *time.Ticker
	// contains filtered or unexported fields
}

func New

func New(envSettings config.ProxyEnvSettings, apiClient apiclient.ClientInterface) *CollectorClient

Returns the instance of CollectorClient

func (*CollectorClient) SendMetric

func (c *CollectorClient) SendMetric(name string, metricType string, value float64, additionalTags map[string]string) error

func (*CollectorClient) StopBatchProcess

func (c *CollectorClient) StopBatchProcess()

Method to stop the batch process

type Handler

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

Handler records request metrics

func NewHandler

func NewHandler(client Client) *Handler

NewHandler returns a new MetricsHandler

func (*Handler) HandleRequest

func (h *Handler) HandleRequest(req *http.Request, ctx *goproxy.ProxyCtx) (*http.Request, *http.Response)

HandleRequest sets up a request for metrics

func (*Handler) HandleResponse

func (h *Handler) HandleResponse(rsp *http.Response, ctx *goproxy.ProxyCtx) *http.Response

HandleResponse records metrics for a response