pagination

Documentation

Index

• type AsyncResult
• type Basic
  • func New[ApiRetT any, RespT any](fn interface{}, opts interface{}, optioner Optioner) *Basic[ApiRetT, RespT]
  • func (p *Basic[ApiRetT, RespT]) Async(params ...interface{}) <-chan AsyncResult[ApiRetT, RespT]
  • func (p *Basic[ApiRetT, RespT]) Sync(params ...interface{}) (SyncResult[ApiRetT, RespT], error)
• type MappedPager
  • func NewMapper[ApiRetT any, UserRetT any, RespT any](fn interface{}, opts interface{}, mapper func(ApiRetT) []UserRetT, ...) *MappedPager[ApiRetT, UserRetT, RespT]
  • func (p *MappedPager[ApiRetT, UserRetT, RespT]) Async(params ...interface{}) <-chan AsyncResult[UserRetT, RespT]
  • func (p *MappedPager[ApiRetT, UserRetT, RespT]) Sync(params ...interface{}) (SyncResult[UserRetT, RespT], error)
• type Optioner
• type SyncResult

Types

type AsyncResult

type AsyncResult[ApiRetT any, RespT any] struct {
	SyncResult[ApiRetT, RespT]
	Err error
}

type Basic

type Basic[ApiRetT any, RespT any] struct {
	// contains filtered or unexported fields
}

func New

func New[ApiRetT any, RespT any](fn interface{}, opts interface{}, optioner Optioner) *Basic[ApiRetT, RespT]

func (*Basic[ApiRetT, RespT]) Async

func (p *Basic[ApiRetT, RespT]) Async(params ...interface{}) <-chan AsyncResult[ApiRetT, RespT]

func (*Basic[ApiRetT, RespT]) Sync

func (p *Basic[ApiRetT, RespT]) Sync(params ...interface{}) (SyncResult[ApiRetT, RespT], error)

type MappedPager

type MappedPager[ApiRetT any, UserRetT any, RespT any] struct {
	Opts   interface{}
	Fn     interface{}
	Mapper func(ApiRetT) []UserRetT
	// contains filtered or unexported fields
}

func NewMapper

func NewMapper[ApiRetT any, UserRetT any, RespT any](fn interface{}, opts interface{}, mapper func(ApiRetT) []UserRetT, optioner Optioner) *MappedPager[ApiRetT, UserRetT, RespT]

func (*MappedPager[ApiRetT, UserRetT, RespT]) Async

func (p *MappedPager[ApiRetT, UserRetT, RespT]) Async(params ...interface{}) <-chan AsyncResult[UserRetT, RespT]

func (*MappedPager[ApiRetT, UserRetT, RespT]) Sync

func (p *MappedPager[ApiRetT, UserRetT, RespT]) Sync(params ...interface{}) (SyncResult[UserRetT, RespT], error)

type Optioner

type Optioner interface {
	Done(resp interface{}) bool
	Advance(resp interface{}, opts interface{})
	OptionsIndex(fnInputsCount int, isVariadic bool) int
}

type SyncResult

type SyncResult[ApiRetT any, RespT any] struct {
	Collected []ApiRetT
	Resp      RespT
}