produce

Documentation

Index

• Variables
• func New(parent charm.Command, f *flag.FlagSet) (charm.Command, error)
• type Command
  • func (c *Command) Run(args []string) error

Variables

var Produce = &charm.Spec{
	Name:  "produce",
	Usage: "produce [options] [file1, file2, ...]",
	Short: "produce Zed data into a Kafka topic",
	Long: `
The produce command copies the input Zed data into a Kafka topic.
No effort is made to provide synchronization as data as simply copied from
input to the topic and any failures are not recovered from.
Use the "zync sync" command to provide synchronization and
fail-safe, restartable operation.`,
	New: New,
}

Functions

func New

func New(parent charm.Command, f *flag.FlagSet) (charm.Command, error)

Types

type Command

type Command struct {
	*root.Command
	// contains filtered or unexported fields
}

func (*Command) Run

func (c *Command) Run(args []string) error