Documentation
¶
Index ¶
- type FtpThrottle
- func (t *FtpThrottle) Close()
- func (t *FtpThrottle) ReleaseAll(id int64)
- func (t *FtpThrottle) ReleaseOnePendingProcessFromEach()
- func (t *FtpThrottle) ReleasePendingProcess(id int64)
- func (t *FtpThrottle) Start()
- func (t *FtpThrottle) Throttle(id int64) (chan bool, error)
- func (t *FtpThrottle) Unregister(id int64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FtpThrottle ¶
type FtpThrottle struct {
// contains filtered or unexported fields
}
func NewFtpThrottle ¶
func NewFtpThrottle(lf fx.Lifecycle, cfg *config.Config) *FtpThrottle
func (*FtpThrottle) Close ¶
func (t *FtpThrottle) Close()
func (*FtpThrottle) ReleaseAll ¶
func (t *FtpThrottle) ReleaseAll(id int64)
func (*FtpThrottle) ReleaseOnePendingProcessFromEach ¶
func (t *FtpThrottle) ReleaseOnePendingProcessFromEach()
func (*FtpThrottle) ReleasePendingProcess ¶
func (t *FtpThrottle) ReleasePendingProcess(id int64)
func (*FtpThrottle) Start ¶
func (t *FtpThrottle) Start()
func (*FtpThrottle) Throttle ¶
func (t *FtpThrottle) Throttle(id int64) (chan bool, error)
Register a new client and returns a channel to close all pending operations with
func (*FtpThrottle) Unregister ¶
func (t *FtpThrottle) Unregister(id int64)
Source Files
Click to show internal directories.
Click to hide internal directories.