metrics

Documentation

Index

• Variables
• func UnaryClientInterceptor() func(ctx context.Context, method string, req, reply interface{}, ...) error
• func UnaryServerInterceptor() ...
• type HTTPStatusResponseWriter
  • func NewHTTPStatusResponseWriter(in http.ResponseWriter) *HTTPStatusResponseWriter
  • func (r *HTTPStatusResponseWriter) Write(in []byte) (int, error)
  • func (r *HTTPStatusResponseWriter) WriteHeader(statusCode int)
• type HTTPTracker
  • func NewHTTPMetric(pr PathRetriever) HTTPTracker
• type MetricTracker
  • func NewDatabaseTracker(db *sql.DB) MetricTracker
  • func NewGrpcClientTracker() MetricTracker
  • func NewGrpcTracker(server *grpc.Server) MetricTracker
• type PathRetriever
  • func DefaultHTTPPathRetriever() PathRetriever
• type Reader
  • func NewCollectorMetricsReader() Reader

Variables

var (
	ErrServerIsNotSet = fmt.Errorf("traking object is not set")
)

Functions

func UnaryClientInterceptor

func UnaryClientInterceptor() func(
	ctx context.Context, method string, req, reply interface{},
	cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption,
) error

func UnaryServerInterceptor

func UnaryServerInterceptor() func(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

Types

type HTTPStatusResponseWriter

type HTTPStatusResponseWriter struct {
	http.ResponseWriter
	Status int

	Response []byte
}

func NewHTTPStatusResponseWriter

func NewHTTPStatusResponseWriter(in http.ResponseWriter) *HTTPStatusResponseWriter

func (*HTTPStatusResponseWriter) Write

func (r *HTTPStatusResponseWriter) Write(in []byte) (int, error)

func (*HTTPStatusResponseWriter) WriteHeader

func (r *HTTPStatusResponseWriter) WriteHeader(statusCode int)

type HTTPTracker

type HTTPTracker interface {
	MetricTracker

	SetPathRetriever(PathRetriever)

	// server mw
	NewHTTPMiddlewareWithOption() func(next http.Handler) http.Handler

	// client mw
	Do(c httpClient, req *http.Request) (*http.Response, error)
}

func NewHTTPMetric

func NewHTTPMetric(pr PathRetriever) HTTPTracker

type MetricTracker

type MetricTracker interface {
	SetUp() error
}

func NewDatabaseTracker

func NewDatabaseTracker(db *sql.DB) MetricTracker

func NewGrpcClientTracker

func NewGrpcClientTracker() MetricTracker

func NewGrpcTracker

func NewGrpcTracker(server *grpc.Server) MetricTracker

type PathRetriever

type PathRetriever interface {
	GetPath(req *http.Request) string
}

func DefaultHTTPPathRetriever

func DefaultHTTPPathRetriever() PathRetriever

type Reader

type Reader interface {
	AddReaderTopicsInUse() Reader
	RmReaderTopicsInUse() Reader
	AddReaderTopicFatalError(topic string, code int) Reader
	AddReaderTopicProcessError(topic string) Reader
	AddReaderTopicReadEvents(topic string, num int) Reader
	AddReaderTopicCommitEvents(topic string, num int) Reader
	AddReaderTopicDecodeEvents(topic string, num int) Reader
	AddReaderTopicSkippedEvents(topic string, num int) Reader
	AddReaderTopicErrorEvents(topic string, num int) Reader
	AddReaderTopicHandlingTime(topic string, duration time.Duration) Reader

	AddGarbageRecords(num int) Reader
}

func NewCollectorMetricsReader

func NewCollectorMetricsReader() Reader