proxyapi

type APIConfig struct {
	SearchTimeout  time.Duration
	ExportTimeout  time.Duration
	QueryRateLimit float64
	EsVersion      string
	// GatewayAddr is grpc-gateway client address. Used for debugging purposes.
	GatewayAddr                       string
	AsyncSearchMaxDocumentsPerRequest int64
}

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

type DocumentsProcessor interface {
	ProcessDocuments(ctx context.Context, requestTime time.Time, readNext func() ([]byte, error)) (int, error)
}

type ExportServer interface {
	seqproxyapi.SeqProxyApi_ExportServer
}

type FetchServer interface {
	seqproxyapi.SeqProxyApi_FetchServer
}

type Ingestor struct {
	Config IngestorConfig

	BulkIngestor   *bulk.Ingestor
	SearchIngestor *search.Ingestor
	// contains filtered or unexported fields
}

type IngestorConfig struct {
	API    APIConfig
	Search search.Config
	Bulk   bulk.IngestorConfig
}

type MappingProvider interface {
	GetRawMapping() *seq.RawMapping
}

type RateLimiter interface {
	Account(string) bool
}

type SearchIngestor interface {
	Search(ctx context.Context, sr *search.SearchRequest, tr *querytracer.Tracer) (*seq.QPR, search.DocsIterator, time.Duration, error)
	Documents(ctx context.Context, r search.FetchRequest) (search.DocsIterator, error)
	Status(ctx context.Context) *search.IngestorStatus
	StartAsyncSearch(context.Context, search.AsyncRequest) (search.AsyncResponse, error)
	FetchAsyncSearchResult(context.Context, search.FetchAsyncSearchResultRequest) (search.FetchAsyncSearchResultResponse, search.DocsIterator, error)
	CancelAsyncSearch(ctx context.Context, id string) error
	DeleteAsyncSearch(ctx context.Context, id string) error
	GetAsyncSearchesList(context.Context, search.GetAsyncSearchesListRequest) ([]*search.AsyncSearchesListItem, error)
}