cli

package

Go to main page

Versions in this module

v0

v0.35.1

Nov 15, 2021

v0.35.0

Nov 15, 2021

v0.34.4

Oct 26, 2021

v0.34.3

Oct 14, 2021

v0.34.2

Oct 5, 2021

Changes in this version

type GCPPubSubOptions

+ CredentialsFile string

+ CredentialsJSON string

v0.34.1

Aug 12, 2021

Changes in this version

+ func HandleKubeMQQueueFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

type DestinationMetadata

+ KubeMQQueueAddress string

+ KubeMQQueueAuthToken string

+ KubeMQQueueClientID string

+ KubeMQQueueQueue string

+ KubeMQQueueTLSCertFile string

+ type KubeMQQueueOptions struct

+ Address string

+ AuthToken string

+ ClientID string

+ Queue string

+ TLSCertFile string

type Options

+ KubeMQQueue *KubeMQQueueOptions

v0.34.0

Aug 9, 2021

v0.33.1

Aug 5, 2021

v0.33.0

Jul 15, 2021

Changes in this version

+ func HandleRabbitStreamsFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

type Options

+ RabbitMQStreams *RabbitMQStreamsOptions

+ type RabbitMQStreamsOptions struct

+ Address string

+ ClientName string

+ DeclareStream bool

+ DeclareStreamSize string

+ Offset string

+ Password string

+ Port int

+ SkipVerifyTLS bool

+ Stream string

+ UseTLS bool

+ Username string

v0.32.0

Jul 8, 2021

Changes in this version

type Options

+ ReadThriftOutput bool

v0.31.0

Jul 6, 2021

Changes in this version

type Options

+ ReadLag bool

v0.30.0

Jun 29, 2021

Changes in this version

type Options

+ WriteInputIsJsonArray bool

v0.29.1

Jun 25, 2021

Changes in this version

type NSQOptions

+ UseTLS bool

v0.29.0

Jun 24, 2021

v0.28.0

Jun 22, 2021

Changes in this version

+ const DefaultDproxyAddress

+ func HandleDynamicFlags(dynamicCmd *kingpin.CmdClause, opts *Options)

+ func HandleGlobalDynamicFlags(cmd *kingpin.CmdClause, opts *Options)

+ type DynamicOptions struct

type Options

+ DProxyAPIToken string

+ DProxyAddress string

+ DProxyInsecure bool

+ DproxyGRPCTimeout time.Duration

v0.27.0

Jun 21, 2021

Changes in this version

+ func HandleNSQFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ type NSQOptions struct

+ AuthSecret string

+ Channel string

+ ClientID string

+ InsecureTLS bool

+ NSQDAddress string

+ NSQLookupDAddress string

+ TLSCAFile string

+ TLSClientCertFile string

+ TLSClientKeyFile string

+ Topic string

type Options

+ NSQ *NSQOptions

v0.26.0

Jun 18, 2021

Changes in this version

type KafkaOptions

+ WriteHeader map[string]string

type Options

+ ReadJSONOutput bool

v0.25.3

Jun 16, 2021

v0.25.2

Jun 15, 2021

Changes in this version

type BatchOptions

+ OutputType string

v0.25.1

Jun 11, 2021

v0.25.0

Jun 11, 2021

Changes in this version

type KafkaOptions

+ Topics []string

v0.24.0

Jun 8, 2021

Changes in this version

+ const DefaultPulsarConnectTimeout

+ func HandlePulsarFlags(readCmd, writeCmd, _ *kingpin.CmdClause, opts *Options)

type Options

+ Pulsar *PulsarOptions

+ type PulsarOptions struct

+ Address string

+ AuthCertificateFile string

+ AuthKeyFile string

+ ClientId string

+ ConnectTimeout time.Duration

+ InsecureTLS bool

+ Queue string

+ ReadFollow bool

+ SubscriptionName string

+ SubscriptionType string

+ Topic string

v0.23.0

Jun 2, 2021

Changes in this version

type KafkaOptions

+ Brokers []string

v0.22.4

May 7, 2021

Changes in this version

type CDCMongoOptions

+ IncludeFullDocument bool

v0.22.3

Apr 27, 2021

v0.22.2

Apr 23, 2021

v0.22.1

Apr 19, 2021

v0.22.0

Apr 16, 2021

Changes in this version

