cli

package

v1.0.3 Latest Latest Go to latest Published: Sep 29, 2022 License: BSD-3-Clause Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func LoadKafkaConfig() ([]kgo.Opt, error)

type Credentials struct {
	User     string
	Password string
}

func SchemaRegistryEndpoint() (string, Credentials, error)

type Flags struct {
	Format    string
	Topic     string
	Namespace string
}

func (f *Flags) SetFlags(fs *flag.FlagSet)

type LakeFlags struct {
	lakeflags.Flags
}

func (l *LakeFlags) SetFlags(fs *flag.FlagSet)

SetFlags calls Flags.SetFlags and then, for any flag added, it prepends "Zed " to flag.Flag.Usage.

type ShaperFlags struct {
	Path string
}

func (s *ShaperFlags) Load() (string, error)

func (s *ShaperFlags) SetFlags(fs *flag.FlagSet)