bankgen

Documentation

Index

• type PutCmd
  • func NewPutCmd() (*PutCmd, error)
  • func (p *PutCmd) ABA() string
  • func (p *PutCmd) CustomAudiences() string
  • func (p *PutCmd) Db() string
  • func (p *PutCmd) Log() logger.Logger
  • func (p *PutCmd) Run() (err error)
  • func (p *PutCmd) UserID() int

Types

type PutCmd

type PutCmd struct {
	idk.ConfluentCommand `flag:"!embed"`

	Topic     string `help:"Kafka topic to post to."`
	Subject   string
	Seed      int64  `help:"Random seed for data generation"`
	Save      string `help:"Filename of record log. '-' for stdout."`
	BatchSize int    `help:"Size of record batches to submit to Kafka."`

	NumRecords int `help:"Number of records to generate"`

	DryRun bool `help:"Dry run - just flag parsing."`
	// contains filtered or unexported fields
}

PutCmd represents a command to put data into Kafka

func NewPutCmd

func NewPutCmd() (*PutCmd, error)

NewPutCmd creates a new PutCmd

func (*PutCmd) ABA

func (p *PutCmd) ABA() string

ABA returns a random 9 numeric digit string with about 27000 possible values.

func (*PutCmd) CustomAudiences

func (p *PutCmd) CustomAudiences() string

CustomAudiences returns a fake Custom Audience string

func (*PutCmd) Db

func (p *PutCmd) Db() string

Db returns a db

func (*PutCmd) Log

func (p *PutCmd) Log() logger.Logger

func (*PutCmd) Run

func (p *PutCmd) Run() (err error)

Run is the entry point for PutCmd

func (*PutCmd) UserID

func (p *PutCmd) UserID() int

UserID returns a user ID