ipPool

Documentation

Overview

* * @Author: TheLife * @Date: 2021/5/21 下午3:46

* * @Author: TheLife * @Date: 2021/5/10 上午9:02

* * @Author: TheLife * @Date: 2021/5/21 下午3:46

* * @Author: TheLife * @Date: 2021/5/21 下午3:38

* * @Author: TheLife * @Date: 2021/5/21 下午3:39

Index

• type Func
• type IpPool
  • func New(tag string, redis *redis.Client, expire time.Duration, sourceFunc ...Func) *IpPool
  • func (i *IpPool) Getter(wayRemove bool) (ip string, err error)
  • func (i *IpPool) GetterWait(wayRemove bool) (ip string)
  • func (i *IpPool) Remove(ip string)
• type Source
  • func (s *Source) AddSource(source ...Func)
  • func (s *Source) GetFuncResult() (res []Func)
  • func (s *Source) RemoveSource(source Func)

Types

type Func

type Func func() (res []string)

type IpPool

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

func New

func New(tag string, redis *redis.Client, expire time.Duration, sourceFunc ...Func) *IpPool

func (*IpPool) Getter

func (i *IpPool) Getter(wayRemove bool) (ip string, err error)

获取IP

func (*IpPool) GetterWait

func (i *IpPool) GetterWait(wayRemove bool) (ip string)

获取ip，没有则阻塞，直到获取到

func (*IpPool) Remove

func (i *IpPool) Remove(ip string)

释放

type Source

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

func (*Source) AddSource

func (s *Source) AddSource(source ...Func)

添加来源

func (*Source) GetFuncResult

func (s *Source) GetFuncResult() (res []Func)

func (*Source) RemoveSource

func (s *Source) RemoveSource(source Func)

删除来源