pkg.gl

Categorygithub.com/batchcorp/plumbercli

package

0.35.1

Repository: https://github.com/batchcorp/plumber.git

Documentation: pkg.go.dev

# Functions

Handle

No description provided by the author

HandleActiveMqFlags

No description provided by the author

HandleAWSSNSFlags

No description provided by the author

HandleAWSSQSFlags

No description provided by the author

HandleAzureEventHubFlags

No description provided by the author

HandleAzureFlags

No description provided by the author

HandleBatchFlags

No description provided by the author

HandleCDCMongoFlags

No description provided by the author

HandleCDCPostgresFlags

No description provided by the author

HandleDynamicFlags

No description provided by the author

HandleGCPPubSubFlags

No description provided by the author

HandleGlobalDynamicFlags

No description provided by the author

HandleGlobalFlags

No description provided by the author

HandleGlobalReadFlags

No description provided by the author

HandleGlobalWriteFlags

No description provided by the author

HandleKafkaFlags

No description provided by the author

HandleKubeMQQueueFlags

No description provided by the author

HandleMQTTFlags

No description provided by the author

HandleNatsFlags

No description provided by the author

HandleNatsStreamingFlags

No description provided by the author

HandleNSQFlags

HandleNSQFlags creates NSQ commands and flags.

HandlePulsarFlags

No description provided by the author

HandleRabbitFlags

No description provided by the author

HandleRabbitStreamsFlags

No description provided by the author

HandleRedisPubSubFlags

No description provided by the author

HandleRedisStreamsFlags

No description provided by the author

HandleRelayFlags

No description provided by the author

ValidateProtobufOptions

No description provided by the author

# Constants

DefaultCount

No description provided by the author

DefaultDproxyAddress

No description provided by the author

DefaultGRPCAddress

No description provided by the author

DefaultGRPCTimeout

No description provided by the author

DefaultHTTPListenAddress

No description provided by the author

DefaultKafkaConnectTimeout

No description provided by the author

DefaultKafkaGroupId

No description provided by the author

DefaultKafkaMaxBytes

No description provided by the author

DefaultKafkaMaxWait

Optimize for immediate output.

DefaultKafkaMinBytes

No description provided by the author

DefaultKafkaQueueCapacity

No description provided by the author

DefaultKafkaReadOffset

No description provided by the author

DefaultKafkaRebalanceTimeout

No description provided by the author

DefaultKafkaRelayCommitInterval

No description provided by the author

DefaultKafkaRelayMaxBytes

1MB.

DefaultKafkaRelayMaxWait

Optimize for throughput + reliability.

DefaultKafkaRelayMinBytes

1MB.

DefaultKafkaRelayQueueCapacity

No description provided by the author

DefaultKafkaRelayRebalanceTimeout

No description provided by the author

DefaultNumWorkers

No description provided by the author

DefaultPulsarConnectTimeout

No description provided by the author

DefaultStatsReportInterval

No description provided by the author

MQTTDefaultClientId

No description provided by the author

MQTTDefaultConnectTimeout

No description provided by the author

# Structs

ActiveMqOptions

No description provided by the author

AWSSNSOptions

No description provided by the author

AWSSQSOptions

No description provided by the author

AzureEventHubOptions

No description provided by the author

AzureServiceBusOptions

No description provided by the author

BatchOptions

No description provided by the author

CDCMongoOptions

No description provided by the author

CDCPostgresOptions

No description provided by the author

DestinationMetadata

No description provided by the author

DynamicOptions

No description provided by the author

GCPPubSubOptions

No description provided by the author

KafkaOptions

No description provided by the author

KubeMQQueueOptions

No description provided by the author

MQTTOptions

No description provided by the author

NatsOptions

No description provided by the author

NatsStreamingOptions

No description provided by the author

NSQOptions

NSQOptions stores the values of CLI options for NSQ flags.

Options

No description provided by the author

PulsarOptions

No description provided by the author

RabbitMQStreamsOptions

No description provided by the author

RabbitOptions

No description provided by the author

RedisPubSubOptions

No description provided by the author

RedisStreamsOptions

No description provided by the author