cli

Documentation

Index

• Constants
• func HandleAWSSQSFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)
• func HandleActiveMqFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)
• func HandleGCPPubSubFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)
• func HandleGlobalFlags(cmd *kingpin.CmdClause, opts *Options)
• func HandleGlobalReadFlags(cmd *kingpin.CmdClause, opts *Options)
• func HandleGlobalWriteFlags(cmd *kingpin.CmdClause, opts *Options)
• func HandleKafkaFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)
• func HandleMQTTFlags(readCmd, writeCmd *kingpin.CmdClause, opts *Options)
• func HandleRabbitFlags(readCmd, writeCmd, relayCmd *kingpin.CmdClause, opts *Options)
• func HandleRelayFlags(relayCmd *kingpin.CmdClause, opts *Options)
• func ValidateProtobufOptions(dirs []string, rootMessage string) error
• type AWSSQSOptions
• type ActiveMqOptions
• type GCPPubSubOptions
• type KafkaOptions
• type MQTTOptions
• type Options
  • func Handle(cliArgs []string) (string, *Options, error)
• type RabbitOptions

Constants

const (
	DefaultGRPCAddress       = "grpc-collector.batch.sh:9000"
	DefaultHTTPListenAddress = ":8080"
	DefaultGRPCTimeout       = "10s"
	DefaultNumWorkers        = "10"
)

const (
	KafkaDefaultConnectTimeout = "10s"
	KafkaDefaultGroupId        = "plumber"
)

const (
	MQTTDefaultConnectTimeout = "5s"
	MQTTDefaultClientId       = "plumber"
)

Functions

func HandleAWSSQSFlags

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

func HandleActiveMqFlags

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

func HandleGCPPubSubFlags

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

func HandleGlobalFlags

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

func HandleGlobalReadFlags

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

func HandleGlobalWriteFlags

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

func HandleKafkaFlags

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

func HandleMQTTFlags

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

func HandleRabbitFlags

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

func HandleRelayFlags

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

func ValidateProtobufOptions

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

Types

type AWSSQSOptions

type AWSSQSOptions struct {
	// Shared
	QueueName       string
	RemoteAccountID string

	// Read
	ReadMaxNumMessages          int64
	ReadAutoDelete              bool
	ReadReceiveRequestAttemptId string
	ReadWaitTimeSeconds         int64

	// Write
	WriteDelaySeconds int64
	WriteAttributes   map[string]string

	// Relay
	RelayMaxNumMessages          int64
	RelayReceiveRequestAttemptId string
	RelayAutoDelete              bool
	RelayWaitTimeSeconds         int64
}

type ActiveMqOptions

type ActiveMqOptions struct {
	// Shared
	Address  string
	Topic    string
	Queue    string
	ClientId string

	// Read
	ReadFollow bool
}

type GCPPubSubOptions

type GCPPubSubOptions struct {
	// Shared
	ProjectId string

	// Read
	ReadSubscriptionId string
	ReadAck            bool

	// Write
	WriteTopicId string
}

type KafkaOptions

type KafkaOptions struct {
	// Shared
	Address     string
	Topic       string
	Timeout     time.Duration
	InsecureTLS bool

	// Read
	ReadGroupId string

	// Write
	WriteKey string
}

type MQTTOptions

type MQTTOptions struct {
	// Shared
	Address  string
	Topic    string
	Timeout  time.Duration
	ClientId string
	QoSLevel int

	// TLS-related pieces
	TLSCAFile         string
	TLSClientCertFile string
	TLSClientKeyFile  string
	InsecureTLS       bool

	// Read
	ReadTimeout time.Duration

	// Write
	WriteTimeout time.Duration
}

type Options

type Options struct {
	// Global
	Debug   bool
	Quiet   bool
	Action  string
	Version string
	Backend string

	// Serializers
	AvroSchemaFile string

	// Relay
	RelayToken             string
	RelayGRPCAddress       string
	RelayType              string
	RelayHTTPListenAddress string
	RelayNumWorkers        int
	RelayGRPCTimeout       time.Duration
	RelayGRPCDisableTLS    bool

	// Shared read flags
	ReadProtobufRootMessage string
	ReadProtobufDirs        []string
	ReadOutputType          string
	ReadFollow              bool
	ReadLineNumbers         bool
	ReadConvert             string

	// Shared write flags
	WriteInputData           string
	WriteInputFile           string
	WriteInputType           string
	WriteOutputType          string
	WriteProtobufDirs        []string
	WriteProtobufRootMessage string

	Kafka     *KafkaOptions
	Rabbit    *RabbitOptions
	GCPPubSub *GCPPubSubOptions
	MQTT      *MQTTOptions
	AWSSQS    *AWSSQSOptions
	ActiveMq  *ActiveMqOptions
}

func Handle

func Handle(cliArgs []string) (string, *Options, error)

type RabbitOptions

type RabbitOptions struct {
	// Shared
	Address    string
	Exchange   string
	RoutingKey string

	// Read
	ReadQueue           string
	ReadQueueDurable    bool
	ReadQueueAutoDelete bool
	ReadQueueExclusive  bool
	ReadAutoAck         bool
	ReadQueueDeclare    bool
	ReadConsumerTag     string

	// Write
	WriteAppID string
}