util

type ILogger interface {
	OpenLog()
	CloseLog()
	Log(level pipeline.LogLevel, msg string)
	Panic(err error)
}

type Pacer interface {

	// RequestTrafficAllocation blocks until the caller is allowed to process byteCount bytes.
	RequestTrafficAllocation(ctx context.Context, byteCount int64) error

	// UndoRequest reverses a previous request to process n bytes.  Is used when
	// the caller did not need all of the allocation they previously requested
	// e.g. when they asked for enough for a big buffer, but never filled it, they would
	// call this method to return the unused portion.
	UndoRequest(byteCount int64)

	// GetTotalTraffic returns the cumulative count of all traffic that has been processed
	GetTotalTraffic() int64

	Close() error
}