+ func HandleCDCMongoFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ func HandleCDCPostgresFlags(readCmd, _, relayCmd *kingpin.CmdClause, opts *Options)

+ type CDCMongoOptions struct

+ Collection string

+ DSN string

+ Database string

+ type CDCPostgresOptions struct

+ DatabaseName string

+ Host string

+ Password string

+ Port uint16

+ PublisherName string

+ SkipVerifyTLS bool

+ SlotName string

+ UseTLS bool

+ Username string

type Options

+ CDCMongo *CDCMongoOptions

+ CDCPostgres *CDCPostgresOptions

v0.21.2

Apr 12, 2021

v0.21.1

Apr 9, 2021

Changes in this version

type NatsStreamingOptions

+ ReadFromSequence uint64

+ ReadLastReceived bool

+ ReadSince time.Duration

v0.21.0

Apr 8, 2021

Changes in this version

+ func HandleAzureEventHubFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ func HandleNatsStreamingFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

type AWSSQSOptions

+ WriteMessageDeduplicationID string

+ WriteMessageGroupID string

+ type AzureEventHubOptions struct

+ ConnectionString string

+ MessageID string

+ PartitionKey string

+ type NatsStreamingOptions struct

+ Address string

+ AllAvailable bool

+ Channel string

+ ClientID string

+ ClusterID string

+ CredsFile string

+ DurableSubscription string

+ InsecureTLS bool

+ StartReadingFrom uint64

+ TLSCAFile string

+ TLSClientCertFile string

+ TLSClientKeyFile string

type Options

+ AzureEventHub *AzureEventHubOptions

+ NatsStreaming *NatsStreamingOptions

+ Verbose bool

v0.20.0

Apr 1, 2021

Changes in this version

+ func HandleBatchFlags(batchCmd *kingpin.CmdClause, opts *Options)

+ type BatchOptions struct

+ CollectionID string

+ CollectionName string

+ DestinationID string

+ DestinationMetadata *DestinationMetadata

+ DestinationName string

+ DestinationType string

+ Notes string

+ Page int

+ Query string

+ ReplayFrom string

+ ReplayID string

+ ReplayName string

+ ReplayTo string

+ ReplayType string

+ SchemaID string

+ type DestinationMetadata struct

+ HTTPHeaders map[string]string

+ HTTPURL string

+ KafkaAddress string

+ KafkaInsecureTLS bool

+ KafkaPassword string

+ KafkaSASLType string

+ KafkaTopic string

+ KafkaUseTLS bool

+ KafkaUsername string

+ RabbitDSN string

+ RabbitExchangeAutoDelete bool

+ RabbitExchangeDeclare bool

+ RabbitExchangeDurable bool

+ RabbitExchangeName string

+ RabbitExchangeType string

+ RabbitRoutingKey string

+ SQSAccountID string

+ SQSQueue string

type Options

+ Batch *BatchOptions

v0.19.0

Apr 1, 2021

v0.18.0

Mar 29, 2021

Changes in this version

+ const DefaultCount

+ func HandleRedisPubSubFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ func HandleRedisStreamsFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

type MQTTOptions

+ ClientID string

type Options

+ RedisPubSub *RedisPubSubOptions

+ RedisStreams *RedisStreamsOptions

+ type RedisPubSubOptions struct

+ Address string

+ Channels []string

+ Database int

+ Password string

+ Username string

+ type RedisStreamsOptions struct

+ Address string

+ ConsumerGroup string

+ ConsumerName string

+ Count int64

+ CreateStreams bool

+ Database int

+ Password string

+ RecreateConsumerGroup bool

+ StartID string

+ Streams []string

+ Username string

+ WriteID string

+ WriteKey string

v0.17.0

Mar 24, 2021

Changes in this version

type RedisOptions

+ Channels []string

+ Database int

+ Password string

+ Username string

v0.16.0

Mar 19, 2021

Changes in this version

+ const DefaultKafkaReadOffset

type KafkaOptions

+ GroupID string

+ ReadOffset int64

+ UseConsumerGroup bool

v0.15.0

Jan 29, 2021

Changes in this version

+ const DefaultBatchSize

+ const DefaultKafkaConnectTimeout

+ const DefaultKafkaGroupId

+ const DefaultKafkaMaxBytes

+ const DefaultKafkaMaxWait

+ const DefaultKafkaMinBytes

+ const DefaultKafkaQueueCapacity

