pager

Documentation

Index

• type BasePager
  • func NewBasePager() *BasePager
  • func (p *BasePager) CheckHasNext(set Set)
  • func (p *BasePager) Next() bool
  • func (p *BasePager) Offset() int64
  • func (p *BasePager) PageNumber() int64
  • func (p *BasePager) PageSize() int64
  • func (p *BasePager) SetPageSize(ps int64)
  • func (p *BasePager) SetRate(r float64)
• type Pager
• type Set

Types

type BasePager

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

func NewBasePager

func NewBasePager() *BasePager

func (*BasePager) CheckHasNext

func (p *BasePager) CheckHasNext(set Set)

通过判断当前set是否小于PageSize, 从而判断是否满页

func (*BasePager) Next

func (p *BasePager) Next() bool

func (*BasePager) Offset

func (p *BasePager) Offset() int64

func (*BasePager) PageNumber

func (p *BasePager) PageNumber() int64

func (*BasePager) PageSize

func (p *BasePager) PageSize() int64

func (*BasePager) SetPageSize

func (p *BasePager) SetPageSize(ps int64)

func (*BasePager) SetRate

func (p *BasePager) SetRate(r float64)

type Pager

type Pager interface {
	// 判断是否还有下一页
	Next() bool
	// 获取当前页面的数据, 注意必须先调用Next, 从而判断是否存在下一页
	Scan(context.Context, Set) error
	// 设置页面打小, 默认20, 一页数据20条
	SetPageSize(ps int64)
	// 设置读取速率, 默认1, 每秒发起一次请求
	SetRate(r float64)
}

分页迭代器

for p.Next() {
	p.Scan(ctx, dst);
}

type Set

type Set interface {
	// 往Set添加元素
	Add(...any)
	// 当前Set有多少个元素
	Length() int64
}

可以往里面添加元素