Go to main page
Imports
- github.com/aws/aws-sdk-go/aws
- github.com/aws/aws-sdk-go/service/sqs
- github.com/batchcorp/collector-schemas/build/go/protos/records
- github.com/batchcorp/collector-schemas/build/go/protos/services
- github.com/batchcorp/plumber-schemas/build/go/protos/records
- github.com/pkg/errors
- github.com/segmentio/kafka-go
- github.com/sirupsen/logrus
- google.golang.org/grpc
- google.golang.org/grpc/credentials
- google.golang.org/grpc/metadata
Imports in module “github.com/batchcorp/plumber”
- github.com/batchcorp/plumber/backends/awssqs/types
- github.com/batchcorp/plumber/backends/azure-servicebus/types
- github.com/batchcorp/plumber/backends/cdcmongo/types
- github.com/batchcorp/plumber/backends/cdcpostgres/types
- github.com/batchcorp/plumber/backends/gcppubsub/types
- github.com/batchcorp/plumber/backends/kafka/types
- github.com/batchcorp/plumber/backends/kubemq-queue/types
- github.com/batchcorp/plumber/backends/mqtt/types
- github.com/batchcorp/plumber/backends/nats-jetstream/types
- github.com/batchcorp/plumber/backends/nats-streaming/types
- github.com/batchcorp/plumber/backends/nats/types
- github.com/batchcorp/plumber/backends/nsq/types
- github.com/batchcorp/plumber/backends/rabbitmq/types
- github.com/batchcorp/plumber/backends/rpubsub/types
- github.com/batchcorp/plumber/backends/rstreams/types
- github.com/batchcorp/plumber/prometheus
- github.com/batchcorp/plumber/util
- github.com/batchcorp/plumber/validate