app

Documentation

Index

• func CallReportAtEveryTick(reporter *Reporter, ticker *time.Ticker, finish <-chan struct{})
• func ClientHandler(ctx context.Context, cancelCtx context.CancelFunc, readCloser io.ReadCloser, ...)
• type Reporter
  • func NewReporter(uniqueWrite, statsWriter io.Writer) *Reporter
  • func (r *Reporter) Record(number domain.Number) error
  • func (r *Reporter) Report() error

Functions

func CallReportAtEveryTick

func CallReportAtEveryTick(reporter *Reporter, ticker *time.Ticker, finish <-chan struct{})

func ClientHandler

func ClientHandler(ctx context.Context, cancelCtx context.CancelFunc, readCloser io.ReadCloser, reporter *Reporter, done chan<- struct{})

Types

type Reporter

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

func NewReporter

func NewReporter(uniqueWrite, statsWriter io.Writer) *Reporter

func (*Reporter) Record

func (r *Reporter) Record(number domain.Number) error

func (*Reporter) Report

func (r *Reporter) Report() error