rate

Documentation

Index

• func IsJobRunActive(jobrunRelRsrcName string) bool
• func NewRateLimitingReader(r io.Reader) io.Reader
• func ProcessJobRunBandwidths(jobBWs []*controlpb.JobRunBandwidth, st *stats.Tracker)
• type RateLimitingReader
  • func (rlr *RateLimitingReader) Read(buf []byte) (n int, err error)

Functions

func IsJobRunActive

func IsJobRunActive(jobrunRelRsrcName string) bool

IsJobRunActive returns a bool indicating if a job run is active (paused).

func NewRateLimitingReader

func NewRateLimitingReader(r io.Reader) io.Reader

NewRateLimitingReader returns a RateLimitingReader.

func ProcessJobRunBandwidths

func ProcessJobRunBandwidths(jobBWs []*controlpb.JobRunBandwidth, st *stats.Tracker)

ProcessJobRunBandwidths updates the jobRunBW mapping and projectBWLimiter given the values in the control message.

Types

type RateLimitingReader

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

RateLimitingReader is an io.Reader that wraps another io.Reader and enforces rate limiting during the Read function.

func (*RateLimitingReader) Read

func (rlr *RateLimitingReader) Read(buf []byte) (n int, err error)

Read implements the io.Reader interface.