| pkg/gofr/datasource/pubsub/eventhub/eventhub.go | 258 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/eventhub/go.mod | |
|
|
| pkg/gofr/datasource/pubsub/eventhub/go.sum | |
|
|
| pkg/gofr/datasource/pubsub/eventhub/logger.go | 26 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/eventhub/message.go | 16 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/eventhub/metrics.go | 7 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/google/google.go | 198 | A 0 mins | C 72% |
| pkg/gofr/datasource/pubsub/google/health.go | 65 | A 0 mins | F 0% |
| pkg/gofr/datasource/pubsub/google/interfaces.go | 20 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/google/message.go | 13 | A 0 mins | A 100% |
| pkg/gofr/datasource/pubsub/google/metrics.go | 5 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/interface.go | 30 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/kafka/health.go | 49 | A 0 mins | B 81% |
| pkg/gofr/datasource/pubsub/kafka/interfaces.go | 22 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/kafka/kafka.go | 205 | A 0 mins | B 84% |
| pkg/gofr/datasource/pubsub/kafka/message.go | 24 | A 0 mins | A 100% |
| pkg/gofr/datasource/pubsub/kafka/metrics.go | 5 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/log.go | 18 | A 0 mins | F 0% |
| pkg/gofr/datasource/pubsub/message.go | 88 | A 0 mins | A 97% |
| pkg/gofr/datasource/pubsub/mqtt/default_client.go | 60 | A 0 mins | B 89% |
| pkg/gofr/datasource/pubsub/mqtt/interface.go | 23 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/mqtt/message.go | 8 | A 0 mins | A 100% |
| pkg/gofr/datasource/pubsub/mqtt/mqtt.go | 247 | A 0 mins | A 96% |
| pkg/gofr/datasource/pubsub/nats/client.go | 204 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/committer.go | 23 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/config.go | 44 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/connection_manager.go | 125 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/connectors.go | 17 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/errors.go | 20 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/go.mod | |
|
|
| pkg/gofr/datasource/pubsub/nats/go.sum | |
|
|
| pkg/gofr/datasource/pubsub/nats/health.go | 34 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/interfaces.go | 51 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/message.go | 20 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/metrics.go | 5 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/pubsub_wrapper.go | 47 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/stream_manager.go | 67 | A 0 mins |
|
| pkg/gofr/datasource/pubsub/nats/subscription_manager.go | 185 | A 0 mins |
|
| pkg/gofr/datasource/redis/health.go | 29 | A 0 mins | B 85% |
| pkg/gofr/datasource/redis/hook.go | 80 | A 0 mins | A 93% |
| pkg/gofr/datasource/redis/metrics.go | 5 | A 0 mins |
|
| pkg/gofr/datasource/redis/metrics_interface.go | 34 | A 0 mins | A 100% |
| pkg/gofr/datasource/redis/redis.go | 83 | A 0 mins | A 95% |
| pkg/gofr/datasource/solr/go.mod | |
|
|
| pkg/gofr/datasource/solr/go.sum | |
|
|
| pkg/gofr/datasource/solr/logger.go | 29 | A 0 mins |
|
| pkg/gofr/datasource/solr/metrics.go | 6 | A 0 mins |
|
| pkg/gofr/datasource/solr/solr.go | 204 | A 0 mins |
|
| pkg/gofr/datasource/sql/bind.go | 41 | A 0 mins | A 100% |
| pkg/gofr/datasource/sql/db.go | 237 | A 0 mins | A 93% |