process

Documentation

Index

• type DefaultQueryResultsProcessor
  • func NewQueryResultsProcessor(displayProgressBar bool) DefaultQueryResultsProcessor
  • func (w DefaultQueryResultsProcessor) ExecutePageQuery(ctx *context.Context, queryResultsCollector context.QueryResultsCollector, ...) (<-chan context.ProcessResult, error)
  • func (w DefaultQueryResultsProcessor) ExecuteQuery(ctx *context.Context, queryResultsCollector context.QueryResultsCollector, ...) (<-chan context.ProcessResult, error)
• type PageQueryResultsCollector
  • func NewAppsQueryResultsCollector(resultsPerPage int) *PageQueryResultsCollector
  • func (a *PageQueryResultsCollector) AddResult(result context.QueryResult)
  • func (a *PageQueryResultsCollector) Close()
  • func (a *PageQueryResultsCollector) GetResults() <-chan context.QueryResult
  • func (a *PageQueryResultsCollector) ResultCount() int
  • func (a *PageQueryResultsCollector) ResultsPerPage() int

Types

type DefaultQueryResultsProcessor

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

func NewQueryResultsProcessor

func NewQueryResultsProcessor(displayProgressBar bool) DefaultQueryResultsProcessor

func (DefaultQueryResultsProcessor) ExecutePageQuery

func (w DefaultQueryResultsProcessor) ExecutePageQuery(ctx *context.Context, queryResultsCollector context.QueryResultsCollector, query func(page int, collector context.QueryResultsCollector) func() (int, error), processor context.ProcessFunc) (<-chan context.ProcessResult, error)

func (DefaultQueryResultsProcessor) ExecuteQuery

func (w DefaultQueryResultsProcessor) ExecuteQuery(ctx *context.Context, queryResultsCollector context.QueryResultsCollector, query func(collector context.QueryResultsCollector) (int, error), processor func(ctx *context.Context, value context.QueryResult) context.ProcessResult) (<-chan context.ProcessResult, error)

type PageQueryResultsCollector

type PageQueryResultsCollector struct {
	Results chan context.QueryResult
	Count   uint32
	PerPage int
}

func NewAppsQueryResultsCollector

func NewAppsQueryResultsCollector(resultsPerPage int) *PageQueryResultsCollector

func (*PageQueryResultsCollector) AddResult

func (a *PageQueryResultsCollector) AddResult(result context.QueryResult)

func (*PageQueryResultsCollector) Close

func (a *PageQueryResultsCollector) Close()

func (*PageQueryResultsCollector) GetResults

func (a *PageQueryResultsCollector) GetResults() <-chan context.QueryResult

func (*PageQueryResultsCollector) ResultCount

func (a *PageQueryResultsCollector) ResultCount() int

func (*PageQueryResultsCollector) ResultsPerPage

func (a *PageQueryResultsCollector) ResultsPerPage() int