cmd

Documentation

Index

• Variables
• func NewFileCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewGenCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewHTTPCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewKafkaCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewKafkaTestCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewKafkagenCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewRootCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewS3Command(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewSSBCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewTaxiCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command
• func NewWeatherCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

Variables

var (
	// Version of this software - filled in by ldflags in Makefile.
	Version string
	// BuildTime of this software - filled in by ldflags in Makefile.
	BuildTime string
)

var FileMain *file.Main

FileMain is wrapped by NewFileCommand and only exported for testing purposes.

var GenMain *gen.Main

GenMain is wrapped by NewGenCommand and only exported for testing purposes.

var KafkaMain *kafka.Main

KafkaMain is wrapped by NewKafkaCommand and only exported for testing purposes.

var KafkaSource *kafka.Source

KafkaSource is wrapped by NewKafkaTestCommand and only exported for testing purposes.

var KafkagenMain *kafkagen.Main

KafkagenMain is wrapped by NewKafkagenCommand and only exported for testing purposes.

var S3Main *s3.Main

S3Main is wrapped by NewS3Command and only exported for testing purposes.

var SSBMain *ssb.Main

SSBMain is wrapped by NewSSBCommand. It is exported for testing purposes.

var TaxiMain *taxi.Main

TaxiMain is wrapped by NewTaxiCommand. It is exported for testing purposes.

var WeatherMain *weather.Main

WeatherMain is wrapped by NewWeatherCommand. It is exported for testing purposes.

Functions

func NewFileCommand

func NewFileCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewFileCommand returns a new cobra command wrapping FileMain.

func NewGenCommand

func NewGenCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewGenCommand returns a new cobra command wrapping GenMain.

func NewHTTPCommand

func NewHTTPCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewHTTPCommand returns a new cobra command which wraps http.Main

func NewKafkaCommand

func NewKafkaCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewKafkaCommand returns a new cobra command wrapping KafkaMain.

func NewKafkaTestCommand

func NewKafkaTestCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewKafkaTestCommand returns a new cobra command wrapping KafkaSource.

func NewKafkagenCommand

func NewKafkagenCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewKafkagenCommand returns a new cobra command wrapping KafkagenMain.

func NewRootCommand

func NewRootCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewRootCommand reads the map of subcommandFns and creates a top level cobra command with each of them as subcommands.

func NewS3Command

func NewS3Command(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewS3Command returns a new cobra command wrapping S3Main.

func NewSSBCommand

func NewSSBCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewSSBCommand wraps ssb.Main with cobra.Command for use from a CLI.

func NewTaxiCommand

func NewTaxiCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewTaxiCommand wraps taxi.Main with cobra.Command for use from a CLI.

func NewWeatherCommand

func NewWeatherCommand(stdin io.Reader, stdout, stderr io.Writer) *cobra.Command

NewWeatherCommand wraps weather.Main with cobra.Command for use from a CLI.