limiter

Documentation

Index

• type LimitRange
  • func ParseLimitBetween(between, inputTimeLayout string) (LimitRange, error)
• type LimitTransport
  • func NewLimitTransport(logger utils.Logger, rt http.RoundTripper, lr LimitRange, filesize int, ...) (*LimitTransport, error)
  • func (t *LimitTransport) GetMonitorStatus() Status
  • func (t *LimitTransport) HasStarted() bool
  • func (t *LimitTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type Status

Types

type LimitRange

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

func ParseLimitBetween

func ParseLimitBetween(between, inputTimeLayout string) (LimitRange, error)

type LimitTransport

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

func NewLimitTransport

func NewLimitTransport(logger utils.Logger, rt http.RoundTripper, lr LimitRange, filesize int, ratelimit int) (*LimitTransport, error)

func (*LimitTransport) GetMonitorStatus

func (t *LimitTransport) GetMonitorStatus() Status

func (*LimitTransport) HasStarted

func (t *LimitTransport) HasStarted() bool

HasStarted returns whether the LimitTransport has seen use

func (*LimitTransport) RoundTrip

func (t *LimitTransport) RoundTrip(r *http.Request) (*http.Response, error)

type Status

type Status struct {
	AvgRate    int // Bytes per second
	Bytes      int
	TotalBytes int

	Progress string

	Start   time.Time
	TimeRem time.Duration
}