+ const DefaultKafkaRebalanceTimeout

+ const DefaultKafkaRelayCommitInterval

+ const DefaultKafkaRelayMaxBytes

+ const DefaultKafkaRelayMaxWait

+ const DefaultKafkaRelayMinBytes

+ const DefaultKafkaRelayQueueCapacity

+ const DefaultKafkaRelayRebalanceTimeout

+ const DefaultStatsReportInterval

type KafkaOptions

+ CommitInterval time.Duration

type Options

+ RelayBatchSize int

+ Stats bool

+ StatsReportInterval time.Duration

v0.14.1

Jan 26, 2021

v0.14.0

Jan 25, 2021

v0.13.0

Jan 22, 2021

Changes in this version

+ const KafkaDefaultMaxBytes

+ const KafkaDefaultMaxWait

+ const KafkaDefaultMinBytes

+ const KafkaDefaultQueueCapacity

+ const KafkaDefaultRebalanceTimeout

type KafkaOptions

+ MaxBytes int

+ MaxWait time.Duration

+ MinBytes int

+ QueueCapacity int

+ RebalanceTimeout time.Duration

v0.12.1

Jan 20, 2021

v0.12.0

Jan 19, 2021

Changes in this version

+ func HandleNatsFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ func HandleRedisFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ type NatsOptions struct

+ Address string

+ CredsFile string

+ InsecureTLS bool

+ Subject string

+ TLSCAFile string

+ TLSClientCertFile string

+ TLSClientKeyFile string

type Options

+ Nats *NatsOptions

+ Redis *RedisOptions

+ type RedisOptions struct

+ Address string

+ Channel string

v0.11.0

Jan 17, 2021

Changes in this version

+ func HandleAWSSNSFlags(_, writeCmd, _ *kingpin.CmdClause, opts *Options)

+ func HandleAzureFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)

+ type AWSSNSOptions struct

+ TopicArn string

+ type AzureServiceBusOptions struct

+ ConnectionString string

+ Queue string

+ Subscription string

+ Topic string

type Options

+ AWSSNS *AWSSNSOptions

+ Azure *AzureServiceBusOptions

v0.10.0

Jan 11, 2021

v0.9.0

Jan 4, 2021

Changes in this version

type KafkaOptions

+ AuthenticationType string

+ Password string

+ Username string

v0.8.1

Jan 2, 2021

Changes in this version

type RabbitOptions

+ SkipVerifyTLS bool

+ UseTLS bool

v0.8.0

Oct 27, 2020

Changes in this version

+ func HandleActiveMqFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ type ActiveMqOptions struct

+ Address string

+ ClientId string

+ Queue string

+ ReadFollow bool

+ Topic string

type Options

+ ActiveMq *ActiveMqOptions

v0.7.0

Oct 22, 2020

Changes in this version

+ func HandleGlobalReadFlags(cmd *kingpin.CmdClause, opts *Options)

+ func HandleGlobalWriteFlags(cmd *kingpin.CmdClause, opts *Options)

type Options

+ Backend string

+ ReadConvert string

+ ReadFollow bool

+ ReadLineNumbers bool

+ ReadOutputType string

+ ReadProtobufDirs []string

+ ReadProtobufRootMessage string

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteOutputType string

+ WriteProtobufDirs []string

+ WriteProtobufRootMessage string

type RabbitOptions

+ ReadConsumerTag string

+ WriteAppID string

v0.6.0

Oct 16, 2020

Changes in this version

+ func HandleGlobalFlags(cmd *kingpin.CmdClause, opts *Options)

type Options

+ AvroSchemaFile string

v0.5.1

Oct 8, 2020

Changes in this version

type RabbitOptions

+ ReadQueueDeclare bool

v0.5.0

Oct 6, 2020

Changes in this version

+ func ValidateProtobufOptions(dirs []string, rootMessage string) error

type AWSSQSOptions

+ ReadProtobufDirs []string

+ RemoteAccountID string

+ WriteProtobufDirs []string

type GCPPubSubOptions

+ ReadProtobufDirs []string

+ WriteProtobufDirs []string

type KafkaOptions

+ ReadProtobufDirs []string

+ WriteProtobufDirs []string

type MQTTOptions

+ ReadProtobufDirs []string

+ WriteProtobufDirs []string

type RabbitOptions

+ ReadAutoAck bool

+ ReadProtobufDirs []string

