app

Documentation

Index

• func HttpMain(args *TextAnalyzerArgs)
• func NewIndexerMux(indexer *IndexingService) *http.ServeMux
• func PipeMain(args *TextAnalyzerArgs)
• func PprofStartCpuIfRequired(args *TextAnalyzerArgs)
• func PprofStartStandaloneServer(port int, oncomplete func()) *http.Server
• func PprofWriteMemoryIfRequired(args *TextAnalyzerArgs)
• func SetupIndexerMux(mux *http.ServeMux, indexer *IndexingService)
• type HttpHandler
  • func IndexHandler(indexer *IndexingService) HttpHandler
  • func ResetHandler(indexer *IndexingService) HttpHandler
  • func StatHandler(config *TextAnalyzerArgs, indexer *IndexingService) HttpHandler
• type IndexingService
  • func NewIndexService(args *TextAnalyzerArgs) *IndexingService
  • func (t *IndexingService) Find(size int, filter *index.TermFilter) []index.TermStat
  • func (t *IndexingService) Index(part int, text string)
  • func (t *IndexingService) Reset()
• type NonFlagsAnalyzerConfig
• type PprofHttpMode
• type TextAnalyzerArgs
  • func NewTextAnalyzerArgsF() *TextAnalyzerArgs
  • func NewTextAnalyzerArgsNF(config NonFlagsAnalyzerConfig) *TextAnalyzerArgs
  • func (a *TextAnalyzerArgs) Cpuprof() string
  • func (a *TextAnalyzerArgs) Debug() bool
  • func (a *TextAnalyzerArgs) GetCollectorConfig() index.CollectConfig
  • func (a *TextAnalyzerArgs) GetReadMode() index.ReadMode
  • func (a *TextAnalyzerArgs) GetStatisticsFilter() *index.TermFilter
  • func (a *TextAnalyzerArgs) Http() int
  • func (a *TextAnalyzerArgs) IsHttpMode() bool
  • func (a *TextAnalyzerArgs) Json() bool
  • func (a *TextAnalyzerArgs) Memprof() string
  • func (a TextAnalyzerArgs) Minlen() int
  • func (a TextAnalyzerArgs) Nonfreq() bool
  • func (a *TextAnalyzerArgs) Parse()
  • func (a *TextAnalyzerArgs) PprofHttpMode() PprofHttpMode
  • func (a *TextAnalyzerArgs) Pprofhttp() int
  • func (a TextAnalyzerArgs) Size() int
  • func (a TextAnalyzerArgs) UseFirst() bool
  • func (a TextAnalyzerArgs) UseLast() bool

Functions

func HttpMain

func HttpMain(args *TextAnalyzerArgs)

func NewIndexerMux

func NewIndexerMux(indexer *IndexingService) *http.ServeMux

func PipeMain

func PipeMain(args *TextAnalyzerArgs)

func PprofStartCpuIfRequired

func PprofStartCpuIfRequired(args *TextAnalyzerArgs)

запускает мониторинг CPU если в аргументах указан файл для хранения результата

func PprofStartStandaloneServer

func PprofStartStandaloneServer(port int, oncomplete func()) *http.Server

стартует сервер, позволяет вызвать колбак после окончания его работы

func PprofWriteMemoryIfRequired

func PprofWriteMemoryIfRequired(args *TextAnalyzerArgs)

выполняет мониторинг памяти в конце работы приложения если настроен соответствующий файл

func SetupIndexerMux

func SetupIndexerMux(mux *http.ServeMux, indexer *IndexingService)

Types

type HttpHandler

type HttpHandler func(writer http.ResponseWriter, request *http.Request)

func IndexHandler

func IndexHandler(indexer *IndexingService) HttpHandler

func ResetHandler

func ResetHandler(indexer *IndexingService) HttpHandler

func StatHandler

func StatHandler(config *TextAnalyzerArgs, indexer *IndexingService) HttpHandler

type IndexingService

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

IndexingService сервис индексации входящих запросов с текстами, используется в Http

func NewIndexService

func NewIndexService(args *TextAnalyzerArgs) *IndexingService

NewIndexService создать и инициализировать новый сервис индексации

func (*IndexingService) Find

func (t *IndexingService) Find(size int, filter *index.TermFilter) []index.TermStat

Find возврат top size элементов из индекса

func (*IndexingService) Index

func (t *IndexingService) Index(part int, text string)

Index индексация переданного текста в текущей коллекции

func (*IndexingService) Reset

func (t *IndexingService) Reset()

Reset сброс состояния текущего индекса

type NonFlagsAnalyzerConfig

type NonFlagsAnalyzerConfig struct {
	Size      int
	Minlen    int
	UseFirst  bool
	UseLast   bool
	Nonfreq   bool
	Json      bool
	Cpuprof   string
	Memprof   string
	Debug     bool
	Http      int
	Pprofhttp string
}

type PprofHttpMode

type PprofHttpMode int

const (
	PPROF_NONE PprofHttpMode = 0
	PPROF_SELF PprofHttpMode = 1
	PPROF_MAIN PprofHttpMode = 2
)

type TextAnalyzerArgs

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

func NewTextAnalyzerArgsF

func NewTextAnalyzerArgsF() *TextAnalyzerArgs

func NewTextAnalyzerArgsNF

func NewTextAnalyzerArgsNF(config NonFlagsAnalyzerConfig) *TextAnalyzerArgs

func (*TextAnalyzerArgs) Cpuprof

func (a *TextAnalyzerArgs) Cpuprof() string

func (*TextAnalyzerArgs) Debug

func (a *TextAnalyzerArgs) Debug() bool

func (*TextAnalyzerArgs) GetCollectorConfig

func (a *TextAnalyzerArgs) GetCollectorConfig() index.CollectConfig

func (*TextAnalyzerArgs) GetReadMode

func (a *TextAnalyzerArgs) GetReadMode() index.ReadMode

func (*TextAnalyzerArgs) GetStatisticsFilter

func (a *TextAnalyzerArgs) GetStatisticsFilter() *index.TermFilter

func (*TextAnalyzerArgs) Http

func (a *TextAnalyzerArgs) Http() int

func (*TextAnalyzerArgs) IsHttpMode

func (a *TextAnalyzerArgs) IsHttpMode() bool

func (*TextAnalyzerArgs) Json

func (a *TextAnalyzerArgs) Json() bool

func (*TextAnalyzerArgs) Memprof

func (a *TextAnalyzerArgs) Memprof() string

func (TextAnalyzerArgs) Minlen

func (a TextAnalyzerArgs) Minlen() int

func (TextAnalyzerArgs) Nonfreq

func (a TextAnalyzerArgs) Nonfreq() bool

func (*TextAnalyzerArgs) Parse

func (a *TextAnalyzerArgs) Parse()

func (*TextAnalyzerArgs) PprofHttpMode

func (a *TextAnalyzerArgs) PprofHttpMode() PprofHttpMode

func (*TextAnalyzerArgs) Pprofhttp

func (a *TextAnalyzerArgs) Pprofhttp() int

func (TextAnalyzerArgs) Size

func (a TextAnalyzerArgs) Size() int

func (TextAnalyzerArgs) UseFirst

func (a TextAnalyzerArgs) UseFirst() bool

func (TextAnalyzerArgs) UseLast

func (a TextAnalyzerArgs) UseLast() bool