dev

Documentation

Index

• Constants
• func GenLines(stop chan struct{}, totalCount int64, lineBytes int, qps int, ...)
• type Config
• type Dev
  • func (d *Dev) Category() api.Category
  • func (d *Dev) Commit(events []api.Event)
  • func (d *Dev) Config() interface{}
  • func (d *Dev) Init(context api.Context) error
  • func (d *Dev) ProductLoop(productFunc api.ProductFunc)
  • func (d *Dev) Start() error
  • func (d *Dev) Stop()
  • func (d *Dev) String() string
  • func (d *Dev) Type() api.Type

Constants

const Type = "dev"

Functions

func GenLines

func GenLines(stop chan struct{}, totalCount int64, lineBytes int, qps int, outFunc func(content []byte, index int64))

Types

type Config

type Config struct {
	Qps         int   `yaml:"qps,omitempty" default:"1000"`
	ByteSize    int   `yaml:"byteSize,omitempty" default:"1024"`
	EventsTotal int64 `yaml:"eventsTotal,omitempty" default:"-1"`
}

type Dev

type Dev struct {
	// contains filtered or unexported fields
}

func (*Dev) Category

func (d *Dev) Category() api.Category

func (*Dev) Commit

func (d *Dev) Commit(events []api.Event)

func (*Dev) Config

func (d *Dev) Config() interface{}

func (*Dev) Init

func (d *Dev) Init(context api.Context) error

func (*Dev) ProductLoop

func (d *Dev) ProductLoop(productFunc api.ProductFunc)

func (*Dev) Start

func (d *Dev) Start() error

func (*Dev) Stop

func (d *Dev) Stop()

func (*Dev) String

func (d *Dev) String() string

func (*Dev) Type

func (d *Dev) Type() api.Type