senders

Documentation

Index

• func Start(ctx context.Context, sender Sender, generator Generator)
• type Generator
• type Sender

Functions

func Start

func Start(ctx context.Context, sender Sender, generator Generator)

Types

type Generator

type Generator interface {
	Generate() ([]byte, error)
	Rate() int
}

type Sender

type Sender interface {
	Send(batch []byte) error
	AddProgress(int)
	Progress() <-chan int
}