metrics

Feb 28, 2025

Changes in this version

+ func RegisterDB(pipeline, pluginName, driver string, db *sqlx.DB)

+ func UnregisterDB(pipeline, pluginName, driver string)

Mar 26, 2024

Changes in this version

+ 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 struct

+ CommitQueueCapacity int

+ CommitQueueLenght int