source

Documentation

Index

• type Config
• type QueryConfig
• type Section
  • func NewSectionSliceMap(config *QueryConfig, newDb database.BuildDb) (*Section[storage.MapEntry], error)
  • func (s *Section[E]) Close() error
  • func (s *Section[E]) Copy(items []E) []E
  • func (s *Section[E]) DB() *database.DB
  • func (s *Section[E]) ReceiveChan() <-chan []E
  • func (s *Section[E]) Scan() error
  • func (s *Section[E]) State() []string
  • func (s *Section[E]) Summary() []string
  • func (s *Section[E]) Title() string

Types

type Config

type Config struct {
	Concurrency int
	Maximum     int64
	StartId     int64
	EndId       int64
	PageSize    int64
	TableName   string
	IdName      string
}

type QueryConfig

type QueryConfig struct {
	Config
	Fields []string
	Where  string // "field1 = ? and field2 = ?"
	Order  string // "field1 desc"
}

type Section

type Section[E storage.Entry] struct {
	storage.Storage
	// contains filtered or unexported fields
}

Section 分段查询

func NewSectionSliceMap

func NewSectionSliceMap(config *QueryConfig, newDb database.BuildDb) (*Section[storage.MapEntry], error)

func (*Section[E]) Close

func (s *Section[E]) Close() error

func (*Section[E]) Copy

func (s *Section[E]) Copy(items []E) []E

func (*Section[E]) DB

func (s *Section[E]) DB() *database.DB

func (*Section[E]) ReceiveChan

func (s *Section[E]) ReceiveChan() <-chan []E

func (*Section[E]) Scan

func (s *Section[E]) Scan() error

func (*Section[E]) State

func (s *Section[E]) State() []string

func (*Section[E]) Summary

func (s *Section[E]) Summary() []string

func (*Section[E]) Title

func (s *Section[E]) Title() string