+ WriteProtobufDirs []string

v0.4.0

Sep 21, 2020

Changes in this version

+ const DefaultGRPCAddress

+ const DefaultGRPCTimeout

+ const DefaultHTTPListenAddress

+ const DefaultNumWorkers

+ func HandleRelayFlags(relayCmd *kingpin.CmdClause, opts *Options)

type AWSSQSOptions

+ RelayAutoDelete bool

+ RelayMaxNumMessages int64

+ RelayReceiveRequestAttemptId string

+ RelayWaitTimeSeconds int64

type Options

+ RelayGRPCAddress string

+ RelayGRPCDisableTLS bool

+ RelayGRPCTimeout time.Duration

+ RelayHTTPListenAddress string

+ RelayNumWorkers int

+ RelayToken string

+ RelayType string

+ Version string

v0.3.0

Sep 16, 2020

Changes in this version

+ func HandleAWSSQSFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ type AWSSQSOptions struct

+ QueueName string

+ ReadAutoDelete bool

+ ReadConvert string

+ ReadFollow bool

+ ReadLineNumbers bool

+ ReadMaxNumMessages int

+ ReadOutputType string

+ ReadProtobufDir string

+ ReadProtobufRootMessage string

+ ReadReceiveRequestAttemptId string

+ ReadWaitTimeSeconds int64

+ WriteAttributes map[string]string

+ WriteDelaySeconds int64

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteOutputType string

+ WriteProtobufDir string

+ WriteProtobufRootMessage string

type Options

+ AWSSQS *AWSSQSOptions

v0.2.0

Aug 19, 2020

Changes in this version

+ const MQTTDefaultClientId

+ const MQTTDefaultConnectTimeout

+ func HandleMQTTFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ type MQTTOptions struct

+ Address string

+ ClientId string

+ InsecureTLS bool

+ LineNumbers bool

+ QoSLevel int

+ ReadConvert string

+ ReadFollow bool

+ ReadOutputType string

+ ReadProtobufDir string

+ ReadProtobufRootMessage string

+ ReadTimeout time.Duration

+ TLSCAFile string

+ TLSClientCertFile string

+ TLSClientKeyFile string

+ Timeout time.Duration

+ Topic string

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteOutputType string

+ WriteProtobufDir string

+ WriteProtobufRootMessage string

+ WriteTimeout time.Duration

type Options

+ MQTT *MQTTOptions

v0.1.0

Aug 6, 2020

Changes in this version

+ const KafkaDefaultConnectTimeout

+ const KafkaDefaultGroupId

+ func HandleGCPPubSubFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ func HandleKafkaFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ func HandleRabbitFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)

+ type GCPPubSubOptions struct

+ ProjectId string

+ ReadAck bool

+ ReadConvert string

+ ReadFollow bool

+ ReadLineNumbers bool

+ ReadOutputType string

+ ReadProtobufDir string

+ ReadProtobufRootMessage string

+ ReadSubscriptionId string

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteOutputType string

+ WriteProtobufDir string

+ WriteProtobufRootMessage string

+ WriteTopicId string

+ type KafkaOptions struct

+ Address string

+ InsecureTLS bool

+ LineNumbers bool

+ ReadConvert string

+ ReadFollow bool

+ ReadGroupId string

+ ReadOutputType string

+ ReadProtobufDir string

+ ReadProtobufRootMessage string

+ Timeout time.Duration

+ Topic string

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteKey string

+ WriteOutputType string

+ WriteProtobufDir string

+ WriteProtobufRootMessage string

+ type Options struct

+ Action string

+ Debug bool

+ GCPPubSub *GCPPubSubOptions

+ Kafka *KafkaOptions

+ Quiet bool

+ Rabbit *RabbitOptions

+ func Handle() (string, *Options, error)

+ type RabbitOptions struct

+ Address string

+ Exchange string

+ ReadConvert string

+ ReadFollow bool

+ ReadLineNumbers bool

+ ReadOutputType string

+ ReadProtobufDir string

+ ReadProtobufRootMessage string

+ ReadQueue string

+ ReadQueueAutoDelete bool

+ ReadQueueDurable bool

+ ReadQueueExclusive bool

+ RoutingKey string

+ WriteInputData string

+ WriteInputFile string

+ WriteInputType string

+ WriteOutputType string

+ WriteProtobufDir string

+ WriteProtobufRootMessage string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL