Documentation
¶
Index ¶
- Constants
- func NewClient(store *Store) storeapi.StoreApiClient
- type APIConfig
- type BulkConfig
- type FetchConfig
- type FilterConfig
- type GrpcV1
- func (g *GrpcV1) Bulk(ctx context.Context, req *storeapi.BulkRequest) (*emptypb.Empty, error)
- func (g *GrpcV1) CancelAsyncSearch(_ context.Context, r *storeapi.CancelAsyncSearchRequest) (*storeapi.CancelAsyncSearchResponse, error)
- func (g *GrpcV1) DeleteAsyncSearch(_ context.Context, r *storeapi.DeleteAsyncSearchRequest) (*storeapi.DeleteAsyncSearchResponse, error)
- func (g *GrpcV1) Fetch(req *storeapi.FetchRequest, stream storeapi.StoreApi_FetchServer) error
- func (g *GrpcV1) FetchAsyncSearchResult(_ context.Context, r *storeapi.FetchAsyncSearchResultRequest) (*storeapi.FetchAsyncSearchResultResponse, error)
- func (g *GrpcV1) GetAsyncSearchesList(_ context.Context, r *storeapi.GetAsyncSearchesListRequest) (*storeapi.GetAsyncSearchesListResponse, error)
- func (g *GrpcV1) Search(ctx context.Context, req *storeapi.SearchRequest) (*storeapi.SearchResponse, error)
- func (g *GrpcV1) StartAsyncSearch(_ context.Context, r *storeapi.StartAsyncSearchRequest) (*storeapi.StartAsyncSearchResponse, error)
- func (g *GrpcV1) Status(_ context.Context, _ *storeapi.StatusRequest) (*storeapi.StatusResponse, error)
- type MappingProvider
- type SearchConfig
- type Store
- type StoreConfig
Constants ¶
View Source
const ( StoreModeHot = "hot" StoreModeCold = "cold" )
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient(store *Store) storeapi.StoreApiClient
Types ¶
type APIConfig ¶
type APIConfig struct {
StoreMode string
Bulk BulkConfig
Search SearchConfig
Fetch FetchConfig
Filter FilterConfig
}
type BulkConfig ¶
type FetchConfig ¶
type FilterConfig ¶ added in v0.61.0
type GrpcV1 ¶
type GrpcV1 struct {
storeapi.UnimplementedStoreApiServer
// contains filtered or unexported fields
}
func NewGrpcV1 ¶
func NewGrpcV1(cfg APIConfig, fracManager *fracmanager.FracManager, mappingProvider MappingProvider) *GrpcV1
func (*GrpcV1) CancelAsyncSearch ¶ added in v0.59.0
func (g *GrpcV1) CancelAsyncSearch( _ context.Context, r *storeapi.CancelAsyncSearchRequest, ) (*storeapi.CancelAsyncSearchResponse, error)
func (*GrpcV1) DeleteAsyncSearch ¶ added in v0.59.0
func (g *GrpcV1) DeleteAsyncSearch( _ context.Context, r *storeapi.DeleteAsyncSearchRequest, ) (*storeapi.DeleteAsyncSearchResponse, error)
func (*GrpcV1) Fetch ¶
func (g *GrpcV1) Fetch(req *storeapi.FetchRequest, stream storeapi.StoreApi_FetchServer) error
func (*GrpcV1) FetchAsyncSearchResult ¶
func (g *GrpcV1) FetchAsyncSearchResult( _ context.Context, r *storeapi.FetchAsyncSearchResultRequest, ) (*storeapi.FetchAsyncSearchResultResponse, error)
func (*GrpcV1) GetAsyncSearchesList ¶ added in v0.59.0
func (g *GrpcV1) GetAsyncSearchesList( _ context.Context, r *storeapi.GetAsyncSearchesListRequest, ) (*storeapi.GetAsyncSearchesListResponse, error)
func (*GrpcV1) Search ¶
func (g *GrpcV1) Search(ctx context.Context, req *storeapi.SearchRequest) (*storeapi.SearchResponse, error)
func (*GrpcV1) StartAsyncSearch ¶
func (g *GrpcV1) StartAsyncSearch( _ context.Context, r *storeapi.StartAsyncSearchRequest, ) (*storeapi.StartAsyncSearchResponse, error)
func (*GrpcV1) Status ¶
func (g *GrpcV1) Status(_ context.Context, _ *storeapi.StatusRequest) (*storeapi.StatusResponse, error)
type MappingProvider ¶
type SearchConfig ¶
type SearchConfig struct {
WorkersCount int
MaxFractionHits int
FractionsPerIteration int
RequestsLimit uint64
LogThreshold time.Duration
Async asyncsearcher.AsyncSearcherConfig
}
type Store ¶
type Store struct {
Config StoreConfig
FracManager *fracmanager.FracManager
// contains filtered or unexported fields
}
func NewStore ¶
func NewStore(ctx context.Context, c StoreConfig, s3cli *s3.Client, mappingProvider MappingProvider) (*Store, error)
func (*Store) OffloadAll ¶ added in v0.60.0
func (s *Store) OffloadAll()
func (*Store) ResetCache ¶
func (s *Store) ResetCache()
type StoreConfig ¶
type StoreConfig struct {
API APIConfig
FracManager fracmanager.Config
}
Click to show internal directories.
Click to hide internal directories.