metrics

Documentation

Index

• func GrpcClientStreamInterceptor(pipeline, pluginName string) grpc.StreamClientInterceptor
• func GrpcClientUnaryInterceptor(pipeline, pluginName string) grpc.UnaryClientInterceptor
• func GrpcServerStreamInterceptor(pipeline, pluginName string) grpc.StreamServerInterceptor
• func GrpcServerUnaryInterceptor(pipeline, pluginName string) grpc.UnaryServerInterceptor
• func HttpServerMiddleware(pipeline string, pluginName string, next http.Handler) http.Handler
• func RegisterKafkaReader(pipeline, pluginName, topic, groupId, clientId string, ...)
• func RegisterKafkaWriter(pipeline, pluginName, topic, clientId string, ...)
• func UnregisterKafkaReader(pipeline, pluginName, topic, groupId, clientId string)
• func UnregisterKafkaWriter(pipeline, pluginName, topic, clientId string)
• type ReaderStats

Functions

func GrpcClientStreamInterceptor

func GrpcClientStreamInterceptor(pipeline, pluginName string) grpc.StreamClientInterceptor

func GrpcClientUnaryInterceptor

func GrpcClientUnaryInterceptor(pipeline, pluginName string) grpc.UnaryClientInterceptor

func GrpcServerStreamInterceptor

func GrpcServerStreamInterceptor(pipeline, pluginName string) grpc.StreamServerInterceptor

func GrpcServerUnaryInterceptor

func GrpcServerUnaryInterceptor(pipeline, pluginName string) grpc.UnaryServerInterceptor

func HttpServerMiddleware

func HttpServerMiddleware(pipeline string, pluginName string, next http.Handler) http.Handler

func RegisterKafkaReader

func RegisterKafkaReader(pipeline, pluginName, topic, groupId, clientId string, statFunc func() ReaderStats)

func RegisterKafkaWriter

func RegisterKafkaWriter(pipeline, pluginName, topic, clientId string, statFunc func() kafka.WriterStats)

func UnregisterKafkaReader

func UnregisterKafkaReader(pipeline, pluginName, topic, groupId, clientId string)

func UnregisterKafkaWriter

func UnregisterKafkaWriter(pipeline, pluginName, topic, clientId string)

Types

type ReaderStats

type ReaderStats struct {
	kafka.ReaderStats
	CommitQueueLenght   int
	CommitQueueCapacity int
}