Documentation ¶
Index ¶
- func Error(str string)
- func Print(str string)
- func PrintKafkaResult(opts *cli.Options, offsetInfo *types.OffsetInfo, msg kafka.Message, ...)
- func PrintKubeMQResult(_ *cli.Options, count int, msg *queues_stream.QueueMessage, data []byte)
- func PrintLogo()
- func PrintNSQResult(opts *cli.Options, count int, msg *nsq.Message, data []byte)
- func PrintRabbitMQStreamsResult(opts *cli.Options, count int, ctx stream.ConsumerContext, msg *amqp.Message, ...)
- func PrintRelayOptions(cmd string, opts *cli.Options)
- type IPrinter
- type Printer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Error ¶
func Error(str string)
TODO: convert backends to use IPrinter methods Error is a convenience function for printing errors.
func Print ¶
func Print(str string)
TODO: convert backends to use IPrinter methods Print is a convenience function for printing regular output.
func PrintKafkaResult ¶ added in v0.26.0
func PrintKafkaResult(opts *cli.Options, offsetInfo *types.OffsetInfo, msg kafka.Message, data []byte)
func PrintKubeMQResult ¶ added in v0.34.1
func PrintKubeMQResult(_ *cli.Options, count int, msg *queues_stream.QueueMessage, data []byte)
func PrintNSQResult ¶ added in v0.27.0
func PrintRabbitMQStreamsResult ¶ added in v0.33.0
func PrintRelayOptions ¶ added in v0.15.0
Types ¶
Click to show internal directories.
Click to hide internal directories.